Package org.voltdb.stream.api.volt

Class BulkVoltStreamSinkConfigurator

java.lang.Object

org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator<Object[],BulkVoltStreamSinkConfigurator>

org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator

All Implemented Interfaces:

OperatorConfigurator, VoltStreamSinkConfigurator<Object[]>

public class BulkVoltStreamSinkConfigurator
extends AbstractVoltStreamSinkConfigurator<Object[],BulkVoltStreamSinkConfigurator>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_TABLE_NAME
static final int	FLUSH_INTERVAL
static final int	MAX_BATCH_SIZE

Fields inherited from class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator

DEFAULT_HOST, VOLTDB_CLIENT_PORT

Constructor Summary

Constructors

Constructor	Description
BulkVoltStreamSinkConfigurator()
BulkVoltStreamSinkConfigurator(int batchSize, int flushInterval, String tableName)

Method Summary

Modifier and Type	Method	Description
static BulkVoltStreamSinkConfigurator	aSink()
int	getBatchSize()
int	getFlushInterval()
VoltBulkOperationType	getOperationType()
String	getTableName()
BulkVoltStreamSinkConfigurator	withBatchSize(int batchSize)
BulkVoltStreamSinkConfigurator	withFlushInterval(int flushInterval)
BulkVoltStreamSinkConfigurator	withOperationType(VoltBulkOperationType operationType)
BulkVoltStreamSinkConfigurator	withTableName(String tableName)

Methods inherited from class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator

emptyToNull, fromHostPortProperties, getExceptionHandler, getHostAndPorts, self, withExceptionHandler, withHostAndPort, withHostAndStandardPort

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.voltdb.stream.api.extension.OperatorConfigurator

configure, getConfiguration

Field Details

MAX_BATCH_SIZE

public static final int MAX_BATCH_SIZE

FLUSH_INTERVAL

public static final int FLUSH_INTERVAL

DEFAULT_TABLE_NAME

public static final String DEFAULT_TABLE_NAME

Constructor Details

BulkVoltStreamSinkConfigurator

public BulkVoltStreamSinkConfigurator()

BulkVoltStreamSinkConfigurator

public BulkVoltStreamSinkConfigurator(int batchSize,
 int flushInterval,
 String tableName)

Method Details

aSink

public static BulkVoltStreamSinkConfigurator aSink()

withBatchSize

public BulkVoltStreamSinkConfigurator withBatchSize(int batchSize)

withFlushInterval

public BulkVoltStreamSinkConfigurator withFlushInterval(int flushInterval)

withTableName

public BulkVoltStreamSinkConfigurator withTableName(String tableName)

withOperationType

public BulkVoltStreamSinkConfigurator withOperationType(VoltBulkOperationType operationType)

getTableName

public String getTableName()

getBatchSize

public int getBatchSize()

getFlushInterval

public int getFlushInterval()

getOperationType

public VoltBulkOperationType getOperationType()