Package org.apache.tika.pipes.pipesiterator.s3

Class S3PipesIterator

java.lang.Object

org.apache.tika.config.ConfigBase

org.apache.tika.pipes.pipesiterator.PipesIterator

org.apache.tika.pipes.pipesiterator.s3.S3PipesIterator

All Implemented Interfaces:

Iterable<FetchEmitTuple>, Callable<Integer>, Initializable

public class S3PipesIterator
extends PipesIterator
implements Initializable

Field Summary

Fields inherited from class org.apache.tika.pipes.pipesiterator.PipesIterator

COMPLETED_SEMAPHORE, DEFAULT_MAX_WAIT_MS, DEFAULT_QUEUE_SIZE

Constructor Summary

Constructors

Constructor	Description
S3PipesIterator()

Method Summary

Modifier and Type	Method	Description
void	checkInitialization(InitializableProblemHandler problemHandler)
protected void	enqueue()
void	initialize(Map<String,Param> params)	This initializes the s3 client.
void	setBucket(String bucket)
void	setCredentialsProvider(String credentialsProvider)
void	setFileNamePattern(String fileNamePattern)
void	setPrefix(String prefix)
void	setProfile(String profile)
void	setRegion(String region)

Methods inherited from class org.apache.tika.pipes.pipesiterator.PipesIterator

build, call, getEmitterName, getFetcherName, getHandlerConfig, getOnParseException, iterator, setEmitterName, setFetcherName, setHandlerType, setMaxEmbeddedResources, setMaxWaitMs, setOnParseException, setOnParseException, setParseMode, setParseMode, setQueueSize, setWriteLimit, tryToAdd

Methods inherited from class org.apache.tika.config.ConfigBase

buildComposite, buildComposite, buildSingle, buildSingle, configure, handleSettings

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

S3PipesIterator

public S3PipesIterator()

Method Detail

setBucket

@Field
public void setBucket(String bucket)

setRegion

@Field
public void setRegion(String region)

setProfile

@Field
public void setProfile(String profile)

setPrefix

@Field
public void setPrefix(String prefix)

setCredentialsProvider

@Field
public void setCredentialsProvider(String credentialsProvider)

setFileNamePattern

@Field
public void setFileNamePattern(String fileNamePattern)

initialize

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

This initializes the s3 client. Note, we wrap S3's RuntimeExceptions, e.g. AmazonClientException in a TikaConfigException.

Specified by:

initialize in interface Initializable

Overrides:

initialize in class PipesIterator

Parameters:

params - params to use for initialization

Throws:

TikaConfigException

checkInitialization

public void checkInitialization(InitializableProblemHandler problemHandler)
                         throws TikaConfigException

Specified by:

checkInitialization in interface Initializable

Overrides:

checkInitialization in class PipesIterator

Parameters:

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

Throws:

TikaConfigException

enqueue

protected void enqueue()
                throws InterruptedException,
                       IOException,
                       TimeoutException

Specified by:

enqueue in class PipesIterator

Throws:

InterruptedException

IOException

TimeoutException