Package org.apache.tika.pipes.async

Class AsyncConfig

java.lang.Object

org.apache.tika.config.ConfigBase

org.apache.tika.pipes.PipesConfigBase

org.apache.tika.pipes.async.AsyncConfig

public class AsyncConfig
extends PipesConfigBase

Field Summary

Fields inherited from class org.apache.tika.pipes.PipesConfigBase

DEFAULT_MAX_FILES_PROCESSED_PER_PROCESS, DEFAULT_MAX_FOR_EMIT_BATCH, DEFAULT_NUM_CLIENTS, DEFAULT_SHUTDOWN_CLIENT_AFTER_MILLS, DEFAULT_STALE_FETCHER_DELAY_SECONDS, DEFAULT_STALE_FETCHER_TIMEOUT_SECONDS, DEFAULT_STARTUP_TIMEOUT_MILLIS, DEFAULT_TIMEOUT_MILLIS

Constructor Summary

Constructors

Constructor	Description
AsyncConfig()

Method Summary

Modifier and Type	Method	Description
long	getEmitMaxEstimatedBytes()	When the emit queue hits this estimated size (sum of estimated extract sizes), emit the batch.
long	getEmitWithinMillis()
int	getNumEmitters()	Number of emitters
PipesReporter	getPipesReporter()
int	getQueueSize()	FetchEmitTuple queue size
boolean	isEmitIntermediateResults()
static AsyncConfig	load(Path p)
void	setEmitIntermediateResults(boolean emitIntermediateResults)
void	setEmitMaxEstimatedBytes(long emitMaxEstimatedBytes)
void	setEmitWithinMillis(long emitWithinMillis)	If nothing has been emitted in this amount of time and the getEmitMaxEstimatedBytes() has not been reached yet, emit what's in the emit queue.
void	setNumEmitters(int numEmitters)
void	setPipesReporter(PipesReporter pipesReporter)
void	setQueueSize(int queueSize)

Methods inherited from class org.apache.tika.pipes.PipesConfigBase

getForkedJvmArgs, getJavaPath, getMaxFilesProcessedPerProcess, getMaxForEmitBatchBytes, getNumClients, getShutdownClientAfterMillis, getSleepOnStartupTimeoutMillis, getStaleFetcherDelaySeconds, getStaleFetcherTimeoutSeconds, getStartupTimeoutMillis, getTikaConfig, getTimeoutMillis, setForkedJvmArgs, setJavaPath, setMaxFilesProcessedPerProcess, setMaxForEmitBatchBytes, setNumClients, setShutdownClientAfterMillis, setSleepOnStartupTimeoutMillis, setStaleFetcherDelaySeconds, setStaleFetcherTimeoutSeconds, setStartupTimeoutMillis, setTikaConfig, setTikaConfig, setTimeoutMillis

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

Constructor Detail

AsyncConfig

public AsyncConfig()

Method Detail

load

public static AsyncConfig load(Path p)
                        throws IOException,
                               TikaConfigException

Throws:

IOException

TikaConfigException

getEmitWithinMillis

public long getEmitWithinMillis()

setEmitWithinMillis

public void setEmitWithinMillis(long emitWithinMillis)

If nothing has been emitted in this amount of time and the getEmitMaxEstimatedBytes() has not been reached yet, emit what's in the emit queue.

Parameters:

emitWithinMillis -

getEmitMaxEstimatedBytes

public long getEmitMaxEstimatedBytes()

When the emit queue hits this estimated size (sum of estimated extract sizes), emit the batch.

Returns:

setEmitMaxEstimatedBytes

public void setEmitMaxEstimatedBytes(long emitMaxEstimatedBytes)

setNumEmitters

public void setNumEmitters(int numEmitters)

getQueueSize

public int getQueueSize()

FetchEmitTuple queue size

Returns:

setQueueSize

public void setQueueSize(int queueSize)

getNumEmitters

public int getNumEmitters()

Number of emitters

Returns:

getPipesReporter

public PipesReporter getPipesReporter()

setPipesReporter

public void setPipesReporter(PipesReporter pipesReporter)

setEmitIntermediateResults

public void setEmitIntermediateResults(boolean emitIntermediateResults)

isEmitIntermediateResults

public boolean isEmitIntermediateResults()