您可以使用社區版Flink或阿里云實時計算版Flink訪問HBase增強版集群。本文介紹同時適用于阿里云實時計算版Flink和社區版Flink訪問HBase增強版集群的方法。

背景信息

您可以將HBase增強版中的表作為Flink中的維表或結果表,并通過Flink SQL或者Flink DataStream訪問HBase增強版集群。

前提條件

  • 通過社區版Flink訪問HBase增強版集群時,HBase增強版集群必須是2.4.3及以上版本。如果使用阿里云實時計算版Flink訪問,HBase增強版集群版本無限制。如何查看或升級當前版本,請參見小版本升級
  • 已將客戶端IP地址添加至HBase增強版集群的白名單。如何添加,請參見設置白名單和安全組
  • 已獲取HBase增強版集群的Java API訪問地址
    說明 使用HBase表作為Flink的維表或者結果表時,創建表的DDL語句需要使用Java API訪問地址作為連接地址。
  • 訪問HBase增強版集群的用戶已有Flink表的讀寫權限。賦予權限的具體操作,請參見管理ACL權限

注意事項

  • 如果您想要通過公網訪問,在執行文本操作前,需要將HBase社區版客戶端更換為阿里云HBase客戶端。具體操作,請參見升級HBase Java SDK
  • 如果應用部署在ECS實例,通過專有網絡訪問HBase增強版集群前,需要確保HBase增強版集群和ECS實例滿足以下條件,以保證網絡的連通性。
    • 所在地域相同,并建議所在可用區相同(以減少網絡延時)。
    • ECS實例與HBase增強版集群屬于同一專有網絡。
  • 如果使用社區版Flink訪問HBase增強版集群,僅支持訪問通過HBaseue Shell創建的HBase表。阿里云實時計算版Flink無此限制。

創建維表

  • 如果您使用社區版Flink訪問HBase增強版集群,具體操作,請參見創建維表
  • 如果您使用阿里云實時計算版Flink訪問HBase增強版集群,具體操作,請參見創建維表

創建結果表

  • 如果您使用社區版Flink訪問HBase增強版集群,具體操作,請參見創建結果表
  • 如果您使用阿里云實時計算版Flink訪問HBase增強版集群,具體操作,請參見創建結果表