限定符和类型 | 方法和说明 |
---|---|
void |
TimestreamDataTable.asyncWrite(TimestreamIdentifier identifier,
Point point)
异步写入数据,如果写入失败需要通过
TableStoreCallback 来获取
异步接口,通过TableStoreWriter 写入数据,相比同步接口,该接口数据写入的吞吐更好
注意:若TableStoreWriter的缓冲区满,则该操作会被block |
void |
TimestreamMetaTable.delete(TimestreamIdentifier identifier)
删除某条时间线
|
DataGetter |
TimestreamDataTable.get(TimestreamIdentifier identifier)
查询单条时间线的数据
|
MetaGetter |
TimestreamMetaTable.get(TimestreamIdentifier identifier)
查询某条时间线
|
void |
TimestreamDataTable.write(TimestreamIdentifier identifier,
Point point)
同步写入数据,如果数据写入失败会抛异常
|
限定符和类型 | 方法和说明 |
---|---|
TimestreamIdentifier |
TimestreamIdentifier.Builder.build() |
TimestreamIdentifier |
TimestreamMeta.getIdentifier() |
构造器和说明 |
---|
PointIterator(Iterator<Row> iterator,
TimestreamIdentifier meta) |
TimestreamMeta(TimestreamIdentifier identifier) |
限定符和类型 | 方法和说明 |
---|---|
TimestreamIdentifier |
Item.getMeta() |
限定符和类型 | 方法和说明 |
---|---|
static List<Item> |
Item.buildItems(List<String> gourpByColumn,
List<TimestreamIdentifier> metas) |
构造器和说明 |
---|
Item(List<String> gourpByColumn,
TimestreamIdentifier meta) |
限定符和类型 | 方法和说明 |
---|---|
protected PointIterator |
DataQuery.getTimestream(TimestreamIdentifier identifier) |
构造器和说明 |
---|
DataGetter(AsyncClient asyncClient,
String tableName,
TimestreamIdentifier identifier) |
MetaGetter(AsyncClient asyncClient,
String metaTableName,
TimestreamIdentifier identifier) |
Copyright © 2019. All Rights Reserved.