メインコンテンツまでスキップ
バージョン: 26.x

ALTER ROUTINE LOAD

説明​

この構文は、既存のroutine load jobを変更するために使用されます。PAUSED状態のjobのみ変更可能です。

構文​

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

必須パラメータ​

1. [<db>.]<job_name>

変更するジョブの名前を指定します。識別子は文字で始まる必要があり、識別子文字列全体がバッククォートで囲まれていない限り、スペースや特殊文字を含むことはできません。

識別子は予約キーワードを使用できません。詳細については、識別子要件と予約キーワードを参照してください。

オプションパラメータ​

1. <job_properties>

変更するジョブパラメータを指定します。現在サポートされているパラメータは以下の通りです：

  • desired_concurrent_number
  • max_error_number
  • max_batch_interval
  • max_batch_rows
  • max_batch_size
  • jsonpaths
  • json_root
  • strip_outer_array
  • strict_mode
  • timezone
  • num_as_string
  • fuzzy_parse
  • partial_columns
  • max_filter_ratio

2. <data_source_properties>

データソースに関連するプロパティです。現在サポートしているもの：

  • <kafka_partitions>
  • <kafka_offsets>
  • <kafka_broker_list>
  • <kafka_topic>
  • カスタムプロパティ（<property.group.id>など）

3. <data_source>

データソースのタイプです。現在サポートしているもの：

  • KAFKA

アクセス制御要件​

このSQLコマンドを実行するユーザーは、少なくとも以下の権限を持つ必要があります：

権限オブジェクト備考
LOAD_PRIVTableSHOW ROUTINE LOADにはTableのLOAD権限が必要

注意事項​

  • kafka_partitionsとkafka_offsetsは、消費するkafkaパーティションのオフセットを変更するために使用され、現在消費中のパーティションのみ変更可能です。新しいパーティションを追加することはできません。

例​

  • desired_concurrent_numberを1に変更

    ALTER ROUTINE LOAD FOR db1.label1
    PROPERTIES
    (
        "desired_concurrent_number" = "1"
    );

  • desired_concurrent_numberを10に変更し、パーティションオフセットを変更し、group idを変更する

    ALTER ROUTINE LOAD FOR db1.label1
    PROPERTIES
    (
        "desired_concurrent_number" = "10"
    )
    FROM kafka
    (
        "kafka_partitions" = "0, 1, 2",
        "kafka_offsets" = "100, 200, 100",
        "property.group.id" = "new_group"
    );