public class TimeseriesRowEventHandler extends Object implements com.lmax.disruptor.EventHandler<TimeseriesRowEvent>
| Constructor and Description |
|---|
TimeseriesRowEventHandler(AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig timeseriesWriterConfig,
TimeseriesBucketConfig timeseriesBucketConfig,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
Semaphore semaphore) |
| Modifier and Type | Method and Description |
|---|---|
void |
onEvent(TimeseriesRowEvent timeseriesRowEvent,
long l,
boolean b) |
void |
setCallback(TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback) |
public TimeseriesRowEventHandler(AsyncTimeseriesClientInterface ots, TimeseriesWriterConfig timeseriesWriterConfig, TimeseriesBucketConfig timeseriesBucketConfig, TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback, Executor executor, TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics, Semaphore semaphore)
public void setCallback(TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback)
public void onEvent(TimeseriesRowEvent timeseriesRowEvent, long l, boolean b) throws Exception
onEvent in interface com.lmax.disruptor.EventHandler<TimeseriesRowEvent>ExceptionCopyright © 2024. All Rights Reserved.