通道服务
表格存储的Java SDK提供了通道服务的多个接口封装。接口封装包括管控接口和自动化的数据消费框架两部分。
快速使用
使用通道服务实时消费数据前,您需要为数据表创建通道,然后通过通道消费表中数据。具体操作,请参见快速体验通道服务。
管控接口
为数据表创建通道时,您需要指定数据表名称、通道名称和通道类型。具体操作,请参见创建通道。
创建通道后,您可以根据实际管理通道。
功能特性 | 说明 |
列举某个数据表内通道的具体信息。 | |
描述某个通道里的具体Channel信息。目前一个Channel对应TableStore Stream接口的一个数据分片。 | |
删除指定数据表的一个通道。 |
数据消费框架
自动化的数据消费框架的实现流程是Tunnel Client通过每一轮的定时心跳探测(Heartbeat)进行活跃Channel的探测,Channel和ChannelConnect状态的更新,以及数据处理任务的初始化、运行和结束等。
Tunnel Client可以解决全量和增量数据处理时的常见问题,例如负载均衡、故障恢复、Checkpoint、分区信息同步确保分区信息消费顺序等。使用Tunnel Client后,您只需要关心每条记录的处理逻辑。更多信息,请参见数据消费框架原理介绍。
相关文档
关于通道服务的更多信息,请参见通道服务。
使用通道服务可以实现数据迁移。更多信息,请参见将表格存储数据表中数据同步到另一个数据表或将表格存储时序表中数据同步到另一个时序表。
实时计算Flink能将通道服务的数据通道作为流式数据的输入,可实现通过Flink计算与分析表格存储数据,更多信息,请参见使用教程(宽表模型)和使用教程(时序模型)。
当前通道服务本身没有额外的费用开销。在消费通道服务数据时,表格存储会根据实际拉取的数据产生读吞吐量计量计费。更多信息,请参见计费概述。