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

Constructor Summary

Constructors

Constructor and Description
AsyncConfig()

Method Summary

Modifier and Type	Method and Description
long	getEmitMaxEstimatedBytes() When the emit queue hits this estimated size (sum of estimated extract sizes), emit the batch.
long	getEmitWithinMillis()
long	getMaxForEmitBatchBytes() What is the maximum bytes size per extract that will be allowed in the emit queue.
int	getNumEmitters() Number of emitters
int	getQueueSize() FetchEmitTuple queue size
static AsyncConfig	load(Path p)
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	setMaxForEmitBatchBytes(long maxForEmitBatchBytes)
void	setNumEmitters(int numEmitters)
void	setQueueSize(int queueSize)

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

getForkedJvmArgs, getJavaPath, getMaxFilesProcessed, getNumClients, getShutdownClientAfterMillis, getStartupTimeoutMillis, getTikaConfig, getTimeoutMillis, setForkedJvmArgs, setJavaPath, setMaxFilesProcessed, setNumClients, setShutdownClientAfterMillis, setTikaConfig, setTikaConfig, setTimeoutMillis

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

buildComposite, buildComposite, 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)

getMaxForEmitBatchBytes

public long getMaxForEmitBatchBytes()

What is the maximum bytes size per extract that will be allowed in the emit queue. If an extract is too big, skip the emit queue and forward it directly from the processor. If set to 0, this will never send an extract back for batch emitting, but will emit the extract directly from the processor.

Returns:

setMaxForEmitBatchBytes

public void setMaxForEmitBatchBytes(long maxForEmitBatchBytes)

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: