public class RowEventHandler extends Object implements com.lmax.disruptor.EventHandler<RowChangeEvent>
| Constructor and Description |
|---|
RowEventHandler(AsyncClientInterface ots,
BucketConfig bucketConfig,
WriterConfig writerConfig,
TableStoreCallback<RowChange,RowWriteResult> callback,
Executor executor,
WriterHandleStatistics writerStatistics,
Semaphore semaphore) |
| Modifier and Type | Method and Description |
|---|---|
void |
onEvent(RowChangeEvent rowChangeEvent,
long sequence,
boolean endOfBatch) |
void |
setCallback(TableStoreCallback<RowChange,RowWriteResult> callback) |
public RowEventHandler(AsyncClientInterface ots, BucketConfig bucketConfig, WriterConfig writerConfig, TableStoreCallback<RowChange,RowWriteResult> callback, Executor executor, WriterHandleStatistics writerStatistics, Semaphore semaphore)
public void setCallback(TableStoreCallback<RowChange,RowWriteResult> callback)
public void onEvent(RowChangeEvent rowChangeEvent, long sequence, boolean endOfBatch) throws Exception
onEvent in interface com.lmax.disruptor.EventHandler<RowChangeEvent>ExceptionCopyright © 2024. All Rights Reserved.