public class RowEventHandler extends Object implements com.lmax.disruptor.EventHandler<RowChangeEvent>
构造器和说明 |
---|
RowEventHandler(AsyncClientInterface ots,
BucketConfig bucketConfig,
WriterConfig writerConfig,
TableStoreCallback<RowChange,RowWriteResult> callback,
Executor executor,
WriterHandleStatistics writerStatistics,
Semaphore semaphore) |
限定符和类型 | 方法和说明 |
---|---|
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
在接口中 com.lmax.disruptor.EventHandler<RowChangeEvent>
Exception
Copyright © 2021. All Rights Reserved.