限定符和类型 | 方法和说明 |
---|---|
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)
向本地缓冲区增加一行数据。
|
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 |
TunnelClientInterface.checkpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse |
TunnelClient.checkpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest request) |
CommitTransactionResponse |
SyncClient.commitTransaction(CommitTransactionRequest request) |
CommitTransactionResponse |
SyncClientInterface.commitTransaction(CommitTransactionRequest request)
提交一个事务
|
ComputeSplitsBySizeResponse |
SyncClient.computeSplitsBySize(ComputeSplitsBySizeRequest computeSplitsBySizeRequest) |
ComputeSplitsBySizeResponse |
SyncClientInterface.computeSplitsBySize(ComputeSplitsBySizeRequest computeSplitsBySizeRequest)
对表的数据根据一定的数据大小进行分块,并返回分块的信息以供数据获取接口使用。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse |
TunnelClientInterface.connectTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse |
TunnelClient.connectTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest request) |
CreateIndexResponse |
SyncClient.createIndex(CreateIndexRequest createIndexRequest) |
CreateIndexResponse |
SyncClientInterface.createIndex(CreateIndexRequest createIndexRequest)
在用户指定的某张表下创建一张索引表
|
Iterator<Row> |
SyncClient.createRangeIterator(RangeIteratorParameter rangeIteratorParameter) |
Iterator<Row> |
SyncClientInterface.createRangeIterator(RangeIteratorParameter rangeIteratorParameter)
以迭代器的形式封装
SyncClientInterface.getRange(GetRangeRequest) 接口。 |
CreateSearchIndexResponse |
SyncClient.createSearchIndex(CreateSearchIndexRequest request) |
CreateSearchIndexResponse |
SyncClientInterface.createSearchIndex(CreateSearchIndexRequest request)
创建SearchIndex
|
CreateTableResponse |
SyncClient.createTable(CreateTableRequest createTableRequest) |
CreateTableResponse |
SyncClientInterface.createTable(CreateTableRequest createTableRequest)
在用户的实例下创建一张新的表。
|
CreateTunnelResponse |
TunnelClientInterface.createTunnel(CreateTunnelRequest request)
创建一个Tunnel。
|
CreateTunnelResponse |
TunnelClient.createTunnel(CreateTunnelRequest request) |
WideColumnIterator |
SyncClient.createWideColumnIterator(GetRowRequest getRowRequest) |
WideColumnIterator |
SyncClientInterface.createWideColumnIterator(GetRowRequest getRowRequest) |
DeleteDefinedColumnResponse |
SyncClient.deleteDefinedColumn(DeleteDefinedColumnRequest deleteDefinedColumnRequest) |
DeleteDefinedColumnResponse |
SyncClientInterface.deleteDefinedColumn(DeleteDefinedColumnRequest deleteDefinedColumnRequest)
为一张表删除预定义列
|
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
通过指定 tableName 和 indexName 即可删除一个index
提示:在没有删除一个table下面所有的index之前,是不允许删除table的
|
DeleteTableResponse |
SyncClient.deleteTable(DeleteTableRequest deleteTableRequest) |
DeleteTableResponse |
SyncClientInterface.deleteTable(DeleteTableRequest deleteTableRequest)
删除用户指定的某个实例下的一张表。。
|
DeleteTunnelResponse |
TunnelClientInterface.deleteTunnel(DeleteTunnelRequest request)
删除一个Tunnel。
|
DeleteTunnelResponse |
TunnelClient.deleteTunnel(DeleteTunnelRequest request) |
DescribeSearchIndexResponse |
SyncClient.describeSearchIndex(DescribeSearchIndexRequest request) |
DescribeSearchIndexResponse |
SyncClientInterface.describeSearchIndex(DescribeSearchIndexRequest request)
获取一个SearchIndex的信息
|
DescribeStreamResponse |
SyncClient.describeStream(DescribeStreamRequest describeStreamRequest) |
DescribeStreamResponse |
SyncClientInterface.describeStream(DescribeStreamRequest describeStreamRequest)
获取指定Stream的详细信息。
|
DescribeTableResponse |
SyncClient.describeTable(DescribeTableRequest request) |
DescribeTableResponse |
SyncClientInterface.describeTable(DescribeTableRequest describeTableRequest)
|
DescribeTunnelResponse |
TunnelClientInterface.describeTunnel(DescribeTunnelRequest request)
获取某个Tunnel下的具体信息。
|
DescribeTunnelResponse |
TunnelClient.describeTunnel(DescribeTunnelRequest request) |
void |
DefaultTableStoreWriter.flush() |
void |
TableStoreWriter.flush()
主动flush缓冲区中的数据,该函数会等待缓冲区中的所有数据被flush完毕。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse |
TunnelClientInterface.getCheckpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse |
TunnelClient.getCheckpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest request) |
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中的数据。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse |
TunnelClientInterface.heartbeat(com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse |
TunnelClient.heartbeat(com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest request) |
ListSearchIndexResponse |
SyncClient.listSearchIndex(ListSearchIndexRequest request) |
ListSearchIndexResponse |
SyncClientInterface.listSearchIndex(ListSearchIndexRequest request)
获取表下的SearchIndex列表
一个table下面,可以存在多个SearchIndex表,通过该函数,将能够获取一个table下面的所有SearchIndex信息
|
ListStreamResponse |
SyncClient.listStream(ListStreamRequest listStreamRequest) |
ListStreamResponse |
SyncClientInterface.listStream(ListStreamRequest listStreamRequest)
获取用户当前实例下的全部Stream列表或者特定表下的Stream。
|
ListTableResponse |
SyncClient.listTable() |
ListTableResponse |
SyncClientInterface.listTable()
返回用户当前实例下的所有表的列表。
|
ListTunnelResponse |
TunnelClientInterface.listTunnel(ListTunnelRequest request)
获取某个表下的Tunnel信息。
|
ListTunnelResponse |
TunnelClient.listTunnel(ListTunnelRequest request) |
PutRowResponse |
SyncClient.putRow(PutRowRequest putRowRequest) |
PutRowResponse |
SyncClientInterface.putRow(PutRowRequest putRowRequest)
向表中插入或覆盖一行数据。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse |
TunnelClientInterface.readRecords(com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse |
TunnelClient.readRecords(com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest request) |
SearchResponse |
SyncClient.search(SearchRequest request) |
SearchResponse |
SyncClientInterface.search(SearchRequest request)
搜索功能
构建自己的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);
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse |
TunnelClientInterface.shutdownTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse |
TunnelClient.shutdownTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest request) |
StartLocalTransactionResponse |
SyncClient.startLocalTransaction(StartLocalTransactionRequest request) |
StartLocalTransactionResponse |
SyncClientInterface.startLocalTransaction(StartLocalTransactionRequest request)
开启一个本地事务
|
boolean |
TableStoreWriter.tryAddRowChange(RowChange rowChange)
Same with
TableStoreWriter.addRowChange(RowChange) , but it won't be blocked if the buffer is full. |
UpdateRowResponse |
SyncClient.updateRow(UpdateRowRequest updateRowRequest) |
UpdateRowResponse |
SyncClientInterface.updateRow(UpdateRowRequest updateRowRequest)
更新表中的一行数据。
|
UpdateTableResponse |
SyncClient.updateTable(UpdateTableRequest request) |
UpdateTableResponse |
SyncClientInterface.updateTable(UpdateTableRequest updateTableRequest)
在表被创建之后,动态的更改表的配置或预留吞吐量。
|
限定符和类型 | 方法和说明 |
---|---|
abstract URL |
HttpCredentialsFetcher.buildUrl() |
URL |
CredentialsFetcher.buildUrl()
构造授权服务器的URL
|
URL |
InstanceProfileCredentialsFetcher.buildUrl() |
ServiceCredentials |
HttpCredentialsFetcher.fetch() |
ServiceCredentials |
CredentialsFetcher.fetch()
从授权服务器获取授权
|
ServiceCredentials |
HttpCredentialsFetcher.fetch(int retryTimes) |
ServiceCredentials |
CredentialsFetcher.fetch(int retryTimes)
从授权服务器获取授权
|
static EnvironmentVariableCredentialsProvider |
CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider()
Create an instance of EnvironmentVariableCredentialsProvider by reading
the environment variable to obtain the ak/sk, such as TABLESTORE_ACCESS_KEY_ID
and TABLESTORE_ACCESS_KEY_SECRET
|
static InstanceProfileCredentialsProvider |
CredentialsProviderFactory.newInstanceProfileCredentialsProvider(String roleName)
Create an instance of InstanceProfileCredentialsProvider obtained the
ak/sk by ECS Metadata Service.
|
static SystemPropertiesCredentialsProvider |
CredentialsProviderFactory.newSystemPropertiesCredentialsProvider()
Create an instance of EnvironmentVariableCredentialsProvider by reading
the java system property used when starting up the JVM to enable the
default metrics collected by the TableStore SDK, such as -Dtablestore.accessKeyId and
-Dtablestore.accessKeySecret.
|
abstract ServiceCredentials |
HttpCredentialsFetcher.parse(HttpResponse response) |
ServiceCredentials |
CredentialsFetcher.parse(HttpResponse response)
解析授权服务器返回的授权信息,解析为Credentials
|
ServiceCredentials |
InstanceProfileCredentialsFetcher.parse(HttpResponse response) |
void |
RequestSigner.sign(RequestMessage request) |
void |
RequestSignerInterface.sign(RequestMessage request) |
限定符和类型 | 方法和说明 |
---|---|
void |
OTSValidationResponseHandler.handle(ResponseMessage responseData) |
void |
ErrorResponseHandler.handle(ResponseMessage responseData) |
void |
OTSDeflateResponseHandler.handle(ResponseMessage responseData) |
void |
ContentMD5ResponseHandler.handle(ResponseMessage responseData) |
限定符和类型 | 方法和说明 |
---|---|
static void |
ParamChecker.checkRowChange(TableMeta tableMeta,
RowChange rowChange,
WriterConfig config)
It does following checkings:
- primary key schema is matched with which defined in table meta
|
Copyright © 2019. All Rights Reserved.