public class TimestreamDBClient extends Object implements TimestreamDB
TimestreamDBClient
定义,提供删建表,以及数据读写功能。
后台默认打开自动更新时间线updateTime功能,可以通过TimestreamDBConfiguration.dumpMeta
选择关闭
当后台打开自动更新时间线updateTime功能时(TimestreamDBConfiguration.dumpMeta
),TimestreamDBClient后台会维护一个内存缓存最近更新过的时间线。数据写入时,会判断该时间线是否需要更新updateTime(缓存中没有或者上次更新时间线超过设置的阈值),
如果需要更新则往meta表中插入一条记录(只更新updateTime)。
数据写入的异步api是通过TableStoreWriter
来实现的,如果需要获取异步写入的结果,可以传入TableStoreCallback
,该callback是所有数据表写入共用的
构造器和说明 |
---|
TimestreamDBClient(AsyncClient asyncClient,
TimestreamDBConfiguration config)
TimestreamDBClient的构造函数
|
TimestreamDBClient(AsyncClient asyncClient,
TimestreamDBConfiguration config,
WriterConfig writerConfig,
TableStoreCallback<RowChange,ConsumedCapacity> callback)
TimestreamDBClient的构造函数
|
限定符和类型 | 方法和说明 |
---|---|
void |
close()
关闭client,释放资源
请确保在所有请求执行完毕之后释放资源。
|
void |
createDataTable(String tableName)
创建数据表
|
void |
createMetaTable()
创建meta表,不为attributes创建索引
|
void |
createMetaTable(List<AttributeIndexSchema> indexForAttributes)
创建meta表,为指定的attributes创建索引
attribute不能为保留字段(h、n、t、s)
|
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的WriterConfig
callback
- 所有数据表使用的TableStoreWriter共用的TableStoreCallback
public void close()
TimestreamDB
请确保在所有请求执行完毕之后释放资源。释放资源之后将不能再发送请求,正在执行的请求可能无法返回结果。
close
在接口中 TimestreamDB
public void createMetaTable()
TimestreamDB
createMetaTable
在接口中 TimestreamDB
public void createMetaTable(List<AttributeIndexSchema> indexForAttributes)
TimestreamDB
attribute不能为保留字段(h、n、t、s)
createMetaTable
在接口中 TimestreamDB
public void deleteMetaTable()
TimestreamDB
deleteMetaTable
在接口中 TimestreamDB
public void createDataTable(String tableName)
TimestreamDB
createDataTable
在接口中 TimestreamDB
tableName
- 数据表表名public void deleteDataTable(String tableName)
TimestreamDB
deleteDataTable
在接口中 TimestreamDB
tableName
- 数据表表名public TimestreamDataTable dataTable(String tableName)
TimestreamDB
dataTable
在接口中 TimestreamDB
tableName
- 数据表表名public TimestreamMetaTable metaTable()
TimestreamDB
metaTable
在接口中 TimestreamDB
Copyright © 2019. All Rights Reserved.