public class InternalClient extends Object
构造器和说明 |
---|
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 String getEndpoint()
public String getInstanceName()
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<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)
Copyright © 2017. All Rights Reserved.