public class TimeseriesBucket extends Object
| Constructor and Description |
|---|
TimeseriesBucket(TimeseriesBucketConfig timeseriesBucketConfig,
AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig timeseriesWriterConfig,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
Semaphore semaphore) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
addRowChange(TimeseriesTableRow timeseriesTableRow,
TimeseriesGroup timeseriesGroup) |
void |
addSignal(CountDownLatch latch) |
void |
close() |
int |
getId() |
com.lmax.disruptor.RingBuffer<TimeseriesRowEvent> |
getRingBuffer() |
void |
setResultCallback(TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback) |
public TimeseriesBucket(TimeseriesBucketConfig timeseriesBucketConfig, AsyncTimeseriesClientInterface ots, TimeseriesWriterConfig timeseriesWriterConfig, TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback, Executor executor, TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics, Semaphore semaphore)
public void setResultCallback(TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback)
public boolean addRowChange(TimeseriesTableRow timeseriesTableRow, TimeseriesGroup timeseriesGroup)
public void addSignal(CountDownLatch latch)
public void close()
public int getId()
public com.lmax.disruptor.RingBuffer<TimeseriesRowEvent> getRingBuffer()
Copyright © 2024. All Rights Reserved.