public class Bucket extends Object
构造器和说明 |
---|
Bucket(BucketConfig bucketConfig,
AsyncClientInterface ots,
WriterConfig writerConfig,
TableStoreCallback<RowChange,RowWriteResult> resultCallback,
Executor executor,
WriterHandleStatistics writerStatistics,
Semaphore semaphore) |
限定符和类型 | 方法和说明 |
---|---|
boolean |
addRowChange(RowChange rowChange,
Group group) |
void |
addSignal(CountDownLatch latch) |
void |
close() |
int |
getId() |
com.lmax.disruptor.RingBuffer<RowChangeEvent> |
getRingBuffer() |
void |
setResultCallback(TableStoreCallback<RowChange,RowWriteResult> resultCallback) |
public Bucket(BucketConfig bucketConfig, AsyncClientInterface ots, WriterConfig writerConfig, TableStoreCallback<RowChange,RowWriteResult> resultCallback, Executor executor, WriterHandleStatistics writerStatistics, Semaphore semaphore)
public void setResultCallback(TableStoreCallback<RowChange,RowWriteResult> resultCallback)
public void addSignal(CountDownLatch latch)
public void close()
public int getId()
public com.lmax.disruptor.RingBuffer<RowChangeEvent> getRingBuffer()
Copyright © 2021. All Rights Reserved.