public class ReaderEventHandler extends Object implements com.lmax.disruptor.EventHandler<ReaderEvent>
| Constructor and Description |
|---|
ReaderEventHandler(AsyncClientInterface ots,
TableStoreReaderConfig config,
Executor executor,
Semaphore callbackSemaphore,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback,
ReaderStatistics statistics) |
| Modifier and Type | Method and Description |
|---|---|
void |
onEvent(ReaderEvent readerEvent,
long l,
boolean b) |
void |
setCallback(TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback) |
void |
setRowQueryCriteria(RowQueryCriteria rowQueryCriteria) |
public ReaderEventHandler(AsyncClientInterface ots, TableStoreReaderConfig config, Executor executor, Semaphore callbackSemaphore, TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback, ReaderStatistics statistics)
public void onEvent(ReaderEvent readerEvent, long l, boolean b) throws Exception
onEvent in interface com.lmax.disruptor.EventHandler<ReaderEvent>Exceptionpublic void setRowQueryCriteria(RowQueryCriteria rowQueryCriteria)
public void setCallback(TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback)
Copyright © 2024. All Rights Reserved.