public class DefaultTableStoreTimeseriesWriter extends Object implements TableStoreTimeseriesWriter
| Constructor and Description |
|---|
DefaultTableStoreTimeseriesWriter(AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig config,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Executor executor)
时序表writer
|
DefaultTableStoreTimeseriesWriter(String endpoint,
ServiceCredentials credentials,
String instanceName,
TimeseriesWriterConfig config,
ClientConfiguration cc,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback)
推荐使用的时序表writer
|
DefaultTableStoreTimeseriesWriter(String endpoint,
ServiceCredentials credentials,
String instanceName,
TimeseriesWriterConfig config,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback)
推荐使用的时序表writer
|
public DefaultTableStoreTimeseriesWriter(AsyncTimeseriesClientInterface ots, TimeseriesWriterConfig config, TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback, Executor executor)
ots - 异步时序表客户端实例config - writer的配置callback - 行级别回调executor - 线程池public DefaultTableStoreTimeseriesWriter(String endpoint, ServiceCredentials credentials, String instanceName, TimeseriesWriterConfig config, TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback)
endpoint - 实例域名credentials - 认证信息:含AK,也支持tokeninstanceName - 实例名config - writer的配置resultCallback - 行级别回调public DefaultTableStoreTimeseriesWriter(String endpoint, ServiceCredentials credentials, String instanceName, TimeseriesWriterConfig config, ClientConfiguration cc, TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback)
endpoint - 实例域名credentials - 认证信息:含AK,也支持tokeninstanceName - 实例名config - writer的配置cc - 客户端的配置resultCallback - 行级别回调public void startFlushTimer(int flushInterval)
public void addTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) throws ClientException
addTimeseriesRowChange in interface TableStoreTimeseriesWriterClientExceptionpublic boolean addTimeseriesRowInternal(TimeseriesTableRow timeseriesTableRow, TimeseriesGroup timeseriesGroup)
public Future<TimeseriesWriterResult> addTimeseriesRowChangeWithFuture(TimeseriesTableRow timeseriesTableRow) throws ClientException
addTimeseriesRowChangeWithFuture in interface TableStoreTimeseriesWritertimeseriesTableRow - 时序表数据ClientExceptionpublic boolean tryAddTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) throws ClientException
tryAddTimeseriesRowChange in interface TableStoreTimeseriesWriterClientExceptionpublic void addTimeseriesRowChange(List<TimeseriesTableRow> timeseriesTableRows, List<TimeseriesTableRow> dirtyTimeseriesTableRows) throws ClientException
addTimeseriesRowChange in interface TableStoreTimeseriesWriterClientExceptionpublic Future<TimeseriesWriterResult> addTimeseriesRowChangeWithFuture(List<TimeseriesTableRow> timeseriesTableRows) throws ClientException
addTimeseriesRowChangeWithFuture in interface TableStoreTimeseriesWritertimeseriesTableRows - 时序表数据ListClientExceptionpublic void setResultCallback(TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback)
setResultCallback in interface TableStoreTimeseriesWriterpublic TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> getResultCallback()
getResultCallback in interface TableStoreTimeseriesWriterpublic TimeseriesWriterConfig getTimeseriesWriterConfig()
getTimeseriesWriterConfig in interface TableStoreTimeseriesWriterpublic TimeseriesWriterHandleStatistics getTimeseriesWriterStatistics()
getTimeseriesWriterStatistics in interface TableStoreTimeseriesWriterpublic void flush()
throws ClientException
flush in interface TableStoreTimeseriesWriterClientExceptionpublic void close()
close in interface TableStoreTimeseriesWriterCopyright © 2024. All Rights Reserved.