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

コンソールでの StarRocks カタログの作成

1. Realtime Compute for Apache Flink コンソールにログインします。管理するワークスペースを探し、[アクション] 列の [コンソール] をクリックします。

2. 左側のナビゲーションペインで、[カタログ] をクリックします。

3. [カタログリスト] ページで、[カタログの作成] をクリックします。[カタログの作成] ウィザードの [組み込みカタログ] タブで [StarRocks] を選択し、[次へ] をクリックします。

4. カタログ パラメーターを設定します。

   重要

   StarRocks カタログの設定は、作成後に変更することはできません。設定を変更するには、既存のカタログを削除して新しいカタログを作成する必要があります。

   パラメーター	説明	必須	注意
   catalog name	StarRocks カタログの名前。	はい	小文字と数字のみ使用できます。ハイフン (-)、アンダースコア (_)、大文字は使用できません。
   endpoint	フロントエンド (FE) ノードのエンドポイント。	はい	フォーマット： jdbc:mysql://IP:port。デフォルトの JDBC ポートは 9030 です。
   dbname	接続先のデフォルトの StarRocks データベース。	はい	—
   username	StarRocks へのアクセスに使用するユーザー名。	はい	—
   password	StarRocks へのアクセスに使用するパスワード。	はい	認証情報の漏洩を避けるため、プレーンテキストパスワードの代わりに変数を使用してください。詳細については、「変数の管理」をご参照ください。

   

5. [確認] をクリックします。

カタログは、[カタログリスト] ページに表示されます。

Flink SQL を使用した StarRocks カタログの作成

スクリプトページの SQL エディタで、CREATE CATALOG 文を入力し、その文を選択して、左側の[実行] をクリックします。

CREATE CATALOG <catalogname> WITH (
  'type' = 'starrocks',
  'endpoint' = 'jdbc:mysql://<IP>:<port>',
  'username' = '<username>',
  'password' = '<password>',
  'dbname' = '<dbname>'
);

設定オプションは VVR のバージョンによって異なります。

StarRocks テーブルからのデータ読み取り

INSERT INTO ${other_sink_table}
SELECT ...
FROM `${catalog_name}`.`${db_name}`.`${table_name}`

INSERT INTO ${other_sink_table}
SELECT ...
FROM `${catalog_name}`.`${db_name}`.`${table_name}`
    /*+
        OPTIONS('connector' = 'starrocks', 'jdbc-url' = 'jdbc:mysql://IP:port', 'scan-url' = 'IP:port')
    */

StarRocks テーブルへのデータ書き込み

INSERT INTO `${catalog_name}`.`${db_name}`.`${table_name}`
SELECT ...
FROM ${other_source_table}

INSERT INTO `${catalog_name}`.`${db_name}`.`${table_name}`
    /*+
        OPTIONS('connector' = 'starrocks', 'jdbc-url' = 'jdbc:mysql://IP:port', 'load-url' = 'IP:port', 'sink.buffer-flush.interval-ms' = '5000', 'sink.properties.row_delimiter' = '\x02', 'sink.properties.column_separator' = '\x01')
    */
SELECT ...
FROM ${other_source_table}

CTAS または CDAS を使用した StarRocks への書き込み

CTAS (CREATE TABLE AS SELECT) と CDAS (CREATE DATABASE AS DATABASE) を使用すると、単一のステートメントで既存のソースから StarRocks のテーブルやデータベースを作成できます。

USE CATALOG sr_catalog;

CREATE TABLE IF NOT EXISTS `${table_name}`
WITH (
  ...
) AS TABLE ${other_source_table};


CREATE DATABASE IF NOT EXISTS `${db_name}`
WITH (
  ...
) AS DATABASE ${other_source_database};

完全なウォークスルーについては、「Flink を使用した MySQL から StarRocks へのデータ取り込み」をご参照ください。

コンソールでの StarRocks カタログの削除

1. Realtime Compute for Apache Flink コンソールにログインします。目的のワークスペースを見つけ、[アクション] 列の [コンソール] をクリックします。

2. 左側のナビゲーションペインで、[カタログ] をクリックします。

3. [カタログリスト] ページで、カタログを見つけ、[アクション] 列の [削除] をクリックします。

4. 確認ダイアログで、[削除] をクリックします。

カタログは、左側のナビゲーションの[カタログ] ペインから削除されます。

Flink SQL を使用した StarRocks カタログの削除

スクリプトページの SQL エディタに次のステートメントを入力し、そのステートメントを右クリックして[実行]を選択します。

DROP CATALOG `<catalog name>`;

<catalog name> を、削除するカタログの名前に置き換えます。

ステートメントの実行後、左側のナビゲーションの [カタログ] ペインで、カタログが削除されていることを確認します。