オープンソースの Apache Flink または Alibaba Cloud Realtime Compute for Apache Flink を使用して、LindormTable に接続できます。このトピックで説明されている LindormTable にアクセスする方法は、オープンソースの Apache Flink と Alibaba Cloud Realtime Compute for Apache Flink の両方に適用できます。
背景情報
Lindorm テーブルを Flink ディメンションテーブルまたは結果テーブルとして指定し、Flink SQL または Flink DataStream を使用して Flink ディメンションテーブルまたは結果テーブルにアクセスできます。
前提条件
オープンソースの Apache Flink を使用して LindormTable に接続する場合、LindormTable のバージョンは 2.4.3 以降である必要があります。Alibaba Cloud Realtime Compute for Apache Flink を使用して Lindorm テーブルに接続する場合、LindormTable のバージョンは制限されません。 LindormTable のバージョンを表示またはアップグレードする方法の詳細については、「LindormTable のリリースノート」および「Lindorm インスタンスのマイナーエンジンバージョンをアップグレードする」をご参照ください。
クライアントの IP アドレスが Lindorm インスタンスのホワイトリストに追加されています。詳細については、「ホワイトリストを構成する」をご参照ください。
使用上の注意
インターネット経由で Lindorm インスタンスに接続する場合、またはアクセスする Lindorm インスタンスが単一ノードの Lindorm インスタンスである場合は、このトピックで説明されている操作を実行する前に、SDK をアップグレードして構成を変更する必要があります。詳細については、「Java 用 ApsaraDB for HBase API を使用して LindormTable に接続し、使用する」のステップ 1 をご参照ください。
アプリケーションが Elastic Compute Service (ECS) インスタンスにデプロイされている場合は、ネットワーク接続を確保するために、Lindorm インスタンスと ECS インスタンスが事前に次の要件を満たしていることを確認してください。
Lindorm インスタンスと ECS インスタンスは同じリージョンにデプロイされています。ネットワーク遅延を減らすために、2 つのインスタンスを同じゾーンにデプロイすることもお勧めします。
Lindorm インスタンスと ECS インスタンスは同じ VPC にデプロイされています。
オープンソースの Apache Flink を使用して Lindorm テーブルにアクセスする場合、HBase ライクなテーブルにのみアクセスできます。 lindorm-cli を使用して作成された SQL テーブルは、オープンソースの Apache Flink ではディメンションテーブルまたは結果テーブルとして指定できません。オープンソースの Flink では、Hbaseue Shell を使用して作成された HBase ライクなテーブルのみをディメンションテーブルまたは結果テーブルとして指定できます。Alibaba Cloud Realtime Compute for Apache Flink を使用している場合は、すべての Lindorm テーブルにアクセスできます。
Realtime Compute for Apache Flink と Flink SQL を一緒に使用して Lindorm テーブルにアクセスする場合、変更を加えることなく Lindorm コネクタを使用できます。
エンドポイントを表示する
Flink を使用して Lindorm テーブルにアクセスする場合、HBase API 用の LindormTable エンドポイントが使用されます。 Lindorm コンソールでLindormTable のエンドポイントを表示できます。
新しく作成したアカウントを使用して Lindorm テーブルにアクセスする場合は、そのアカウントに Flink テーブルに対する読み取りおよび書き込み権限があることを確認してください。読み取りおよび書き込み権限を付与する方法の詳細については、「ユーザーの管理」をご参照ください。
ディメンションテーブルを作成する
オープンソースの Flink を使用して Lindorm テーブルにアクセスする場合は、「ディメンションテーブルを作成する」で説明されている手順に従ってください。
Realtime Compute for Apache Flink を使用して Lindorm テーブルにアクセスする場合は、「Lindormコネクタ」で説明されている手順に従ってください。
結果テーブルを作成する
オープンソースの Flink を使用して Lindorm テーブルにアクセスする場合は、「結果テーブルを作成する」で説明されている手順に従ってください。
Realtime Compute for Apache Flink を使用して Lindorm テーブルにアクセスする場合は、「Lindormコネクタ」で説明されている手順に従ってください。