Class S3Emitter
java.lang.Object
org.apache.tika.plugins.AbstractTikaExtension
org.apache.tika.pipes.api.emitter.AbstractStreamEmitter
org.apache.tika.pipes.emitter.s3.S3Emitter
- All Implemented Interfaces:
Emitter, StreamEmitter, TikaExtension
Emitter to write to an existing S3 bucket.
Example JSON configuration:
{
"emitters": {
"s3-emitter": {
"my-s3": {
"region": "us-east-1",
"bucket": "my-bucket",
"credentialsProvider": "profile",
"profile": "my-profile",
"prefix": "output",
"fileExtension": "json",
"spoolToTemp": true
}
}
}
}
-
Field Summary
Fields inherited from class AbstractTikaExtension
pluginConfig -
Method Summary
Modifier and TypeMethodDescriptionstatic S3Emitterbuild(ExtensionConfig extensionConfig) voidemit(String path, InputStream is, Metadata userMetadata, ParseContext parseContext) voidemit(String emitKey, List<Metadata> metadataList, ParseContext parseContext) Methods inherited from class AbstractStreamEmitter
emitMethods inherited from class AbstractTikaExtension
getExtensionConfigMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface TikaExtension
getExtensionConfig
-
Method Details
-
build
public static S3Emitter build(ExtensionConfig extensionConfig) throws TikaConfigException, IOException - Throws:
TikaConfigExceptionIOException
-
emit
public void emit(String emitKey, List<Metadata> metadataList, ParseContext parseContext) throws IOException - Throws:
IOException
-
emit
public void emit(String path, InputStream is, Metadata userMetadata, ParseContext parseContext) throws IOException - Throws:
IOException
-