public class TimestreamDBClient extends Object implements TimestreamDB
TimestreamDBClient定义,提供删建表,以及数据读写功能。
后台默认打开自动更新时间线updateTime功能,可以通过TimestreamDBConfiguration.dumpMeta选择关闭
当后台打开自动更新时间线updateTime功能时(TimestreamDBConfiguration.dumpMeta),TimestreamDBClient后台会维护一个内存缓存最近更新过的时间线。数据写入时,会判断该时间线是否需要更新updateTime(缓存中没有或者上次更新时间线超过设置的阈值),
如果需要更新则往meta表中插入一条记录(只更新updateTime)。
数据写入的异步api是通过TableStoreWriter来实现的,如果需要获取异步写入的结果,可以传入TableStoreCallback,该callback是所有数据表写入共用的
| Constructor and Description |
|---|
TimestreamDBClient(AsyncClient asyncClient,
TimestreamDBConfiguration config)
TimestreamDBClient的构造函数
|
TimestreamDBClient(AsyncClient asyncClient,
TimestreamDBConfiguration config,
WriterConfig writerConfig,
TableStoreCallback<RowChange,ConsumedCapacity> callback)
TimestreamDBClient的构造函数
|
| Modifier and Type | Method and Description |
|---|---|
void |
close()
关闭client,释放资源
|
void |
createDataTable(String tableName)
创建数据表
|
void |
createMetaTable()
创建meta表,不为attributes创建索引
|
void |
createMetaTable(List<AttributeIndexSchema> indexForAttributes)
创建meta表,为指定的attributes创建索引
|
TimestreamDataTable |
dataTable(String tableName)
获取数据表的操作对象
|
void |
deleteDataTable(String tableName)
删除数据表
|
void |
deleteMetaTable()
删除meta表
|
TimestreamMetaTable |
metaTable()
获取meta表的操作对象
|
public TimestreamDBClient(AsyncClient asyncClient, TimestreamDBConfiguration config)
asyncClient - TableStore异步clientconfig - client配置public TimestreamDBClient(AsyncClient asyncClient, TimestreamDBConfiguration config, WriterConfig writerConfig, TableStoreCallback<RowChange,ConsumedCapacity> callback)
asyncClient - TableStore异步clientconfig - client配置writerConfig - 所有数据表使用的TableStoreWriter的WriterConfigcallback - 所有数据表使用的TableStoreWriter共用的TableStoreCallbackpublic void close()
TimestreamDB请确保在所有请求执行完毕之后释放资源。释放资源之后将不能再发送请求,正在执行的请求可能无法返回结果。
close in interface TimestreamDBpublic void createMetaTable()
TimestreamDBcreateMetaTable in interface TimestreamDBpublic void createMetaTable(List<AttributeIndexSchema> indexForAttributes)
TimestreamDBattribute不能为保留字段(h、n、t、s)
createMetaTable in interface TimestreamDBpublic void deleteMetaTable()
TimestreamDBdeleteMetaTable in interface TimestreamDBpublic void createDataTable(String tableName)
TimestreamDBcreateDataTable in interface TimestreamDBtableName - 数据表表名public void deleteDataTable(String tableName)
TimestreamDBdeleteDataTable in interface TimestreamDBtableName - 数据表表名public TimestreamDataTable dataTable(String tableName)
TimestreamDBdataTable in interface TimestreamDBtableName - 数据表表名public TimestreamMetaTable metaTable()
TimestreamDBmetaTable in interface TimestreamDBCopyright © 2024. All Rights Reserved.