public class ReaderBucket extends Object
| Constructor and Description |
|---|
ReaderBucket(AsyncClientInterface ots,
Semaphore semaphore,
TableStoreReaderConfig config,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback,
Executor executor,
ReaderStatistics statistics) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
addPrimaryKeyWithTable(PrimaryKeyWithTable pkWithTable,
ReaderGroup readerGroup) |
void |
addSignal(CountDownLatch latch,
ReaderEvent.EventType type) |
void |
close() |
com.lmax.disruptor.RingBuffer<ReaderEvent> |
getRingBuffer() |
void |
setCallback(TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback) |
void |
setRowQueryCriteria(RowQueryCriteria rowQueryCriteria) |
public ReaderBucket(AsyncClientInterface ots, Semaphore semaphore, TableStoreReaderConfig config, TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback, Executor executor, ReaderStatistics statistics)
public void setCallback(TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback)
public boolean addPrimaryKeyWithTable(PrimaryKeyWithTable pkWithTable, ReaderGroup readerGroup)
public void addSignal(CountDownLatch latch, ReaderEvent.EventType type)
public void setRowQueryCriteria(RowQueryCriteria rowQueryCriteria)
public com.lmax.disruptor.RingBuffer<ReaderEvent> getRingBuffer()
public void close()
Copyright © 2024. All Rights Reserved.