com.arakelian.elastic.model

Class BulkIndexerConfig

java.lang.Object

com.arakelian.elastic.model.BulkIndexerConfig

@Value.Immutable(copy=false)
public abstract class BulkIndexerConfig
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	ONE_MEGABYTE

Constructor Summary

Constructors

Constructor and Description
BulkIndexerConfig()

Method Summary

Modifier and Type	Method and Description
protected void	checkSettings()
int	getAutomaticFlushMillis() Returns the number of milliseconds to wait before automatically flushing the bulk queue.
abstract BulkOperationFactory	getBulkOperationFactory()
IndexerListener	getListener()
int	getMaxBulkOperationBytes() Returns the maximum size of a bulk operation (in bytes)
int	getMaxBulkOperations() Returns the maximum size of a bulk operation (in documents)
int	getMaximumThreads()
int	getQueueSize()
int	getRetryDelayMillis()
com.github.rholder.retry.Retryer<BulkResponse>	getRetryer()
int	getShutdownTimeout()
java.util.concurrent.TimeUnit	getShutdownTimeoutUnit()
boolean	isBlockingQueue() Returns true if caller should block when indexer queue is full.

Methods inherited from class java.lang.Object

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

Field Detail

ONE_MEGABYTE

public static final int ONE_MEGABYTE

See Also:

Constant Field Values

Constructor Detail

BulkIndexerConfig

public BulkIndexerConfig()

Method Detail

getAutomaticFlushMillis

@Value.Default
public int getAutomaticFlushMillis()

Returns the number of milliseconds to wait before automatically flushing the bulk queue. If this is zero or negative, the bulk queue is never automatically flushed.

Returns:

number of milliseconds to wait before automatically flushing the bulk queue.

getBulkOperationFactory

@Value.Auxiliary
public abstract BulkOperationFactory getBulkOperationFactory()

getListener

@Value.Default
 @Value.Auxiliary
public IndexerListener getListener()

getMaxBulkOperationBytes

@Value.Default
public int getMaxBulkOperationBytes()

Returns the maximum size of a bulk operation (in bytes)

Returns:

maximum size of a bulk operation

getMaxBulkOperations

@Value.Default
public int getMaxBulkOperations()

Returns the maximum size of a bulk operation (in documents)

Returns:

maximum size of a batch operation (in documents)

getMaximumThreads

@Value.Default
public int getMaximumThreads()

getQueueSize

@Value.Default
public int getQueueSize()

getRetryDelayMillis

@Value.Default
public int getRetryDelayMillis()

getRetryer

@Value.Default
 @Value.Auxiliary
public com.github.rholder.retry.Retryer<BulkResponse> getRetryer()

getShutdownTimeout

@Value.Default
public int getShutdownTimeout()

getShutdownTimeoutUnit

@Value.Default
public java.util.concurrent.TimeUnit getShutdownTimeoutUnit()

isBlockingQueue

@Value.Default
public boolean isBlockingQueue()

Returns true if caller should block when indexer queue is full.

Returns:

true if caller should block when indexer queue is full.

checkSettings

@Value.Check
protected void checkSettings()