public interface TunnelClientInterface
限定符和类型 | 方法和说明 |
---|---|
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自动化数据处理框架。
|
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 |
shutdown()
释放资源。
|
com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse |
shutdownTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest request)
高级接口: 不推荐直接使用,无特殊需求,请优先使用TunnelWorker自动化数据处理框架。
|
CreateTunnelResponse createTunnel(CreateTunnelRequest request) throws TableStoreException, ClientException
request
- 创建Tunnel所需的参数,详见CreateTunnelRequest
CreateTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常ListTunnelResponse listTunnel(ListTunnelRequest request) throws TableStoreException, ClientException
request
- 列举某张表下的Tunnel所需的参数,详见ListTunnelRequest
ListTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常DescribeTunnelResponse describeTunnel(DescribeTunnelRequest request) throws TableStoreException, ClientException
request
- 描述某个Tunnel下的详细信息所需的参数,详见DescribeTunnelRequest
DescribeTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常DeleteTunnelResponse deleteTunnel(DeleteTunnelRequest request) throws TableStoreException, ClientException
request
- 删除某个Tunnel所需的参数,详见DeleteTunnelRequest
DeleteTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse connectTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest request) throws TableStoreException, ClientException
request
- 连接某个Tunnel所需的参数,详见ConnectTunnelRequest
ConnectTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse heartbeat(com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest request) throws TableStoreException, ClientException
request
- 探测心跳所需的参数,详见HeartbeatRequest
HeartbeatResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse shutdownTunnel(com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest request) throws TableStoreException, ClientException
request
- 关闭TunnelClient所需的参数,详见ShutdownTunnelRequest
ShutdownTunnelResponse
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse getCheckpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest request) throws TableStoreException, ClientException
request
- 获取某个Channel的Checkpoint所需的参数,详见GetCheckpointRequest
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse readRecords(com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest request) throws TableStoreException, ClientException
request
- 读取某个Channel中的数据, 详见ReadRecordsRequest
TableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse checkpoint(com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest request) throws TableStoreException, ClientException
request
- 设置某个Channel上的CheckpointTableStoreException
- TableStore服务返回的异常ClientException
- 请求的返回结果无效、或遇到网络异常void shutdown()
请确保在所有请求执行完毕之后释放资源。释放资源之后将不能再发送请求,正在执行的请求可能无法返回结果。
Copyright © 2019. All Rights Reserved.