ALTER ETL - Lindorm - Alibaba Cloud ドキュメントセンター

ALTER ETL 文は、ステータスが RUNNING の ETL タスクを変更します。

エンジンとバージョン

ALTER ETL はストリームエンジンにのみ適用されます。バージョン 3.1.8 以降が必要です。

説明

構文

alter_etl_statement ::= ALTER ETL etl_name
                        [WITH etl_properties]
                        AS INSERT INTO [[catalog_name.]db_name.]table_name column_list 
                        select_statement

etl_properties       ::= '(' property_definition (',' property_definition)* ')'
property_definition  ::= property_name '=' property_value  
column_list          ::= '(' column_name (',' column_name)* ')'

使用上の注意

ETL 名 (etl_name)

必須。変更する ETL タスクを指定します。

ETL プロパティ (etl_properties)

次の ETL プロパティを追加するには、WITH キーワードを使用します。

重要

プロパティ名はバックティック (`) で、プロパティ値は一重引用符 (') で囲みます。例: `parallelism` = '2'。

プロパティ	データ型	説明	デフォルト値
parallelism	INTEGER	タスクの並列処理の次数。	1
sink.ignore-update-before	BOOLEAN	シンク操作中に -U を無視するかどうかを指定します。	false
sink.ignore-delete	BOOLEAN	シンク操作中に -D を無視するかどうかを指定します。	false
sink.null-mode	STRING	シンク操作中に NULL 値を書き込むかどうかを指定します。有効な値: NO_OP: ソースデータの NULL 値を保持して書き込みます。 SKIP: NULL 値をスキップして書き込みません。	NO_OP
udf.xxxx	STRING	ユーザー定義関数 (UDF) を設定します。このプロパティを使用する前に、UDF JAR ファイルをアップロードする必要があります。パラメーターは `udf.<udfFunction> = <jarName>#<className>` のフォーマットを使用します。ここで、`udfFunction` は関数名、`jarName` は JAR パッケージ名、`className` はクラス名です。	なし
stream.xxx	ANY	ストリームエンジンジョブのパラメーター。例: `execution.checkpointing.interval`。	なし

結果テーブルの指定

パラメーター	必須	説明
catalog_name	いいえ	結果テーブルのカタログ。
db_name	いいえ	結果テーブルが配置されているデータベース。
table_name	はい	結果テーブルの名前。
column_name	はい	結果テーブルの列名。

SQL 検索文 (select_statement)

新しい SQL 検索文を指定します。

例

LindormTable のソーステーブル source と結果テーブル sink が次の構造を持っていると仮定します。

-- ソーステーブル: source
CREATE TABLE source(p1 INT, c1 DOUBLE, PRIMARY KEY(p1));

-- 結果テーブル: sink
CREATE TABLE sink(p1 INT, c1 DOUBLE, PRIMARY KEY(p1));

次の文は、filter2 という名前の ETL タスクを作成し、プロパティを追加します。

CREATE ETL IF NOT EXISTS filter2
WITH (
`parallelism` = '2',
`stream.execution.checkpointing.interval` = '30000'
)
AS
  INSERT INTO `lindorm_table`.`default`.`sink` (p1, c1)
  SELECT p1, c1 FROM `lindorm_table`.`default`.`source` WHERE c1 > 10;

ETL タスクのプロパティの変更

次の文は、parallelism プロパティを 4 に変更します。

ALTER ETL filter2
WITH (`parallelism` = '4')
AS
  INSERT INTO `lindorm_table`.`default`.`sink` (p1, c1)
  SELECT p1, c1 FROM `lindorm_table`.`default`.`source`;

結果の確認

DESC ETL filter2; 文を実行して ATTRIBUTES の filter2 を表示し、変更が成功したことを確認します。