バージョン: 4.x

ALTER ROUTINE LOAD

デスクリプション

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

Syntax

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_PRIV	Table	SHOW 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"
);

デスクリプション​

Syntax​

必須パラメータ​

オプションパラメータ​

アクセス制御要件​

注意事項​

例​