AbortTransactionResponse |
SyncClient.abortTransaction(AbortTransactionRequest request) |
AbortTransactionResponse |
SyncClientInterface.abortTransaction(AbortTransactionRequest request)
取消一个事务
|
AddDefinedColumnResponse |
SyncClient.addDefinedColumn(AddDefinedColumnRequest addDefinedColumnRequest) |
AddDefinedColumnResponse |
SyncClientInterface.addDefinedColumn(AddDefinedColumnRequest addDefinedColumnRequest)
为一张表添加预定义列^M
|
void |
DefaultTableStoreWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows) |
void |
TableStoreWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows)
|
void |
TableStoreWriter.addRowChange(RowChange rowChange)
|
Future<WriterResult> |
DefaultTableStoreWriter.addRowChangeWithFuture(List<RowChange> rowChanges) |
Future<WriterResult> |
TableStoreWriter.addRowChangeWithFuture(List<RowChange> rowChanges)
|
Future<WriterResult> |
TableStoreWriter.addRowChangeWithFuture(RowChange rowChange)
|
void |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowChange(List<TimeseriesTableRow> timeseriesTableRows,
List<TimeseriesTableRow> dirtyTimeseriesTableRows) |
void |
TableStoreTimeseriesWriter.addTimeseriesRowChange(List<TimeseriesTableRow> timeseriesTableRows,
List<TimeseriesTableRow> ditryRows) |
void |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) |
void |
TableStoreTimeseriesWriter.addTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) |
Future<TimeseriesWriterResult> |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowChangeWithFuture(List<TimeseriesTableRow> timeseriesTableRows)
批量写入时序表数据
|
Future<TimeseriesWriterResult> |
TableStoreTimeseriesWriter.addTimeseriesRowChangeWithFuture(List<TimeseriesTableRow> timeseriesTableRows) |
Future<TimeseriesWriterResult> |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowChangeWithFuture(TimeseriesTableRow timeseriesTableRow)
写入一条时序表数据
|
Future<TimeseriesWriterResult> |
TableStoreTimeseriesWriter.addTimeseriesRowChangeWithFuture(TimeseriesTableRow timeseriesTableRow) |
BatchGetRowResponse |
SyncClient.batchGetRow(BatchGetRowRequest batchGetRowRequest) |
BatchGetRowResponse |
SyncClientInterface.batchGetRow(BatchGetRowRequest batchGetRowRequest)
从多张表中读取多行数据。
|
BatchWriteRowResponse |
SyncClient.batchWriteRow(BatchWriteRowRequest batchWriteRowRequest) |
BatchWriteRowResponse |
SyncClientInterface.batchWriteRow(BatchWriteRowRequest batchWriteRowRequest)
对多张表中对多行执行更新或者删除操作。
|
BulkExportResponse |
SyncClient.bulkExport(BulkExportRequest bulkExportRequest) |
BulkExportResponse |
SyncClientInterface.bulkExport(BulkExportRequest bulkExportRequest)
从表中查询一个范围内的多行数据,离线服务接口。
|
BulkImportResponse |
SyncClient.bulkImport(BulkImportRequest bulkImportRequest) |
BulkImportResponse |
SyncClientInterface.bulkImport(BulkImportRequest bulkImportRequest)
单张表中对多行执行更新或者删除操作,离线服务接口。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse |
TunnelClient.checkpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest request) |
com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse |
TunnelClientInterface.checkpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
设置某个Channel的Checkpoint和Checkpoint对应的SequenceNumber。
|
CommitTransactionResponse |
SyncClient.commitTransaction(CommitTransactionRequest request) |
CommitTransactionResponse |
SyncClientInterface.commitTransaction(CommitTransactionRequest request)
提交一个事务
|
ComputeSplitsResponse |
SyncClient.computeSplits(ComputeSplitsRequest request) |
ComputeSplitsResponse |
SyncClientInterface.computeSplits(ComputeSplitsRequest request)
Get the partition information of the data.
|
ComputeSplitsBySizeResponse |
SyncClient.computeSplitsBySize(ComputeSplitsBySizeRequest computeSplitsBySizeRequest) |
ComputeSplitsBySizeResponse |
SyncClientInterface.computeSplitsBySize(ComputeSplitsBySizeRequest computeSplitsBySizeRequest)
对表的数据根据一定的数据大小进行分块,并返回分块的信息以供数据获取接口使用。返回的数据分块按照主键列的递增顺序排列,返回的每个数据分块信息中包含分块所处的partition分区的ID的哈希值以及起始行和终止行的主键值,遵循左闭右开区间。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse |
TunnelClient.connectTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest request) |
com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse |
TunnelClientInterface.connectTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
为指定Tunnel分配客户端标识(ClientId), 同时可以传输一些Client的参数给Master,比如client心跳超时时间,client的类型等。
|
Iterator<Row> |
SyncClient.createBulkExportIterator(RangeIteratorParameter rangeIteratorParameter) |
Iterator<Row> |
SyncClientInterface.createBulkExportIterator(RangeIteratorParameter rangeIteratorParameter) |
CreateDeliveryTaskResponse |
SyncClient.createDeliveryTask(CreateDeliveryTaskRequest request) |
CreateDeliveryTaskResponse |
SyncClientInterface.createDeliveryTask(CreateDeliveryTaskRequest request)
创建数据投递任务
|
CreateIndexResponse |
SyncClient.createIndex(CreateIndexRequest createIndexRequest) |
CreateIndexResponse |
SyncClientInterface.createIndex(CreateIndexRequest createIndexRequest)
在用户指定的某张表下创建一张索引表
|
RowIterator |
SyncClient.createParallelScanIterator(ParallelScanRequest request) |
RowIterator |
SyncClientInterface.createParallelScanIterator(ParallelScanRequest request)
Get the Iterator for ParallelScan.
|
Iterator<Row> |
SyncClient.createRangeIterator(RangeIteratorParameter rangeIteratorParameter) |
Iterator<Row> |
SyncClientInterface.createRangeIterator(RangeIteratorParameter rangeIteratorParameter)
|
CreateSearchIndexResponse |
SyncClient.createSearchIndex(CreateSearchIndexRequest request) |
CreateSearchIndexResponse |
SyncClientInterface.createSearchIndex(CreateSearchIndexRequest request)
创建SearchIndex
|
RowIterator |
SyncClient.createSearchIterator(SearchRequest request) |
RowIterator |
SyncClientInterface.createSearchIterator(SearchRequest request)
Get the Iterator for Search.
|
CreateTableResponse |
SyncClient.createTable(CreateTableRequest createTableRequest) |
CreateTableResponse |
SyncClientInterface.createTable(CreateTableRequest createTableRequest)
在用户的实例下创建一张新的表。
|
CreateTimeseriesAnalyticalStoreResponse |
TimeseriesClient.createTimeseriesAnalyticalStore(CreateTimeseriesAnalyticalStoreRequest request) |
CreateTimeseriesAnalyticalStoreResponse |
TimeseriesClientInterface.createTimeseriesAnalyticalStore(CreateTimeseriesAnalyticalStoreRequest request) |
Future<CreateTimeseriesAnalyticalStoreResponse> |
AsyncTimeseriesClient.createTimeseriesAnalyticalStore(CreateTimeseriesAnalyticalStoreRequest request,
TableStoreCallback<CreateTimeseriesAnalyticalStoreRequest,CreateTimeseriesAnalyticalStoreResponse> callback) |
Future<CreateTimeseriesAnalyticalStoreResponse> |
AsyncTimeseriesClientInterface.createTimeseriesAnalyticalStore(CreateTimeseriesAnalyticalStoreRequest request,
TableStoreCallback<CreateTimeseriesAnalyticalStoreRequest,CreateTimeseriesAnalyticalStoreResponse> callback) |
CreateTimeseriesLastpointIndexResponse |
TimeseriesClient.createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request) |
CreateTimeseriesLastpointIndexResponse |
TimeseriesClientInterface.createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request) |
Future<CreateTimeseriesLastpointIndexResponse> |
AsyncTimeseriesClient.createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request,
TableStoreCallback<CreateTimeseriesLastpointIndexRequest,CreateTimeseriesLastpointIndexResponse> callback) |
Future<CreateTimeseriesLastpointIndexResponse> |
AsyncTimeseriesClientInterface.createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request,
TableStoreCallback<CreateTimeseriesLastpointIndexRequest,CreateTimeseriesLastpointIndexResponse> callback) |
CreateTunnelResponse |
TunnelClient.createTunnel(CreateTunnelRequest request) |
CreateTunnelResponse |
TunnelClientInterface.createTunnel(CreateTunnelRequest request)
创建一个Tunnel。
|
WideColumnIterator |
SyncClient.createWideColumnIterator(GetRowRequest getRowRequest) |
WideColumnIterator |
SyncClientInterface.createWideColumnIterator(GetRowRequest getRowRequest) |
DeleteDefinedColumnResponse |
SyncClient.deleteDefinedColumn(DeleteDefinedColumnRequest deleteDefinedColumnRequest) |
DeleteDefinedColumnResponse |
SyncClientInterface.deleteDefinedColumn(DeleteDefinedColumnRequest deleteDefinedColumnRequest)
为一张表删除预定义列
|
DeleteDeliveryTaskResponse |
SyncClient.deleteDeliveryTask(DeleteDeliveryTaskRequest request) |
DeleteDeliveryTaskResponse |
SyncClientInterface.deleteDeliveryTask(DeleteDeliveryTaskRequest request)
删除投递任务
|
DeleteIndexResponse |
SyncClient.deleteIndex(DeleteIndexRequest deleteIndexRequest) |
DeleteIndexResponse |
SyncClientInterface.deleteIndex(DeleteIndexRequest deleteIndexRequest)
删除用户指定的某张表下的某张索引表
|
DeleteRowResponse |
SyncClient.deleteRow(DeleteRowRequest deleteRowRequest) |
DeleteRowResponse |
SyncClientInterface.deleteRow(DeleteRowRequest deleteRowRequest)
删除表中的一行数据。
|
DeleteSearchIndexResponse |
SyncClient.deleteSearchIndex(DeleteSearchIndexRequest request) |
DeleteSearchIndexResponse |
SyncClientInterface.deleteSearchIndex(DeleteSearchIndexRequest request)
删除SearchIndex
|
DeleteTableResponse |
SyncClient.deleteTable(DeleteTableRequest deleteTableRequest) |
DeleteTableResponse |
SyncClientInterface.deleteTable(DeleteTableRequest deleteTableRequest)
删除用户指定的某个实例下的一张表。。
|
DeleteTimeseriesAnalyticalStoreResponse |
TimeseriesClient.deleteTimeseriesAnalyticalStore(DeleteTimeseriesAnalyticalStoreRequest request) |
DeleteTimeseriesAnalyticalStoreResponse |
TimeseriesClientInterface.deleteTimeseriesAnalyticalStore(DeleteTimeseriesAnalyticalStoreRequest request) |
Future<DeleteTimeseriesAnalyticalStoreResponse> |
AsyncTimeseriesClient.deleteTimeseriesAnalyticalStore(DeleteTimeseriesAnalyticalStoreRequest request,
TableStoreCallback<DeleteTimeseriesAnalyticalStoreRequest,DeleteTimeseriesAnalyticalStoreResponse> callback) |
Future<DeleteTimeseriesAnalyticalStoreResponse> |
AsyncTimeseriesClientInterface.deleteTimeseriesAnalyticalStore(DeleteTimeseriesAnalyticalStoreRequest request,
TableStoreCallback<DeleteTimeseriesAnalyticalStoreRequest,DeleteTimeseriesAnalyticalStoreResponse> callback) |
DeleteTimeseriesLastpointIndexResponse |
TimeseriesClient.deleteTimeseriesLastpointIndex(DeleteTimeseriesLastpointIndexRequest request) |
DeleteTimeseriesLastpointIndexResponse |
TimeseriesClientInterface.deleteTimeseriesLastpointIndex(DeleteTimeseriesLastpointIndexRequest request) |
Future<DeleteTimeseriesLastpointIndexResponse> |
AsyncTimeseriesClient.deleteTimeseriesLastpointIndex(DeleteTimeseriesLastpointIndexRequest request,
TableStoreCallback<DeleteTimeseriesLastpointIndexRequest,DeleteTimeseriesLastpointIndexResponse> callback) |
Future<DeleteTimeseriesLastpointIndexResponse> |
AsyncTimeseriesClientInterface.deleteTimeseriesLastpointIndex(DeleteTimeseriesLastpointIndexRequest request,
TableStoreCallback<DeleteTimeseriesLastpointIndexRequest,DeleteTimeseriesLastpointIndexResponse> callback) |
DeleteTimeseriesMetaResponse |
TimeseriesClient.deleteTimeseriesMeta(DeleteTimeseriesMetaRequest request) |
DeleteTimeseriesMetaResponse |
TimeseriesClientInterface.deleteTimeseriesMeta(DeleteTimeseriesMetaRequest request) |
Future<DeleteTimeseriesMetaResponse> |
AsyncTimeseriesClient.deleteTimeseriesMeta(DeleteTimeseriesMetaRequest request,
TableStoreCallback<DeleteTimeseriesMetaRequest,DeleteTimeseriesMetaResponse> callback) |
Future<DeleteTimeseriesMetaResponse> |
AsyncTimeseriesClientInterface.deleteTimeseriesMeta(DeleteTimeseriesMetaRequest request,
TableStoreCallback<DeleteTimeseriesMetaRequest,DeleteTimeseriesMetaResponse> callback) |
DeleteTunnelResponse |
TunnelClient.deleteTunnel(DeleteTunnelRequest request) |
DeleteTunnelResponse |
TunnelClientInterface.deleteTunnel(DeleteTunnelRequest request)
删除一个Tunnel。
|
DescribeDeliveryTaskResponse |
SyncClient.describeDeliveryTask(DescribeDeliveryTaskRequest request) |
DescribeDeliveryTaskResponse |
SyncClientInterface.describeDeliveryTask(DescribeDeliveryTaskRequest request)
投递任务描述函数
|
DescribeSearchIndexResponse |
SyncClient.describeSearchIndex(DescribeSearchIndexRequest request) |
DescribeSearchIndexResponse |
SyncClientInterface.describeSearchIndex(DescribeSearchIndexRequest request)
获取一个SearchIndex的信息
|
DescribeStreamResponse |
SyncClient.describeStream(DescribeStreamRequest describeStreamRequest) |
DescribeStreamResponse |
SyncClientInterface.describeStream(DescribeStreamRequest describeStreamRequest)
获取指定Stream的详细信息。通过此方法获取Shard列表。
|
DescribeTableResponse |
SyncClient.describeTable(DescribeTableRequest request) |
DescribeTableResponse |
SyncClientInterface.describeTable(DescribeTableRequest describeTableRequest)
获取表的详细信息,表的详细信息包括:
|
DescribeTimeseriesAnalyticalStoreResponse |
TimeseriesClient.describeTimeseriesAnalyticalStore(DescribeTimeseriesAnalyticalStoreRequest request) |
DescribeTimeseriesAnalyticalStoreResponse |
TimeseriesClientInterface.describeTimeseriesAnalyticalStore(DescribeTimeseriesAnalyticalStoreRequest request) |
Future<DescribeTimeseriesAnalyticalStoreResponse> |
AsyncTimeseriesClient.describeTimeseriesAnalyticalStore(DescribeTimeseriesAnalyticalStoreRequest request,
TableStoreCallback<DescribeTimeseriesAnalyticalStoreRequest,DescribeTimeseriesAnalyticalStoreResponse> callback) |
Future<DescribeTimeseriesAnalyticalStoreResponse> |
AsyncTimeseriesClientInterface.describeTimeseriesAnalyticalStore(DescribeTimeseriesAnalyticalStoreRequest request,
TableStoreCallback<DescribeTimeseriesAnalyticalStoreRequest,DescribeTimeseriesAnalyticalStoreResponse> callback) |
DescribeTunnelResponse |
TunnelClient.describeTunnel(DescribeTunnelRequest request) |
DescribeTunnelResponse |
TunnelClientInterface.describeTunnel(DescribeTunnelRequest request)
获取某个Tunnel下的具体信息。
|
void |
DefaultTableStoreTimeseriesWriter.flush() |
void |
TableStoreTimeseriesWriter.flush() |
void |
DefaultTableStoreWriter.flush() |
void |
TableStoreWriter.flush()
主动flush缓冲区中的数据,该函数会等待缓冲区中的所有数据被flush完毕。
注意:若在调用flush之后继续向缓冲区中写入数据,flush不会等待这部分新数据的写入,新数据的flush需要重新调用一次flush。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse |
TunnelClient.getCheckpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest request) |
com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse |
TunnelClientInterface.getCheckpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
获取某个Channel上次记录的Checkpoint和Checkpoint对应的SequenceNumber。
|
GetRangeResponse |
SyncClient.getRange(GetRangeRequest getRangeRequest) |
GetRangeResponse |
SyncClientInterface.getRange(GetRangeRequest getRangeRequest)
从表中查询一个范围内的多行数据。
|
GetRowResponse |
SyncClient.getRow(GetRowRequest getRowRequest) |
GetRowResponse |
SyncClientInterface.getRow(GetRowRequest getRowRequest)
读取表中的一行数据。
|
GetShardIteratorResponse |
SyncClient.getShardIterator(GetShardIteratorRequest getShardIteratorRequest) |
GetShardIteratorResponse |
SyncClientInterface.getShardIterator(GetShardIteratorRequest getShardIteratorRequest)
获取ShardIterator,可通过ShardIterator读取Shard中的数据。
|
GetStreamRecordResponse |
SyncClient.getStreamRecord(GetStreamRecordRequest getStreamRecordRequest) |
GetStreamRecordResponse |
SyncClientInterface.getStreamRecord(GetStreamRecordRequest getStreamRecordRequest)
通过ShardIterator读取Shard中的数据。
|
GetTimeseriesDataResponse |
TimeseriesClient.getTimeseriesData(GetTimeseriesDataRequest request) |
GetTimeseriesDataResponse |
TimeseriesClientInterface.getTimeseriesData(GetTimeseriesDataRequest request) |
Future<GetTimeseriesDataResponse> |
AsyncTimeseriesClient.getTimeseriesData(GetTimeseriesDataRequest request,
TableStoreCallback<GetTimeseriesDataRequest,GetTimeseriesDataResponse> callback) |
Future<GetTimeseriesDataResponse> |
AsyncTimeseriesClientInterface.getTimeseriesData(GetTimeseriesDataRequest request,
TableStoreCallback<GetTimeseriesDataRequest,GetTimeseriesDataResponse> callback) |
com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse |
TunnelClient.heartbeat(com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest request) |
com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse |
TunnelClientInterface.heartbeat(com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
Heartbeat操作的作用为(TunnelClient)保持心跳,同时可以获取可以消费的Channel,上报一些处理状态。
当心跳超时后认为TunnelClient下线,需要重新Connect。
|
ListDeliveryTaskResponse |
SyncClient.listDeliveryTask(ListDeliveryTaskRequest request) |
ListDeliveryTaskResponse |
SyncClientInterface.listDeliveryTask(ListDeliveryTaskRequest request)
列出用户表下所有投递任务列表
|
ListSearchIndexResponse |
SyncClient.listSearchIndex(ListSearchIndexRequest request) |
ListSearchIndexResponse |
SyncClientInterface.listSearchIndex(ListSearchIndexRequest request)
获取表下的SearchIndex列表
|
ListStreamResponse |
SyncClient.listStream(ListStreamRequest listStreamRequest) |
ListStreamResponse |
SyncClientInterface.listStream(ListStreamRequest listStreamRequest)
获取用户当前实例下的全部Stream列表或者特定表下的Stream。
|
ListTableResponse |
SyncClient.listTable() |
ListTableResponse |
SyncClientInterface.listTable()
返回用户当前实例下的所有表的列表。
|
ListTunnelResponse |
TunnelClient.listTunnel(ListTunnelRequest request) |
ListTunnelResponse |
TunnelClientInterface.listTunnel(ListTunnelRequest request)
获取某个表下的Tunnel信息。
|
ParallelScanResponse |
SyncClient.parallelScan(ParallelScanRequest request) |
ParallelScanResponse |
SyncClientInterface.parallelScan(ParallelScanRequest request)
Scan data form SearchIndex.
|
PutRowResponse |
SyncClient.putRow(PutRowRequest putRowRequest) |
PutRowResponse |
SyncClientInterface.putRow(PutRowRequest putRowRequest)
向表中插入或覆盖一行数据。
|
PutTimeseriesDataResponse |
TimeseriesClient.putTimeseriesData(PutTimeseriesDataRequest request) |
PutTimeseriesDataResponse |
TimeseriesClientInterface.putTimeseriesData(PutTimeseriesDataRequest request) |
Future<PutTimeseriesDataResponse> |
AsyncTimeseriesClient.putTimeseriesData(PutTimeseriesDataRequest request,
TableStoreCallback<PutTimeseriesDataRequest,PutTimeseriesDataResponse> callback) |
Future<PutTimeseriesDataResponse> |
AsyncTimeseriesClientInterface.putTimeseriesData(PutTimeseriesDataRequest request,
TableStoreCallback<PutTimeseriesDataRequest,PutTimeseriesDataResponse> callback) |
QueryTimeseriesMetaResponse |
TimeseriesClient.queryTimeseriesMeta(QueryTimeseriesMetaRequest request) |
QueryTimeseriesMetaResponse |
TimeseriesClientInterface.queryTimeseriesMeta(QueryTimeseriesMetaRequest request) |
Future<QueryTimeseriesMetaResponse> |
AsyncTimeseriesClient.queryTimeseriesMeta(QueryTimeseriesMetaRequest request,
TableStoreCallback<QueryTimeseriesMetaRequest,QueryTimeseriesMetaResponse> callback) |
Future<QueryTimeseriesMetaResponse> |
AsyncTimeseriesClientInterface.queryTimeseriesMeta(QueryTimeseriesMetaRequest request,
TableStoreCallback<QueryTimeseriesMetaRequest,QueryTimeseriesMetaResponse> callback) |
com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse |
TunnelClient.readRecords(com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest request) |
com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse |
TunnelClientInterface.readRecords(com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
从某个Channel中读取数据,读取时需要指定Tunnel ID, Client ID, Channel ID和起始Token值。第一次读取时,
使用上次记录的Token(Checkpoint)开始读取,之后每次使用返回的NextToken开始读取。
|
ScanTimeseriesDataResponse |
TimeseriesClient.scanTimeseriesData(ScanTimeseriesDataRequest request) |
ScanTimeseriesDataResponse |
TimeseriesClientInterface.scanTimeseriesData(ScanTimeseriesDataRequest request) |
Future<ScanTimeseriesDataResponse> |
AsyncTimeseriesClient.scanTimeseriesData(ScanTimeseriesDataRequest request,
TableStoreCallback<ScanTimeseriesDataRequest,ScanTimeseriesDataResponse> callback) |
Future<ScanTimeseriesDataResponse> |
AsyncTimeseriesClientInterface.scanTimeseriesData(ScanTimeseriesDataRequest request,
TableStoreCallback<ScanTimeseriesDataRequest,ScanTimeseriesDataResponse> callback) |
SearchResponse |
SyncClient.search(SearchRequest request) |
SearchResponse |
SyncClientInterface.search(SearchRequest request)
搜索功能
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse |
TunnelClient.shutdownTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest request) |
com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse |
TunnelClientInterface.shutdownTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
关闭某个TunnelClient, 断开与Tunnel的服务端的连接。
|
SplitTimeseriesScanTaskResponse |
TimeseriesClient.splitTimeseriesScanTask(SplitTimeseriesScanTaskRequest request) |
SplitTimeseriesScanTaskResponse |
TimeseriesClientInterface.splitTimeseriesScanTask(SplitTimeseriesScanTaskRequest request) |
Future<SplitTimeseriesScanTaskResponse> |
AsyncTimeseriesClient.splitTimeseriesScanTask(SplitTimeseriesScanTaskRequest request,
TableStoreCallback<SplitTimeseriesScanTaskRequest,SplitTimeseriesScanTaskResponse> callback) |
Future<SplitTimeseriesScanTaskResponse> |
AsyncTimeseriesClientInterface.splitTimeseriesScanTask(SplitTimeseriesScanTaskRequest request,
TableStoreCallback<SplitTimeseriesScanTaskRequest,SplitTimeseriesScanTaskResponse> callback) |
SQLQueryResponse |
SyncClient.sqlQuery(SQLQueryRequest request) |
SQLQueryResponse |
SyncClientInterface.sqlQuery(SQLQueryRequest request)
SQL query 请求
|
StartLocalTransactionResponse |
SyncClient.startLocalTransaction(StartLocalTransactionRequest request) |
StartLocalTransactionResponse |
SyncClientInterface.startLocalTransaction(StartLocalTransactionRequest request)
开启一个本地事务
|
boolean |
TableStoreWriter.tryAddRowChange(RowChange rowChange)
|
boolean |
DefaultTableStoreTimeseriesWriter.tryAddTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) |
boolean |
TableStoreTimeseriesWriter.tryAddTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) |
UpdateRowResponse |
SyncClient.updateRow(UpdateRowRequest updateRowRequest) |
UpdateRowResponse |
SyncClientInterface.updateRow(UpdateRowRequest updateRowRequest)
更新表中的一行数据。
|
UpdateSearchIndexResponse |
SyncClient.updateSearchIndex(UpdateSearchIndexRequest request) |
UpdateSearchIndexResponse |
SyncClientInterface.updateSearchIndex(UpdateSearchIndexRequest request)
更新SearchIndex(用户索引交换,或设置索引查询权重)
|
UpdateTableResponse |
SyncClient.updateTable(UpdateTableRequest request) |
UpdateTableResponse |
SyncClientInterface.updateTable(UpdateTableRequest updateTableRequest)
在表被创建之后,动态的更改表的配置或预留吞吐量。
|
UpdateTimeseriesAnalyticalStoreResponse |
TimeseriesClient.updateTimeseriesAnalyticalStore(UpdateTimeseriesAnalyticalStoreRequest request) |
UpdateTimeseriesAnalyticalStoreResponse |
TimeseriesClientInterface.updateTimeseriesAnalyticalStore(UpdateTimeseriesAnalyticalStoreRequest request) |
Future<UpdateTimeseriesAnalyticalStoreResponse> |
AsyncTimeseriesClient.updateTimeseriesAnalyticalStore(UpdateTimeseriesAnalyticalStoreRequest request,
TableStoreCallback<UpdateTimeseriesAnalyticalStoreRequest,UpdateTimeseriesAnalyticalStoreResponse> callback) |
Future<UpdateTimeseriesAnalyticalStoreResponse> |
AsyncTimeseriesClientInterface.updateTimeseriesAnalyticalStore(UpdateTimeseriesAnalyticalStoreRequest request,
TableStoreCallback<UpdateTimeseriesAnalyticalStoreRequest,UpdateTimeseriesAnalyticalStoreResponse> callback) |
UpdateTimeseriesMetaResponse |
TimeseriesClient.updateTimeseriesMeta(UpdateTimeseriesMetaRequest request) |
UpdateTimeseriesMetaResponse |
TimeseriesClientInterface.updateTimeseriesMeta(UpdateTimeseriesMetaRequest request) |
Future<UpdateTimeseriesMetaResponse> |
AsyncTimeseriesClient.updateTimeseriesMeta(UpdateTimeseriesMetaRequest request,
TableStoreCallback<UpdateTimeseriesMetaRequest,UpdateTimeseriesMetaResponse> callback) |
Future<UpdateTimeseriesMetaResponse> |
AsyncTimeseriesClientInterface.updateTimeseriesMeta(UpdateTimeseriesMetaRequest request,
TableStoreCallback<UpdateTimeseriesMetaRequest,UpdateTimeseriesMetaResponse> callback) |