通过Flink访问宽表引擎

背景信息

您可以将云原生多模数据库 Lindorm宽表作为Flink中的维表或者结果表，通过Flink SQL或者Flink DataStream访问Lindorm宽表。

前提条件

• 通过社区版Flink访问Lindorm宽表时，宽表引擎为2.4.3及以上版本。如果使用阿里云Flink访问，宽表引擎版本无限制。如何查看或升级当前版本，请参见宽表引擎版本说明和升级小版本。

• 已将客户端IP地址添加至Lindorm白名单。如何添加，请参见设置白名单。

注意事项

• 如果您想要通过公网访问或您的实例类型为Lindorm单节点，在执行本文操作前，需要先升级SDK并更改配置。具体操作，请参见通过HBase Java API连接并使用宽表引擎章节中的步骤1。

• 如果应用部署在ECS实例，通过专有网络访问Lindorm实例前，需要确保Lindorm实例和ECS实例满足以下条件，以保证网络的连通性。

  • 所在地域相同，并建议所在可用区相同（以减少网络延时）。

  • ECS实例与Lindorm实例属于同一专有网络。

• 使用社区版Flink访问Lindorm宽表时，仅支持HBase-like表，这表示通过lindorm-cli创建的SQL表无法作为社区版Flink的维表或结果表，必须使用HBase Shell创建HBase-like表以供访问。阿里云实时计算Flink无此限制。

• 如果您使用阿里云实时计算Flink并采用Flink SQL方式访问Lindorm宽表，那么可以直接使用Lindorm Connector。

获取连接地址

通过Flink访问Lindorm宽表使用的是Lindorm宽表引擎的HBase Java API访问地址（专有网络）。您可以通过控制台查看宽表引擎连接地址。

创建维表

• 如果您使用社区版Flink访问Lindorm宽表，具体操作请参见创建维表。

• 如果您使用阿里云实时计算Flink访问Lindorm宽表，具体操作请参见创建Lindorm维表。

创建结果表

• 如果您使用社区版Flink访问Lindorm宽表，具体操作请参见创建结果表。

• 如果您使用阿里云实时计算Flink访问Lindorm宽表，具体操作请参见创建Lindorm结果表。