Package com.illumon.iris.db.tables.dataimport

Class BatchedRowBufferProcessorFactory

java.lang.Object

com.illumon.iris.db.tables.dataimport.BatchedRowBufferProcessorFactory

public final class BatchedRowBufferProcessorFactory
extends Object

Factory used by the DIS to create a row batched listener.

This can be backed by either the IntradayLoggerFactory or the V2RowBatchListenerFactory.

Method Summary

Modifier and Type	Method	Description
static <LISTENER_TYPE extends BatchedImportRowBufferProcessor> LISTENER_TYPE	makeBatchedImportRowBufferProcessor(SchemaXml schema, TableDefinition tableDefinition, int applicationVersion, int rowBatchCapacity, int parallelism)	Create an appropriate row batched listener for the given schema and application version.

Methods inherited from class java.lang.Object

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

Method Details

makeBatchedImportRowBufferProcessor

public static <LISTENER_TYPE extends BatchedImportRowBufferProcessor>
LISTENER_TYPE makeBatchedImportRowBufferProcessor(@NotNull
 SchemaXml schema,
 @NotNull
 TableDefinition tableDefinition,
 int applicationVersion,
 int rowBatchCapacity,
 int parallelism)

Create an appropriate row batched listener for the given schema and application version.

If the application version is zero, and no default version is specified the highest numbered listener version is used. If two listeners are defined for the same version, the schema is ambiguous and an Exception is thrown.

Type Parameters:

LISTENER_TYPE - the type of the listener being returned

Parameters:

schema - the relevant schema we are generating a listener for

tableDefinition - the table definition we are writing

applicationVersion - the application version of the binary log file we are processing

rowBatchCapacity - the number of rows in each batch that is processed

parallelism - the amount of parallelism the listener is configured for

Returns:

a row batched listener