Package org.apache.tika.pipes.emitter.gcs

Class GCSEmitter

java.lang.Object

org.apache.tika.pipes.emitter.AbstractEmitter

org.apache.tika.pipes.emitter.gcs.GCSEmitter

All Implemented Interfaces:

Initializable, Emitter, StreamEmitter

public class GCSEmitter
extends AbstractEmitter
implements Initializable, StreamEmitter

Constructor Summary

Constructors

Constructor	Description
GCSEmitter()

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 gcs client.
void	setBucket(String bucket)
void	setFileExtension(String fileExtension)	If you want to customize the output file's file extension.
void	setPrefix(String prefix)
void	setProjectId(String projectId)

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 Details

GCSEmitter

public GCSEmitter()

Method Details

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:

metadataList -

Throws:

IOException

TikaException

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, not including the bucket

is - inputStream to copy

userMetadata - this will be written to the s3 ObjectMetadata's userMetadata

Throws:

TikaEmitterException - or IOexception if there is a Runtime s3 client exception

IOException

setProjectId

@Field
public void setProjectId(String projectId)

setBucket

@Field
public void setBucket(String bucket)

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 gcs 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