Future<AbortTransactionResponse> |
AsyncClient.abortTransaction(AbortTransactionRequest request,
TableStoreCallback<AbortTransactionRequest,AbortTransactionResponse> callback) |
Future<AbortTransactionResponse> |
InternalClient.abortTransaction(AbortTransactionRequest request,
TableStoreCallback<AbortTransactionRequest,AbortTransactionResponse> callback) |
Future<AbortTransactionResponse> |
AsyncClientInterface.abortTransaction(AbortTransactionRequest request,
TableStoreCallback<AbortTransactionRequest,AbortTransactionResponse> callback)
取消一个事务
|
Future<AddDefinedColumnResponse> |
AsyncClient.addDefinedColumn(AddDefinedColumnRequest request,
TableStoreCallback<AddDefinedColumnRequest,AddDefinedColumnResponse> callback) |
Future<AddDefinedColumnResponse> |
InternalClient.addDefinedColumn(AddDefinedColumnRequest request,
TableStoreCallback<AddDefinedColumnRequest,AddDefinedColumnResponse> callback) |
Future<AddDefinedColumnResponse> |
AsyncClientInterface.addDefinedColumn(AddDefinedColumnRequest addDefinedColumnRequest,
TableStoreCallback<AddDefinedColumnRequest,AddDefinedColumnResponse> callback)
为用户指定的表添加预定义列
|
Future<BatchGetRowResponse> |
AsyncClient.batchGetRow(BatchGetRowRequest request,
TableStoreCallback<BatchGetRowRequest,BatchGetRowResponse> callback) |
Future<BatchGetRowResponse> |
InternalClient.batchGetRow(BatchGetRowRequest request,
TableStoreCallback<BatchGetRowRequest,BatchGetRowResponse> callback) |
Future<BatchGetRowResponse> |
AsyncClientInterface.batchGetRow(BatchGetRowRequest batchGetRowRequest,
TableStoreCallback<BatchGetRowRequest,BatchGetRowResponse> callback)
从多张表中读取多行数据。
|
Future<BatchGetRowResponse> |
InternalClient.batchGetRowInternal(BatchGetRowRequest request,
TableStoreCallback<BatchGetRowRequest,BatchGetRowResponse> callback) |
Future<BatchWriteRowResponse> |
AsyncClient.batchWriteRow(BatchWriteRowRequest request,
TableStoreCallback<BatchWriteRowRequest,BatchWriteRowResponse> callback) |
Future<BatchWriteRowResponse> |
InternalClient.batchWriteRow(BatchWriteRowRequest request,
TableStoreCallback<BatchWriteRowRequest,BatchWriteRowResponse> callback) |
Future<BatchWriteRowResponse> |
AsyncClientInterface.batchWriteRow(BatchWriteRowRequest batchWriteRowRequest,
TableStoreCallback<BatchWriteRowRequest,BatchWriteRowResponse> callback)
对多张表中对多行执行更新或者删除操作。
|
Future<BulkExportResponse> |
AsyncClient.bulkExport(BulkExportRequest request,
TableStoreCallback<BulkExportRequest,BulkExportResponse> callback) |
Future<BulkExportResponse> |
InternalClient.bulkExport(BulkExportRequest request,
TableStoreCallback<BulkExportRequest,BulkExportResponse> callback) |
Future<BulkExportResponse> |
AsyncClientInterface.bulkExport(BulkExportRequest bulkExportRequest,
TableStoreCallback<BulkExportRequest,BulkExportResponse> callback)
从表中查询一个范围内的多行数据,离线服务接口。
|
Future<BulkExportResponse> |
InternalClient.bulkExportInternal(BulkExportRequest request,
TableStoreCallback<BulkExportRequest,BulkExportResponse> callback) |
Future<BulkImportResponse> |
AsyncClient.bulkImport(BulkImportRequest request,
TableStoreCallback<BulkImportRequest,BulkImportResponse> callback) |
Future<BulkImportResponse> |
InternalClient.bulkImport(BulkImportRequest request,
TableStoreCallback<BulkImportRequest,BulkImportResponse> callback) |
Future<BulkImportResponse> |
AsyncClientInterface.bulkImport(BulkImportRequest bulkImportRequest,
TableStoreCallback<BulkImportRequest,BulkImportResponse> callback)
在单张表中对多行执行更新或者删除操作,离线服务接口。
|
Future<com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse> |
InternalClient.checkpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest request,
TableStoreCallback<com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest,com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse> callback) |
Future<CommitTransactionResponse> |
AsyncClient.commitTransaction(CommitTransactionRequest request,
TableStoreCallback<CommitTransactionRequest,CommitTransactionResponse> callback) |
Future<CommitTransactionResponse> |
InternalClient.commitTransaction(CommitTransactionRequest request,
TableStoreCallback<CommitTransactionRequest,CommitTransactionResponse> callback) |
Future<CommitTransactionResponse> |
AsyncClientInterface.commitTransaction(CommitTransactionRequest request,
TableStoreCallback<CommitTransactionRequest,CommitTransactionResponse> callback)
提交一个事务
|
Future<ComputeSplitsBySizeResponse> |
AsyncClient.computeSplitsBySize(ComputeSplitsBySizeRequest request,
TableStoreCallback<ComputeSplitsBySizeRequest,ComputeSplitsBySizeResponse> callback) |
Future<ComputeSplitsBySizeResponse> |
InternalClient.computeSplitsBySize(ComputeSplitsBySizeRequest request,
TableStoreCallback<ComputeSplitsBySizeRequest,ComputeSplitsBySizeResponse> callback) |
Future<ComputeSplitsBySizeResponse> |
AsyncClientInterface.computeSplitsBySize(ComputeSplitsBySizeRequest computeSplitsBySizeRequest,
TableStoreCallback<ComputeSplitsBySizeRequest,ComputeSplitsBySizeResponse> callback)
对表的数据根据一定的数据大小进行分块,并返回分块的信息以供数据获取接口使用。
|
Future<com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse> |
InternalClient.connectTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest request,
TableStoreCallback<com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest,com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse> callback) |
Future<CreateIndexResponse> |
AsyncClient.createIndex(CreateIndexRequest request,
TableStoreCallback<CreateIndexRequest,CreateIndexResponse> callback) |
Future<CreateIndexResponse> |
InternalClient.createIndex(CreateIndexRequest request,
TableStoreCallback<CreateIndexRequest,CreateIndexResponse> callback) |
Future<CreateIndexResponse> |
AsyncClientInterface.createIndex(CreateIndexRequest createIndexRequest,
TableStoreCallback<CreateIndexRequest,CreateIndexResponse> callback)
在用户指定的某张表下创建一张索引表
|
Future<CreateSearchIndexResponse> |
AsyncClient.createSearchIndex(CreateSearchIndexRequest request,
TableStoreCallback<CreateSearchIndexRequest,CreateSearchIndexResponse> callback) |
Future<CreateSearchIndexResponse> |
InternalClient.createSearchIndex(CreateSearchIndexRequest request,
TableStoreCallback<CreateSearchIndexRequest,CreateSearchIndexResponse> callback) |
Future<CreateSearchIndexResponse> |
AsyncClientInterface.createSearchIndex(CreateSearchIndexRequest request,
TableStoreCallback<CreateSearchIndexRequest,CreateSearchIndexResponse> callback)
创建SearchIndex
|
Future<CreateTableResponse> |
AsyncClient.createTable(CreateTableRequest request,
TableStoreCallback<CreateTableRequest,CreateTableResponse> callback) |
Future<CreateTableResponse> |
InternalClient.createTable(CreateTableRequest request,
TableStoreCallback<CreateTableRequest,CreateTableResponse> callback) |
Future<CreateTableResponse> |
AsyncClientInterface.createTable(CreateTableRequest createTableRequest,
TableStoreCallback<CreateTableRequest,CreateTableResponse> callback)
在用户的实例下创建一张新的表。
|
Future<CreateTunnelResponse> |
InternalClient.createTunnel(CreateTunnelRequest request,
TableStoreCallback<CreateTunnelRequest,CreateTunnelResponse> callback) |
Future<DeleteDefinedColumnResponse> |
AsyncClient.deleteDefinedColumn(DeleteDefinedColumnRequest request,
TableStoreCallback<DeleteDefinedColumnRequest,DeleteDefinedColumnResponse> callback) |
Future<DeleteDefinedColumnResponse> |
InternalClient.deleteDefinedColumn(DeleteDefinedColumnRequest request,
TableStoreCallback<DeleteDefinedColumnRequest,DeleteDefinedColumnResponse> callback) |
Future<DeleteDefinedColumnResponse> |
AsyncClientInterface.deleteDefinedColumn(DeleteDefinedColumnRequest deleteDefinedColumnRequest,
TableStoreCallback<DeleteDefinedColumnRequest,DeleteDefinedColumnResponse> callback)
为用户指定的表删除预定义列
|
Future<DeleteIndexResponse> |
AsyncClient.deleteIndex(DeleteIndexRequest request,
TableStoreCallback<DeleteIndexRequest,DeleteIndexResponse> callback) |
Future<DeleteIndexResponse> |
InternalClient.deleteIndex(DeleteIndexRequest request,
TableStoreCallback<DeleteIndexRequest,DeleteIndexResponse> callback) |
Future<DeleteIndexResponse> |
AsyncClientInterface.deleteIndex(DeleteIndexRequest deleteIndexRequest,
TableStoreCallback<DeleteIndexRequest,DeleteIndexResponse> callback)
在用户指定的某张表下删除一张索引表
|
Future<DeleteRowResponse> |
AsyncClient.deleteRow(DeleteRowRequest request,
TableStoreCallback<DeleteRowRequest,DeleteRowResponse> callback) |
Future<DeleteRowResponse> |
InternalClient.deleteRow(DeleteRowRequest request,
TableStoreCallback<DeleteRowRequest,DeleteRowResponse> callback) |
Future<DeleteRowResponse> |
AsyncClientInterface.deleteRow(DeleteRowRequest deleteRowRequest,
TableStoreCallback<DeleteRowRequest,DeleteRowResponse> callback)
删除表中的一行数据。
|
Future<DeleteSearchIndexResponse> |
AsyncClient.deleteSearchIndex(DeleteSearchIndexRequest request,
TableStoreCallback<DeleteSearchIndexRequest,DeleteSearchIndexResponse> callback) |
Future<DeleteSearchIndexResponse> |
InternalClient.deleteSearchIndex(DeleteSearchIndexRequest request,
TableStoreCallback<DeleteSearchIndexRequest,DeleteSearchIndexResponse> callback) |
Future<DeleteSearchIndexResponse> |
AsyncClientInterface.deleteSearchIndex(DeleteSearchIndexRequest request,
TableStoreCallback<DeleteSearchIndexRequest,DeleteSearchIndexResponse> callback)
删除SearchIndex
通过指定 tableName 和 indexName 即可删除一个index
提示:在没有删除一个table下面所有的index之前,是不允许删除table的
|
Future<DeleteTableResponse> |
AsyncClient.deleteTable(DeleteTableRequest request,
TableStoreCallback<DeleteTableRequest,DeleteTableResponse> callback) |
Future<DeleteTableResponse> |
InternalClient.deleteTable(DeleteTableRequest request,
TableStoreCallback<DeleteTableRequest,DeleteTableResponse> callback) |
Future<DeleteTableResponse> |
AsyncClientInterface.deleteTable(DeleteTableRequest deleteTableRequest,
TableStoreCallback<DeleteTableRequest,DeleteTableResponse> callback)
删除用户指定的某个实例下的一张表。。
|
Future<DeleteTunnelResponse> |
InternalClient.deleteTunnel(DeleteTunnelRequest request,
TableStoreCallback<DeleteTunnelRequest,DeleteTunnelResponse> callback) |
Future<DescribeSearchIndexResponse> |
AsyncClient.describeSearchIndex(DescribeSearchIndexRequest request,
TableStoreCallback<DescribeSearchIndexRequest,DescribeSearchIndexResponse> callback) |
Future<DescribeSearchIndexResponse> |
InternalClient.describeSearchIndex(DescribeSearchIndexRequest request,
TableStoreCallback<DescribeSearchIndexRequest,DescribeSearchIndexResponse> callback) |
Future<DescribeSearchIndexResponse> |
AsyncClientInterface.describeSearchIndex(DescribeSearchIndexRequest request,
TableStoreCallback<DescribeSearchIndexRequest,DescribeSearchIndexResponse> callback)
获取一个SearchIndex的信息
|
Future<DescribeStreamResponse> |
AsyncClient.describeStream(DescribeStreamRequest request,
TableStoreCallback<DescribeStreamRequest,DescribeStreamResponse> callback) |
Future<DescribeStreamResponse> |
InternalClient.describeStream(DescribeStreamRequest request,
TableStoreCallback<DescribeStreamRequest,DescribeStreamResponse> callback) |
Future<DescribeStreamResponse> |
AsyncClientInterface.describeStream(DescribeStreamRequest describeStreamRequest,
TableStoreCallback<DescribeStreamRequest,DescribeStreamResponse> callback)
获取指定Stream的详细信息。
|
Future<DescribeTableResponse> |
AsyncClient.describeTable(DescribeTableRequest request,
TableStoreCallback<DescribeTableRequest,DescribeTableResponse> callback) |
Future<DescribeTableResponse> |
InternalClient.describeTable(DescribeTableRequest request,
TableStoreCallback<DescribeTableRequest,DescribeTableResponse> callback) |
Future<DescribeTableResponse> |
AsyncClientInterface.describeTable(DescribeTableRequest describeTableRequest,
TableStoreCallback<DescribeTableRequest,DescribeTableResponse> callback)
|
Future<DescribeTunnelResponse> |
InternalClient.describeTunnel(DescribeTunnelRequest request,
TableStoreCallback<DescribeTunnelRequest,DescribeTunnelResponse> callback) |
Future<com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse> |
InternalClient.getCheckpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest request,
TableStoreCallback<com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest,com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse> callback) |
Future<GetRangeResponse> |
AsyncClient.getRange(GetRangeRequest request,
TableStoreCallback<GetRangeRequest,GetRangeResponse> callback) |
Future<GetRangeResponse> |
InternalClient.getRange(GetRangeRequest request,
TableStoreCallback<GetRangeRequest,GetRangeResponse> callback) |
Future<GetRangeResponse> |
AsyncClientInterface.getRange(GetRangeRequest getRangeRequest,
TableStoreCallback<GetRangeRequest,GetRangeResponse> callback)
从表中查询一个范围内的多行数据。
|
Future<GetRangeResponse> |
InternalClient.getRangeInternal(GetRangeRequest request,
TableStoreCallback<GetRangeRequest,GetRangeResponse> callback) |
Future<GetRowResponse> |
AsyncClient.getRow(GetRowRequest request,
TableStoreCallback<GetRowRequest,GetRowResponse> callback) |
Future<GetRowResponse> |
InternalClient.getRow(GetRowRequest request,
TableStoreCallback<GetRowRequest,GetRowResponse> callback) |
Future<GetRowResponse> |
AsyncClientInterface.getRow(GetRowRequest getRowRequest,
TableStoreCallback<GetRowRequest,GetRowResponse> callback)
读取表中的一行数据。
|
Future<GetRowResponse> |
InternalClient.getRowInternal(GetRowRequest request,
TableStoreCallback<GetRowRequest,GetRowResponse> callback) |
Future<GetShardIteratorResponse> |
AsyncClient.getShardIterator(GetShardIteratorRequest request,
TableStoreCallback<GetShardIteratorRequest,GetShardIteratorResponse> callback) |
Future<GetShardIteratorResponse> |
InternalClient.getShardIterator(GetShardIteratorRequest request,
TableStoreCallback<GetShardIteratorRequest,GetShardIteratorResponse> callback) |
Future<GetShardIteratorResponse> |
AsyncClientInterface.getShardIterator(GetShardIteratorRequest getShardIteratorRequest,
TableStoreCallback<GetShardIteratorRequest,GetShardIteratorResponse> callback)
获取ShardIterator,可通过ShardIterator读取Shard中的数据。
|
Future<GetStreamRecordResponse> |
AsyncClient.getStreamRecord(GetStreamRecordRequest request,
TableStoreCallback<GetStreamRecordRequest,GetStreamRecordResponse> callback) |
Future<GetStreamRecordResponse> |
InternalClient.getStreamRecord(GetStreamRecordRequest request,
TableStoreCallback<GetStreamRecordRequest,GetStreamRecordResponse> callback) |
Future<GetStreamRecordResponse> |
AsyncClientInterface.getStreamRecord(GetStreamRecordRequest getStreamRecordRequest,
TableStoreCallback<GetStreamRecordRequest,GetStreamRecordResponse> callback)
通过ShardIterator读取Shard中的数据。
|
Future<com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse> |
InternalClient.heartbeat(com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest request,
TableStoreCallback<com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest,com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse> callback) |
Future<ListSearchIndexResponse> |
AsyncClient.listSearchIndex(ListSearchIndexRequest request,
TableStoreCallback<ListSearchIndexRequest,ListSearchIndexResponse> callback) |
Future<ListSearchIndexResponse> |
InternalClient.listSearchIndex(ListSearchIndexRequest request,
TableStoreCallback<ListSearchIndexRequest,ListSearchIndexResponse> callback) |
Future<ListSearchIndexResponse> |
AsyncClientInterface.listSearchIndex(ListSearchIndexRequest request,
TableStoreCallback<ListSearchIndexRequest,ListSearchIndexResponse> callback)
获取表下的SearchIndex列表
一个table下面,可以存在多个SearchIndex表,通过该函数,将能够获取一个table下面的所有SearchIndex信息
|
Future<ListStreamResponse> |
AsyncClient.listStream(ListStreamRequest request,
TableStoreCallback<ListStreamRequest,ListStreamResponse> callback) |
Future<ListStreamResponse> |
InternalClient.listStream(ListStreamRequest request,
TableStoreCallback<ListStreamRequest,ListStreamResponse> callback) |
Future<ListStreamResponse> |
AsyncClientInterface.listStream(ListStreamRequest listStreamRequest,
TableStoreCallback<ListStreamRequest,ListStreamResponse> callback)
获取用户当前实例下的全部Stream列表或者特定表下的Stream。
|
Future<ListTableResponse> |
AsyncClient.listTable(TableStoreCallback<ListTableRequest,ListTableResponse> callback) |
Future<ListTableResponse> |
InternalClient.listTable(TableStoreCallback<ListTableRequest,ListTableResponse> callback) |
Future<ListTableResponse> |
AsyncClientInterface.listTable(TableStoreCallback<ListTableRequest,ListTableResponse> callback)
返回用户当前实例下的所有表的列表。
|
Future<ListTunnelResponse> |
InternalClient.listTunnel(ListTunnelRequest request,
TableStoreCallback<ListTunnelRequest,ListTunnelResponse> callback) |
Future<PutRowResponse> |
AsyncClient.putRow(PutRowRequest request,
TableStoreCallback<PutRowRequest,PutRowResponse> callback) |
Future<PutRowResponse> |
InternalClient.putRow(PutRowRequest request,
TableStoreCallback<PutRowRequest,PutRowResponse> callback) |
Future<PutRowResponse> |
AsyncClientInterface.putRow(PutRowRequest putRowRequest,
TableStoreCallback<PutRowRequest,PutRowResponse> callback)
向表中插入或覆盖一行数据。
|
Future<com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse> |
InternalClient.readRecords(com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest request,
TableStoreCallback<com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest,com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse> callback) |
Future<SearchResponse> |
AsyncClient.search(SearchRequest request,
TableStoreCallback<SearchRequest,SearchResponse> callback) |
Future<SearchResponse> |
InternalClient.search(SearchRequest request,
TableStoreCallback<SearchRequest,SearchResponse> callback) |
Future<SearchResponse> |
AsyncClientInterface.search(SearchRequest request,
TableStoreCallback<SearchRequest,SearchResponse> callback)
搜索功能
构建自己的SearchRequest,然后获取SearchResponse
示例:
SearchQuery searchQuery = new SearchQuery();
TermQuery termQuery = new TermQuery();
termQuery.setFieldName("user_name");
termQuery.setTerm("jay");
searchQuery.setQuery(termQuery);
SearchRequest searchRequest = new SearchRequest(tableName, indexName, searchQuery);
SearchResponse resp = ots.search(searchRequest);
|
void |
DefaultTableStoreWriter.setCallback(TableStoreCallback<RowChange,ConsumedCapacity> callback) |
void |
TableStoreWriter.setCallback(TableStoreCallback<RowChange,ConsumedCapacity> callback)
|
void |
DefaultTableStoreWriter.setResultCallback(TableStoreCallback<RowChange,RowWriteResult> resultCallback) |
void |
TableStoreWriter.setResultCallback(TableStoreCallback<RowChange,RowWriteResult> callback)
设置Callback,数据写入成功或者失败均会通过Callback来反馈。
|
Future<com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse> |
InternalClient.shutdownTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest request,
TableStoreCallback<com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest,com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse> callback) |
Future<StartLocalTransactionResponse> |
AsyncClient.startLocalTransaction(StartLocalTransactionRequest request,
TableStoreCallback<StartLocalTransactionRequest,StartLocalTransactionResponse> callback) |
Future<StartLocalTransactionResponse> |
InternalClient.startLocalTransaction(StartLocalTransactionRequest request,
TableStoreCallback<StartLocalTransactionRequest,StartLocalTransactionResponse> callback) |
Future<StartLocalTransactionResponse> |
AsyncClientInterface.startLocalTransaction(StartLocalTransactionRequest request,
TableStoreCallback<StartLocalTransactionRequest,StartLocalTransactionResponse> callback)
开启一个本地事务
|
Future<UpdateRowResponse> |
AsyncClient.updateRow(UpdateRowRequest request,
TableStoreCallback<UpdateRowRequest,UpdateRowResponse> callback) |
Future<UpdateRowResponse> |
InternalClient.updateRow(UpdateRowRequest request,
TableStoreCallback<UpdateRowRequest,UpdateRowResponse> callback) |
Future<UpdateRowResponse> |
AsyncClientInterface.updateRow(UpdateRowRequest updateRowRequest,
TableStoreCallback<UpdateRowRequest,UpdateRowResponse> callback)
更新表中的一行数据。
|
Future<UpdateTableResponse> |
AsyncClient.updateTable(UpdateTableRequest request,
TableStoreCallback<UpdateTableRequest,UpdateTableResponse> callback) |
Future<UpdateTableResponse> |
InternalClient.updateTable(UpdateTableRequest request,
TableStoreCallback<UpdateTableRequest,UpdateTableResponse> callback) |
Future<UpdateTableResponse> |
AsyncClientInterface.updateTable(UpdateTableRequest updateTableRequest,
TableStoreCallback<UpdateTableRequest,UpdateTableResponse> callback)
在表被创建之后,动态的更改表的配置或预留吞吐量。
|