public class InternalClient extends Object
构造器和说明 |
---|
InternalClient(String endpoint,
CredentialsProvider credsProvider,
String instanceName,
ClientConfiguration config,
ExecutorService callbackExecutor) |
InternalClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName)
使用指定的TableStore Endpoint和默认配置构造一个新的
AsyncClient 实例。 |
InternalClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
ClientConfiguration config)
使用指定的TableStore Endpoint和默认配置构造一个新的
AsyncClient 实例。 |
InternalClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
ClientConfiguration config,
ExecutorService callbackExecutor)
使用指定的TableStore Endpoint和默认配置构造一个新的
AsyncClient 实例。 |
InternalClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
ClientConfiguration config,
ExecutorService callbackExecutor,
String stsToken)
使用指定的TableStore Endpoint和默认配置构造一个新的
AsyncClient 实例。 |
public InternalClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName)
AsyncClient
实例。endpoint
- TableStore服务的endpoint。accessKeyId
- 访问TableStore服务的Access ID。accessKeySecret
- 访问TableStore服务的Access Key。instanceName
- 访问TableStore服务的实例名称。public InternalClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, ClientConfiguration config)
AsyncClient
实例。endpoint
- TableStore服务的endpoint。accessKeyId
- 访问TableStore服务的Access ID。accessKeySecret
- 访问TableStore服务的Access Key。instanceName
- 访问TableStore服务的实例名称。config
- 客户端配置信息(ClientConfiguration
)。 如果传入null则使用默认配置。public InternalClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, ClientConfiguration config, ExecutorService callbackExecutor)
AsyncClient
实例。endpoint
- TableStore服务的endpoint。accessKeyId
- 访问TableStore服务的Access ID。accessKeySecret
- 访问TableStore服务的Access Key。instanceName
- 访问TableStore服务的实例名称。config
- 客户端配置信息(ClientConfiguration
)。 如果传入null则使用默认配置。callbackExecutor
- 用于执行用户在调用异步接口时传入的Callback。如果传入null则使用默认配置( 线程数与CPU核数相同的线程池)。public InternalClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, ClientConfiguration config, ExecutorService callbackExecutor, String stsToken)
AsyncClient
实例。endpoint
- TableStore服务的endpoint。accessKeyId
- 访问TableStore服务的Access ID。accessKeySecret
- 访问TableStore服务的Access Key。instanceName
- 访问TableStore服务的实例名称。config
- 客户端配置信息(ClientConfiguration
)。 如果传入null则使用默认配置。callbackExecutor
- 用于执行用户在调用异步接口时传入的Callback。如果传入null则使用默认配置( 线程数与CPU核数相同的线程池)。stsToken
- Sts Token.public InternalClient(String endpoint, CredentialsProvider credsProvider, String instanceName, ClientConfiguration config, ExecutorService callbackExecutor)
public String getEndpoint()
public String getInstanceName()
public ClientConfiguration getClientConfig()
public Future<ListTableResponse> listTable(TableStoreCallback<ListTableRequest,ListTableResponse> callback)
public Future<CreateTableResponse> createTable(CreateTableRequest request, TableStoreCallback<CreateTableRequest,CreateTableResponse> callback)
public Future<DescribeTableResponse> describeTable(DescribeTableRequest request, TableStoreCallback<DescribeTableRequest,DescribeTableResponse> callback)
public Future<DeleteTableResponse> deleteTable(DeleteTableRequest request, TableStoreCallback<DeleteTableRequest,DeleteTableResponse> callback)
public Future<UpdateTableResponse> updateTable(UpdateTableRequest request, TableStoreCallback<UpdateTableRequest,UpdateTableResponse> callback)
public Future<CreateIndexResponse> createIndex(CreateIndexRequest request, TableStoreCallback<CreateIndexRequest,CreateIndexResponse> callback)
public Future<DeleteIndexResponse> deleteIndex(DeleteIndexRequest request, TableStoreCallback<DeleteIndexRequest,DeleteIndexResponse> callback)
public Future<GetRowResponse> getRowInternal(GetRowRequest request, TableStoreCallback<GetRowRequest,GetRowResponse> callback)
public Future<GetRowResponse> getRow(GetRowRequest request, TableStoreCallback<GetRowRequest,GetRowResponse> callback)
public Future<PutRowResponse> putRow(PutRowRequest request, TableStoreCallback<PutRowRequest,PutRowResponse> callback)
public Future<UpdateRowResponse> updateRow(UpdateRowRequest request, TableStoreCallback<UpdateRowRequest,UpdateRowResponse> callback)
public Future<DeleteRowResponse> deleteRow(DeleteRowRequest request, TableStoreCallback<DeleteRowRequest,DeleteRowResponse> callback)
public Future<BatchGetRowResponse> batchGetRowInternal(BatchGetRowRequest request, TableStoreCallback<BatchGetRowRequest,BatchGetRowResponse> callback)
public Future<BatchGetRowResponse> batchGetRow(BatchGetRowRequest request, TableStoreCallback<BatchGetRowRequest,BatchGetRowResponse> callback)
public Future<BatchWriteRowResponse> batchWriteRow(BatchWriteRowRequest request, TableStoreCallback<BatchWriteRowRequest,BatchWriteRowResponse> callback)
public Future<GetRangeResponse> getRangeInternal(GetRangeRequest request, TableStoreCallback<GetRangeRequest,GetRangeResponse> callback)
public Future<GetRangeResponse> getRange(GetRangeRequest request, TableStoreCallback<GetRangeRequest,GetRangeResponse> callback)
public Future<ComputeSplitsBySizeResponse> computeSplitsBySize(ComputeSplitsBySizeRequest request, TableStoreCallback<ComputeSplitsBySizeRequest,ComputeSplitsBySizeResponse> callback)
public void shutdown()
public Future<ListStreamResponse> listStream(ListStreamRequest request, TableStoreCallback<ListStreamRequest,ListStreamResponse> callback)
public Future<DescribeStreamResponse> describeStream(DescribeStreamRequest request, TableStoreCallback<DescribeStreamRequest,DescribeStreamResponse> callback)
public Future<GetShardIteratorResponse> getShardIterator(GetShardIteratorRequest request, TableStoreCallback<GetShardIteratorRequest,GetShardIteratorResponse> callback)
public Future<GetStreamRecordResponse> getStreamRecord(GetStreamRecordRequest request, TableStoreCallback<GetStreamRecordRequest,GetStreamRecordResponse> callback)
public Future<StartLocalTransactionResponse> startLocalTransaction(StartLocalTransactionRequest request, TableStoreCallback<StartLocalTransactionRequest,StartLocalTransactionResponse> callback)
public Future<CommitTransactionResponse> commitTransaction(CommitTransactionRequest request, TableStoreCallback<CommitTransactionRequest,CommitTransactionResponse> callback)
public Future<AbortTransactionResponse> abortTransaction(AbortTransactionRequest request, TableStoreCallback<AbortTransactionRequest,AbortTransactionResponse> callback)
public Future<CreateSearchIndexResponse> createSearchIndex(CreateSearchIndexRequest request, TableStoreCallback<CreateSearchIndexRequest,CreateSearchIndexResponse> callback)
public Future<ListSearchIndexResponse> listSearchIndex(ListSearchIndexRequest request, TableStoreCallback<ListSearchIndexRequest,ListSearchIndexResponse> callback)
public Future<DeleteSearchIndexResponse> deleteSearchIndex(DeleteSearchIndexRequest request, TableStoreCallback<DeleteSearchIndexRequest,DeleteSearchIndexResponse> callback)
public Future<DescribeSearchIndexResponse> describeSearchIndex(DescribeSearchIndexRequest request, TableStoreCallback<DescribeSearchIndexRequest,DescribeSearchIndexResponse> callback)
public Future<SearchResponse> search(SearchRequest request, TableStoreCallback<SearchRequest,SearchResponse> callback)
public Future<CreateTunnelResponse> createTunnel(CreateTunnelRequest request, TableStoreCallback<CreateTunnelRequest,CreateTunnelResponse> callback)
public Future<ListTunnelResponse> listTunnel(ListTunnelRequest request, TableStoreCallback<ListTunnelRequest,ListTunnelResponse> callback)
public Future<DescribeTunnelResponse> describeTunnel(DescribeTunnelRequest request, TableStoreCallback<DescribeTunnelRequest,DescribeTunnelResponse> callback)
public Future<DeleteTunnelResponse> deleteTunnel(DeleteTunnelRequest request, TableStoreCallback<DeleteTunnelRequest,DeleteTunnelResponse> callback)
public Future<com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse> 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)
public Future<com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse> 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)
public Future<com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse> 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)
public Future<com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse> 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)
public Future<com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse> 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)
public Future<com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse> 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)
public void setCredentials(ServiceCredentials credentials)
public void switchCredentialsProvider(CredentialsProvider newCrdsProvider)
Copyright © 2019. All Rights Reserved.