Package org.apache.tika.pipes.emitter.s3

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

public class S3Emitter
extends AbstractStreamEmitter

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 org.apache.tika.plugins.AbstractTikaExtension

pluginConfig

Method Summary

Modifier and Type	Method	Description
static S3Emitter	build(ExtensionConfig extensionConfig)
void	emit(String path, InputStream is, Metadata userMetadata, ParseContext parseContext)
void	emit(String emitKey, List<Metadata> metadataList, ParseContext parseContext)

Methods inherited from class org.apache.tika.pipes.api.emitter.AbstractStreamEmitter

emit

Methods inherited from class org.apache.tika.plugins.AbstractTikaExtension

getExtensionConfig

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.plugins.TikaExtension

getExtensionConfig

Method Details

build

public static S3Emitter build(ExtensionConfig extensionConfig)
                       throws TikaConfigException,
IOException

Throws:

TikaConfigException

IOException

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