public class TunnelClient extends Object implements TunnelClientInterface
构造器和说明 |
---|
TunnelClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName)
使用指定的TableStore Endpoint和默认配置构造一个新的
TunnelClient 实例。 |
TunnelClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
ClientConfiguration config)
使用指定的TableStore Endpoint和配置构造一个新的
TunnelClient 实例。 |
TunnelClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
ClientConfiguration config,
String stsToken)
使用指定的TableStore Endpoint和默认配置构造一个新的
TunnelClient 实例。 |
TunnelClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
ClientConfiguration config,
String stsToken,
ExecutorService callbackExecutor)
使用指定的TableStore Endpoint和默认配置构造一个新的
TunnelClient 实例。 |
TunnelClient(String endpoint,
String accessKeyId,
String accessKeySecret,
String instanceName,
String stsToken)
使用指定的TableStore Endpoint和默认配置构造一个新的
TunnelClient 实例。 |
限定符和类型 | 方法和说明 |
---|---|
com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse |
checkpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse |
connectTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
CreateTunnelResponse |
createTunnel(CreateTunnelRequest request)
创建一个Tunnel。
|
DeleteTunnelResponse |
deleteTunnel(DeleteTunnelRequest request)
删除一个Tunnel。
|
DescribeTunnelResponse |
describeTunnel(DescribeTunnelRequest request)
获取某个Tunnel下的具体信息。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse |
getCheckpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
String |
getEndpoint()
返回访问的TableStore Endpoint。
|
String |
getInstanceName()
返回访问的实例的名称
|
com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse |
heartbeat(com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
ListTunnelResponse |
listTunnel(ListTunnelRequest request)
获取某个表下的Tunnel信息。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse |
readRecords(com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
void |
setExtraHeaders(Map<String,String> extraHeaders) |
void |
shutdown()
释放资源。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse |
shutdownTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
public TunnelClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName)
TunnelClient
实例。endpoint
- TableStore服务的endpoint。accessKeyId
- 访问TableStore服务的Access ID。accessKeySecret
- 访问TableStore服务的Access Key。instanceName
- 访问TableStore服务的实例名称。public TunnelClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, String stsToken)
TunnelClient
实例。endpoint
- TableStore服务的endpoint。accessKeyId
- 访问TableStore服务的Access ID。accessKeySecret
- 访问TableStore服务的Access Key。instanceName
- 访问TableStore服务的实例名称。stsToken
- Sts Token.public TunnelClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, ClientConfiguration config)
TunnelClient
实例。endpoint
- TableStore服务的endpoint。accessKeyId
- 访问TableStore服务的Access ID。accessKeySecret
- 访问TableStore服务的Access Key。instanceName
- 访问TableStore服务的实例名称。config
- 客户端配置信息(ClientConfiguration
)。 如果传入null则使用默认配置。public TunnelClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, ClientConfiguration config, String stsToken)
TunnelClient
实例。endpoint
- TableStore服务的endpoint。accessKeyId
- 访问TableStore服务的Access ID。accessKeySecret
- 访问TableStore服务的Access Key。instanceName
- 访问TableStore服务的实例名称。config
- 客户端配置信息(ClientConfiguration
)。 如果传入null则使用默认配置。stsToken
- Sts Token.public TunnelClient(String endpoint, String accessKeyId, String accessKeySecret, String instanceName, ClientConfiguration config, String stsToken, ExecutorService callbackExecutor)
TunnelClient
实例。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 String getEndpoint()
public String getInstanceName()
public CreateTunnelResponse createTunnel(CreateTunnelRequest request) throws TableStoreException, ClientException
TunnelClientInterface
createTunnel
在接口中 TunnelClientInterface
request
- 创建Tunnel所需的参数,详见CreateTunnelRequest
CreateTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public ListTunnelResponse listTunnel(ListTunnelRequest request) throws TableStoreException, ClientException
TunnelClientInterface
listTunnel
在接口中 TunnelClientInterface
request
- 列举某张表下的Tunnel所需的参数,详见ListTunnelRequest
ListTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public DescribeTunnelResponse describeTunnel(DescribeTunnelRequest request) throws TableStoreException, ClientException
TunnelClientInterface
describeTunnel
在接口中 TunnelClientInterface
request
- 描述某个Tunnel下的详细信息所需的参数,详见DescribeTunnelRequest
DescribeTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public DeleteTunnelResponse deleteTunnel(DeleteTunnelRequest request) throws TableStoreException, ClientException
TunnelClientInterface
deleteTunnel
在接口中 TunnelClientInterface
request
- 删除某个Tunnel所需的参数,详见DeleteTunnelRequest
DeleteTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse connectTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest request) throws TableStoreException, ClientException
TunnelClientInterface
connectTunnel
在接口中 TunnelClientInterface
request
- 连接某个Tunnel所需的参数,详见ConnectTunnelRequest
ConnectTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse heartbeat(com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest request) throws TableStoreException, ClientException
TunnelClientInterface
heartbeat
在接口中 TunnelClientInterface
request
- 探测心跳所需的参数,详见HeartbeatRequest
HeartbeatResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse shutdownTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest request) throws TableStoreException, ClientException
TunnelClientInterface
shutdownTunnel
在接口中 TunnelClientInterface
request
- 关闭TunnelClient所需的参数,详见ShutdownTunnelRequest
ShutdownTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse getCheckpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest request) throws TableStoreException, ClientException
TunnelClientInterface
getCheckpoint
在接口中 TunnelClientInterface
request
- 获取某个Channel的Checkpoint所需的参数,详见GetCheckpointRequest
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse readRecords(com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest request) throws TableStoreException, ClientException
TunnelClientInterface
readRecords
在接口中 TunnelClientInterface
request
- 读取某个Channel中的数据, 详见ReadRecordsRequest
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse checkpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest request) throws TableStoreException, ClientException
TunnelClientInterface
checkpoint
在接口中 TunnelClientInterface
request
- 设置某个Channel上的CheckpointTableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常public void shutdown()
TunnelClientInterface
请确保在所有请求执行完毕之后释放资源。释放资源之后将不能再发送请求,正在执行的请求可能无法返回结果。
shutdown
在接口中 TunnelClientInterface
Copyright © 2019. All Rights Reserved.