您可以使用社区版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增强版集群，具体操作，请参见创建结果表。