public class RowChangeEventHandler extends Object implements com.lmax.disruptor.EventHandler<RowChangeEvent>
构造器和说明 |
---|
RowChangeEventHandler(AsyncClientInterface ots,
WriterConfig writerConfig,
TableStoreCallback<RowChange,ConsumedCapacity> callback,
Executor executor,
DefaultWriterStatistics writerStatistics) |
public RowChangeEventHandler(AsyncClientInterface ots, WriterConfig writerConfig, TableStoreCallback<RowChange,ConsumedCapacity> callback, Executor executor, DefaultWriterStatistics writerStatistics)
public void onEvent(RowChangeEvent rowChangeEvent, long sequence, boolean endOfBatch) throws Exception
onEvent
在接口中 com.lmax.disruptor.EventHandler<RowChangeEvent>
Exception
Copyright © 2017. All Rights Reserved.