public class AsyncTimeseriesClient extends Object implements AsyncTimeseriesClientInterface
| Constructor and Description |
|---|
AsyncTimeseriesClient(String endpoint,
CredentialsProvider credsProvider,
String instanceName,
ClientConfiguration config,
ResourceManager resourceManager)
使用指定的TableStore Endpoint和默认配置构造一个新的
AsyncTimeseriesClient实例。 |
AsyncTimeseriesClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName)
使用指定的TableStore Endpoint和默认配置构造一个新的
AsyncTimeseriesClient实例。 |
AsyncTimeseriesClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
ClientConfiguration conf)
使用指定的TableStore Endpoint和配置构造一个新的
AsyncTimeseriesClient实例。 |
AsyncTimeseriesClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
ClientConfiguration config,
String stsToken)
使用指定的TableStore Endpoint和默认配置构造一个新的
AsyncTimeseriesClient实例。 |
AsyncTimeseriesClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
ClientConfiguration config,
String stsToken,
ExecutorService callbackExecutor)
使用指定的TableStore Endpoint和默认配置构造一个新的
AsyncTimeseriesClient实例。 |
AsyncTimeseriesClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
String stsToken)
使用指定的TableStore Endpoint和默认配置构造一个新的
AsyncTimeseriesClient实例。 |
public AsyncTimeseriesClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName)
AsyncTimeseriesClient实例。endpoint - TableStore服务的Endpoint。accessKeyId - 访问TableStore服务的Access ID。accessKeySecret - 访问TableStore服务的Access Key。instanceName - 访问TableStore的服务的实例名称。public AsyncTimeseriesClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, ClientConfiguration conf)
AsyncTimeseriesClient实例。endpoint - TableStore服务的endpoint。accessKeyId - 访问TableStore服务的Access ID。accessKeySecret - 访问TableStore服务的Access Key。instanceName - 访问TableStore服务的实例名称。conf - 客户端配置信息(ClientConfiguration)。 如果传入null则使用默认配置。public AsyncTimeseriesClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, String stsToken)
AsyncTimeseriesClient实例。endpoint - TableStore服务的endpoint。accessKeyId - 访问TableStore服务的Access ID。accessKeySecret - 访问TableStore服务的Access Key。instanceName - 访问TableStore服务的实例名称。stsToken - Sts Token.public AsyncTimeseriesClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, ClientConfiguration config, String stsToken)
AsyncTimeseriesClient实例。endpoint - TableStore服务的endpoint。accessKeyId - 访问TableStore服务的Access ID。accessKeySecret - 访问TableStore服务的Access Key。instanceName - 访问TableStore服务的实例名称。config - 客户端配置信息(ClientConfiguration)。 如果传入null则使用默认配置。stsToken - Sts Token.public AsyncTimeseriesClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, ClientConfiguration config, String stsToken, ExecutorService callbackExecutor)
AsyncTimeseriesClient实例。endpoint - TableStore服务的endpoint。accessKeyId - 访问TableStore服务的Access ID。accessKeySecret - 访问TableStore服务的Access Key。instanceName - 访问TableStore服务的实例名称。config - 客户端配置信息(ClientConfiguration)。 如果传入null则使用默认配置。stsToken - Sts Token.callbackExecutor - 执行callback的线程池,需要注意的是,client在shutdown的时候也会shutdown这个线程池。public AsyncTimeseriesClient(String endpoint, CredentialsProvider credsProvider, String instanceName, ClientConfiguration config, ResourceManager resourceManager)
AsyncTimeseriesClient实例。public Future<CreateTimeseriesTableResponse> createTimeseriesTable(CreateTimeseriesTableRequest request, TableStoreCallback<CreateTimeseriesTableRequest,CreateTimeseriesTableResponse> callback)
createTimeseriesTable in interface AsyncTimeseriesClientInterfacepublic Future<ListTimeseriesTableResponse> listTimeseriesTable(TableStoreCallback<ListTimeseriesTableRequest,ListTimeseriesTableResponse> callback)
listTimeseriesTable in interface AsyncTimeseriesClientInterfacepublic Future<DeleteTimeseriesTableResponse> deleteTimeseriesTable(DeleteTimeseriesTableRequest request, TableStoreCallback<DeleteTimeseriesTableRequest,DeleteTimeseriesTableResponse> callback)
deleteTimeseriesTable in interface AsyncTimeseriesClientInterfacepublic Future<DescribeTimeseriesTableResponse> describeTimeseriesTable(DescribeTimeseriesTableRequest request, TableStoreCallback<DescribeTimeseriesTableRequest,DescribeTimeseriesTableResponse> callback)
describeTimeseriesTable in interface AsyncTimeseriesClientInterfacepublic Future<UpdateTimeseriesTableResponse> updateTimeseriesTable(UpdateTimeseriesTableRequest request, TableStoreCallback<UpdateTimeseriesTableRequest,UpdateTimeseriesTableResponse> callback)
updateTimeseriesTable in interface AsyncTimeseriesClientInterfacepublic Future<PutTimeseriesDataResponse> putTimeseriesData(PutTimeseriesDataRequest request, TableStoreCallback<PutTimeseriesDataRequest,PutTimeseriesDataResponse> callback) throws TableStoreException, ClientException
putTimeseriesData in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<GetTimeseriesDataResponse> getTimeseriesData(GetTimeseriesDataRequest request, TableStoreCallback<GetTimeseriesDataRequest,GetTimeseriesDataResponse> callback) throws TableStoreException, ClientException
getTimeseriesData in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<QueryTimeseriesMetaResponse> queryTimeseriesMeta(QueryTimeseriesMetaRequest request, TableStoreCallback<QueryTimeseriesMetaRequest,QueryTimeseriesMetaResponse> callback) throws TableStoreException, ClientException
queryTimeseriesMeta in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<UpdateTimeseriesMetaResponse> updateTimeseriesMeta(UpdateTimeseriesMetaRequest request, TableStoreCallback<UpdateTimeseriesMetaRequest,UpdateTimeseriesMetaResponse> callback) throws TableStoreException, ClientException
updateTimeseriesMeta in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<DeleteTimeseriesMetaResponse> deleteTimeseriesMeta(DeleteTimeseriesMetaRequest request, TableStoreCallback<DeleteTimeseriesMetaRequest,DeleteTimeseriesMetaResponse> callback) throws TableStoreException, ClientException
deleteTimeseriesMeta in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<SplitTimeseriesScanTaskResponse> splitTimeseriesScanTask(SplitTimeseriesScanTaskRequest request, TableStoreCallback<SplitTimeseriesScanTaskRequest,SplitTimeseriesScanTaskResponse> callback) throws TableStoreException, ClientException
splitTimeseriesScanTask in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<ScanTimeseriesDataResponse> scanTimeseriesData(ScanTimeseriesDataRequest request, TableStoreCallback<ScanTimeseriesDataRequest,ScanTimeseriesDataResponse> callback) throws TableStoreException, ClientException
scanTimeseriesData in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<CreateTimeseriesAnalyticalStoreResponse> createTimeseriesAnalyticalStore(CreateTimeseriesAnalyticalStoreRequest request, TableStoreCallback<CreateTimeseriesAnalyticalStoreRequest,CreateTimeseriesAnalyticalStoreResponse> callback) throws TableStoreException, ClientException
createTimeseriesAnalyticalStore in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<DeleteTimeseriesAnalyticalStoreResponse> deleteTimeseriesAnalyticalStore(DeleteTimeseriesAnalyticalStoreRequest request, TableStoreCallback<DeleteTimeseriesAnalyticalStoreRequest,DeleteTimeseriesAnalyticalStoreResponse> callback) throws TableStoreException, ClientException
deleteTimeseriesAnalyticalStore in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<DescribeTimeseriesAnalyticalStoreResponse> describeTimeseriesAnalyticalStore(DescribeTimeseriesAnalyticalStoreRequest request, TableStoreCallback<DescribeTimeseriesAnalyticalStoreRequest,DescribeTimeseriesAnalyticalStoreResponse> callback) throws TableStoreException, ClientException
describeTimeseriesAnalyticalStore in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<UpdateTimeseriesAnalyticalStoreResponse> updateTimeseriesAnalyticalStore(UpdateTimeseriesAnalyticalStoreRequest request, TableStoreCallback<UpdateTimeseriesAnalyticalStoreRequest,UpdateTimeseriesAnalyticalStoreResponse> callback) throws TableStoreException, ClientException
updateTimeseriesAnalyticalStore in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<CreateTimeseriesLastpointIndexResponse> createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request, TableStoreCallback<CreateTimeseriesLastpointIndexRequest,CreateTimeseriesLastpointIndexResponse> callback) throws TableStoreException, ClientException
createTimeseriesLastpointIndex in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic Future<DeleteTimeseriesLastpointIndexResponse> deleteTimeseriesLastpointIndex(DeleteTimeseriesLastpointIndexRequest request, TableStoreCallback<DeleteTimeseriesLastpointIndexRequest,DeleteTimeseriesLastpointIndexResponse> callback) throws TableStoreException, ClientException
deleteTimeseriesLastpointIndex in interface AsyncTimeseriesClientInterfaceTableStoreExceptionClientExceptionpublic void shutdown()
AsyncTimeseriesClientInterface请确保在所有请求执行完毕之后释放资源。释放资源之后将不能再发送请求,正在执行的请求可能无法返回结果。
shutdown in interface AsyncTimeseriesClientInterfacepublic TimeseriesClientInterface asTimeseriesClientInterface()
asTimeseriesClientInterface in interface AsyncTimeseriesClientInterfacepublic SyncClient asSyncClient()
public AsyncClient asAsyncClient()
public TimeseriesClient asTimeseriesClient()
Copyright © 2024. All Rights Reserved.