Table Store的Java SDK提供了通道服務的多個介面封裝。介面封裝包括管控介面和自動化的資料消費架構兩部分。
快速使用
使用通道服務即時消費資料前,您需要為資料表建立通道,然後通過通道消費表中資料。具體操作,請參見快速體驗通道服務。
管控介面
為資料表建立通道時,您需要指定資料表名稱、通道名稱和通道類型。具體操作,請參見建立通道。
建立通道後,您可以根據實際管理通道。
功能特性 | 說明 |
列舉某個資料表內通道的具體資訊。 | |
描述某個通道裡的具體Channel資訊。目前一個Channel對應TableStore Stream介面的一個資料分區。 | |
刪除指定資料表的一個通道。 |
資料消費架構
自動化的資料消費架構的實現流程是Tunnel Client通過每一輪的定時心跳探測(Heartbeat)進行活躍Channel的探測,Channel和ChannelConnect狀態的更新,以及資料處理任務的初始化、運行和結束等。
Tunnel Client可以解決全量和增量資料處理時的常見問題,例如負載平衡、故障恢複、Checkpoint、分區資訊同步確保分區資訊消費順序等。使用Tunnel Client後,您只需要關心每條記錄的處理邏輯。更多資訊,請參見資料消費架構原理介紹。