Flink SQL を使用してコンピューティングタスクを送信する場合にワイドテーブルコネクタを設定する方法 -

Lindorm ストリーミングエンジンを使用してコンピューティングタスクを処理する場合、ワイドテーブルをディメンションテーブルまたは結果テーブルとして使用できます。このトピックでは、Flink SQL を使用してコンピューティングタスクを送信する場合にワイドテーブルコネクタを設定する方法について説明します。

背景情報

Lindorm ストリーミングエンジンで Flink SQL を使用してコンピューティングタスクを送信する場合は、CREATE TABLE ステートメントを実行し、コネクタ関連のパラメータを設定する必要があります。

Lindorm ストリーミングエンジンでワイドテーブルを使用する

CREATE TABLE lindorm_table(
  c1 VARCHAR,
  c2 DOUBLE,
  c3 BIGINT,
  PRIMARY KEY (c1, c2) NOT ENFORCED -- ステートメントで指定された主キーは、LindormTable で作成された結果テーブルの主キーと同じである必要があります。
)WITH(
      'connector'='lindorm',
      'seedServer'='ld-bp17pwu1541ia****-proxy-lindorm.lindorm.rds.aliyuncs.com:30020',
      'userName'='yourUser',
      'password'='yourPassword',
      'tableName'='yourTablename',
      'namespace'='yourNamespace'
    ); -- WITH 句でコネクタ関連のパラメータを設定します。

説明

CREATE TABLE ステートメントの詳細については、「CREATE TABLE」をご参照ください。

コネクタ関連のパラメータ

共通パラメータ

パラメータ	デフォルト値	必須	説明
seedServer	なし	はい	HBase Java API を使用して LindormTable に接続するために使用されるエンドポイント。詳細については、「LindormTable のエンドポイントを表示する」をご参照ください。
namespace	なし	はい	ワイドテーブルが属する名前空間。
userName	なし	はい	LindormTable への接続に使用するユーザー名。
password	なし	はい	LindormTable への接続に使用するパスワード。
tableName	なし	はい	ワイドテーブルの名前。
bufferSize	5000	いいえ	データを書き込むバッチの数。
flushIntervalMs	2000	いいえ	`flush` 操作がワイドテーブルにデータを書き込む際に実行される間隔です。単位：ミリ秒。ワイドテーブルに書き込まれるデータ量が小さい場合、指定された間隔に基づいて `flush` 操作が実行されます。説明指定された間隔で flush 操作が実行される基準となるデータ量は、ビジネスシナリオによって異なります。
columnFamily	f	いいえ	列ファミリの名前。説明 Lindorm ストリーミングエンジンでワイドテーブルを使用する場合、columnFamily パラメータが必要かどうかは、ワイドテーブルの作成方法によって異なります。ワイドテーブルが ApsaraDB for HBase API for Java を使用して作成された場合、このパラメータは必須です。ワイドテーブルが Lindorm SQL を使用して作成された場合、このパラメータはオプションです。

時空間パラメータ

パラメータ	デフォルト値	必須	説明
cacheTTLMs	-1	いいえ	データキャッシュの有効期限 (TTL)。このパラメータのデフォルト値は -1 で、データキャッシュが生成されないことを示します。単位：ミリ秒。データキャッシュの有効期限が切れると、次のクエリが実行されたときに時空間インデックスが再構築されます。
geomHint	なし	いいえ	指定されたルックアップ結合クエリ。このパラメータの値は、`<columnName>:<queryFunction>` 形式です。例：`fence:st_contains`。ルックアップ結合クエリが実行されると、結合条件の時空間式は、指定された時空間クエリに置き換えられます。たとえば、`fence=ST_MakePoint(x,y))` 式は、指定された `ST_Contains(fence, ST_MakePoint(x,y))` クエリに置き換えられます。 queryFunction は、次の関数をサポートしています。 ST_Contains ST_Within ST_DWithin ST_DWithinSphere ST_Intersects ST_Overlaps ST_Equals
geomIndex	なし	いいえ	時空間インデックスの作成の基になる列。テーブルのルックアップ結合クエリは、インメモリインデックスを使用して高速化されます。インデックスは、テーブル内の 1 つの列に対してのみ作成できます。次の関数は、インメモリインデックスを使用して高速化できます。 ST_Contains ST_Within ST_DWithin ST_DWithinSphere ST_Intersects ST_Overlaps ST_Equals 重要 geomIndex パラメータは、geomHint パラメータおよび cacheTTLMs パラメータと一緒に指定する必要があります。cacheTTLMs パラメータの値は 0 より大きい必要があります。