Realtime Compute for Apache Flink:カタログの管理

前提条件

作業を開始する前に、以下の要件を満たしていることを確認してください。

• Realtime Compute for Apache Flink が Ververica Runtime (VVR) 6.0.2 以降で実行されていること

• AnalyticDB for MySQL データベースのホスト名（または IP アドレス）、ポート、ユーザー名、およびパスワード

制限事項

• カタログの DDL ステートメントは、作成後に変更できません。

• カタログテーブルは読み取り専用です。カタログ経由でデータベースやテーブルの作成、変更、削除はできません。

• カタログテーブルはディメンションテーブルおよび結果テーブルとしてのみ使用可能で、ソーステーブルとしては使用できません。

カタログの作成

SQL エディターのScripts タブで、次の文を入力して実行します:

CREATE CATALOG <catalogName> WITH (
  'type' = 'adb3.0',
  'hostName' = '<hostname>',
  'port' = '<port>',
  'userName' = '<username>',
  'password' = '<password>',
  'defaultDatabase' = '<dbname>'
);

ステートメントを選択し、エディター左側の [実行] をクリックします。

カタログメタデータの表示

1. Realtime Compute for Apache Flink コンソール にログインします。

2. ワークスペースを見つけ、[コンソール] を [操作] 列でクリックします。

3. 左側のナビゲーションウィンドウで、[カタログ] をクリックします。

4. [カタログ一覧] ページで、対象のカタログを見つけ、[カタログ名] 列と [タイプ] 列を確認します。カタログ内のデータベースおよびテーブルを参照するには、[操作] 列の [表示] をクリックします。

カタログテーブルの使用

カタログテーブルは、AnalyticDB for MySQL の名前空間に対応する 3 部構成の識別子を使用します。

カタログテーブルは、`<catalog>`.`<database>`.`<table>` の形式で参照します。

INSERT INTO <other_sink_table>
SELECT ...
FROM <other_source_table> AS e
JOIN `<adb_mysql_catalog>`.`<db_name>`.`<table_name>` FOR SYSTEM_TIME AS OF e.proctime AS w
ON e.id = w.id;

INSERT INTO `<adb_mysql_catalog>`.`<db_name>`.`<table_name>`
SELECT ...
FROM <other_source_table>;

INSERT INTO `<adb_mysql_catalog>`.`<db_name>`.`<table_name>` /*+ OPTIONS('replaceMode'='true') */
SELECT ...
FROM <other_source_table>;

カタログの削除

UI（推奨）または SQL ステートメントでカタログを削除できます。