ALTER ROUTINE LOAD

説明

PAUSED 状態にある Routine Load ジョブを変更します。PAUSE ROUTINE LOAD を実行して Routine Load ジョブを一時停止できます。

Routine Load ジョブを正常に変更した後、以下の操作が可能です：

• SHOW ROUTINE LOAD を使用して、Routine Load ジョブに加えられた変更を確認します。
• RESUME ROUTINE LOAD を使用して、Routine Load ジョブを再開します。

You can manage Routine Load jobs that run on StarRocks tables only as a user who has the INSERT privilege on those StarRocks tables. If you do not have the INSERT privilege, follow the instructions provided in GRANT to grant the INSERT privilege to the user that you use to connect to your StarRocks cluster.

構文

ALTER ROUTINE LOAD FOR [<db_name>.]<job_name>
[load_properties]
[job_properties]
FROM data_source
[data_source_properties]

パラメータ

• [<db_name>.]<job_name>

  • db_name: 任意。StarRocks データベースの名前。
  • job_name: 必須。変更する Routine Load ジョブの名前。

• load_properties

  ロードするソースデータのプロパティ。構文は以下の通りです：

  [COLUMNS TERMINATED BY '<column_separator>'],
  [ROWS TERMINATED BY '<row_separator>'],
  [COLUMNS ([<column_name> [, ...] ] [, column_assignment [, ...] ] )],
  [WHERE <expr>],
  [PARTITION ([ <partition_name> [, ...] ])]
  [TEMPORARY PARTITION (<temporary_partition1_name>[,<temporary_partition2_name>,...])]

  詳細なパラメータの説明については、CREATE ROUTINE LOAD を参照してください。

• job_properties

  ロードジョブのプロパティ。構文は以下の通りです：

  PROPERTIES ("<key1>" = "<value1>"[, "<key2>" = "<value2>" ...])

  以下のパラメータのみ変更可能です：

  • desired_concurrent_number

  • max_error_number

  • max_batch_interval

  • max_batch_rows

  • max_batch_size

  • jsonpaths

  • json_root

  • strip_outer_array

  • strict_mode

  • timezone

  詳細なパラメータの説明については、CREATE ROUTINE LOAD を参照してください。

• data_source および data_source_properties

  • data_source

    必須。ロードしたいデータのソース。 有効な値: KAFKA。

  • data_source_properties

    データソースのプロパティ。現在、以下のプロパティのみ変更可能です：

    • kafka_partitions および kafka_offsets: StarRocks は、すでに消費された Kafka パーティションのオフセットの変更のみをサポートし、新しい Kafka パーティションの追加はサポートしていません。
    • property.*: Kafka のデータソース用のカスタムパラメータ、例：property.kafka_default_offsets。

例

1. 次の例では、ロードジョブの desired_concurrent_number プロパティの値を 5 に増やして、ロードタスクの並行性を高めます。

   ALTER ROUTINE LOAD FOR example_tbl_ordertest
   PROPERTIES
   (
   "desired_concurrent_number" = "5"
   );

2. 次の例では、ロードジョブのプロパティとデータソース情報を同時に変更します。

   ALTER ROUTINE LOAD FOR example_tbl_ordertest
   PROPERTIES
   (
   "desired_concurrent_number" = "5"
   )
   FROM KAFKA
   (
   "kafka_partitions" = "0, 1, 2",
   "kafka_offsets" = "100, 200, 100",
   "property.group.id" = "new_group"
   );

3. 次の例では、フィルタリング条件と、データがロードされる StarRocks パーティションを同時に変更します。

   ALTER ROUTINE LOAD FOR example_tbl_ordertest
   WHERE pay_dt < 2023-06-31
   PARTITION (p202306);