public class RowChangeEventHandler extends Object implements com.lmax.disruptor.EventHandler<RowChangeEvent>
构造器和说明 |
---|
RowChangeEventHandler(AsyncClientInterface ots,
WriterConfig writerConfig,
TableStoreCallback<RowChange,RowWriteResult> callback,
Executor executor,
DefaultWriterStatistics writerStatistics) |
限定符和类型 | 方法和说明 |
---|---|
void |
onEvent(RowChangeEvent rowChangeEvent,
long sequence,
boolean endOfBatch) |
void |
setCallback(TableStoreCallback<RowChange,RowWriteResult> callback) |
public RowChangeEventHandler(AsyncClientInterface ots, WriterConfig writerConfig, TableStoreCallback<RowChange,RowWriteResult> callback, Executor executor, DefaultWriterStatistics writerStatistics)
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 © 2019. All Rights Reserved.