Dataphin:ステップ 4: FLINK_SQL リアルタイムタスクを開発する

ステップ 1: FLINK_SQL タスクを作成する

1. Dataphin ホームページに移動し、トップメニューバーから [開発] オプションを選択します。

2. 以下の図の操作ガイドを参照して、[新規 FLINK_SQL タスク] ダイアログボックスにアクセスします。

   

3. [新規 FLINK_SQL タスク] ダイアログボックスで、次のパラメーターを設定します。

   パラメーター	説明
   タスク名	flink_dataphin という名前を入力します。
   本番環境クラスタ	FLINK_SQL タスクに適切なクラスタを選択します。
   エンジンバージョン	vvr-8.0.1-flink-1.17 バージョンを選択します。
   テンプレートを使用	デフォルトでは、無効 に設定されています。
   ストレージディレクトリ	デフォルトは コード管理 に設定されています。
   説明	FLINK_SQL タスクの簡潔な説明 (単一製品の総売上高を計算する など) を入力します。

4. [OK] をクリックして確定します。

ステップ 2: FLINK_SQL タスクコードを開発およびプリコンパイルする

1. FLINK_SQL タスクコードエディタで、次のコードを記述します。

   INSERT INTO ads_gross
   SELECT
            sku_type as prod_code
           ,sum(sku_quantity) as sale_num
   FROM    oms_orders
   GROUP BY  sku_type;

2. 左上隅にある ボタンをクリックして、コードの構文と権限を確認します。

   説明

   1. プリコンパイルが成功すると、ページ上部に 通知が表示されます。

   2. プリコンパイルが失敗すると、 通知が表示されます。下部にある [コンソール] をクリックして、プリコンパイルエラーログを表示します。

ステップ 3: FLINK_SQL タスクを送信する

1. 左上隅にある ボタンをクリックし、[送信の備考] ダイアログボックスに備考を入力します。

2. [OKして送信] をクリックして、送信プロセスを完了します。