Package org.apache.tika.pipes.emitter.azblob

Class AZBlobEmitter

java.lang.Object

org.apache.tika.pipes.emitter.AbstractEmitter

org.apache.tika.pipes.emitter.azblob.AZBlobEmitter

All Implemented Interfaces:

Initializable, Emitter, StreamEmitter

public class AZBlobEmitter
extends AbstractEmitter
implements Initializable, StreamEmitter

Emit files to Azure blob storage. Must set endpoint, sasToken and container via config.

Constructor Summary

Constructors

Constructor	Description
AZBlobEmitter()

Method Summary

Modifier and Type	Method	Description
void	checkInitialization(InitializableProblemHandler problemHandler)
void	emit(String path, InputStream is, Metadata userMetadata, ParseContext parseContext)
void	emit(String emitKey, List<Metadata> metadataList, ParseContext parseContext)	Requires the src-bucket/path/to/my/file.txt in the TikaCoreProperties.SOURCE_PATH.
void	initialize(Map<String,Param> params)	This initializes the az blob container client
void	setContainer(String container)
void	setEndpoint(String endpoint)
void	setFileExtension(String fileExtension)	If you want to customize the output file's file extension.
void	setOverwriteExisting(boolean overwriteExisting)
void	setPrefix(String prefix)
void	setSasToken(String sasToken)

Methods inherited from class org.apache.tika.pipes.emitter.AbstractEmitter

emit, getName, setName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.tika.pipes.emitter.Emitter

emit, getName

Constructor Detail

AZBlobEmitter

public AZBlobEmitter()

Method Detail

emit

public void emit(String emitKey,
                 List<Metadata> metadataList,
                 ParseContext parseContext)
          throws IOException,
                 TikaEmitterException

Requires the src-bucket/path/to/my/file.txt in the TikaCoreProperties.SOURCE_PATH.

Specified by:

emit in interface Emitter

Parameters:

emitKey -

metadataList -

parseContext -

Throws:

IOException

TikaEmitterException

emit

public void emit(String path,
                 InputStream is,
                 Metadata userMetadata,
                 ParseContext parseContext)
          throws IOException,
                 TikaEmitterException

Specified by:

emit in interface StreamEmitter

Parameters:

path - object path; prefix will be prepended

is - inputStream to copy, if a TikaInputStream contains an underlying file, the client will upload the file; if a content-length is included in the metadata, the client will upload the stream with the content-length; otherwise, the client will copy the stream to a byte array and then upload.

userMetadata - this will be written to the az blob's properties.metadata

parseContext -

Throws:

IOException - if there is a Runtime client exception

TikaEmitterException - if there is a Runtime client exception

setSasToken

@Field
public void setSasToken(String sasToken)

setEndpoint

@Field
public void setEndpoint(String endpoint)

setContainer

@Field
public void setContainer(String container)

setOverwriteExisting

@Field
public void setOverwriteExisting(boolean overwriteExisting)

setPrefix

@Field
public void setPrefix(String prefix)

setFileExtension

@Field
public void setFileExtension(String fileExtension)

If you want to customize the output file's file extension. Do not include the "."

Parameters:

fileExtension -

initialize

public void initialize(Map<String,Param> params)
                throws TikaConfigException

This initializes the az blob container client

Specified by:

initialize in interface Initializable

Parameters:

params - params to use for initialization

Throws:

TikaConfigException

checkInitialization

public void checkInitialization(InitializableProblemHandler problemHandler)
                         throws TikaConfigException

Specified by:

checkInitialization in interface Initializable

Parameters:

problemHandler - if there is a problem and no custom initializableProblemHandler has been configured via Initializable parameters, this is called to respond.

Throws:

TikaConfigException