ALTER ROUTINE LOAD

ALTER ROUTINE LOAD изменяет задачу Routine Load, которая находится в состоянии PAUSED. Вы можете выполнить PAUSE ROUTINE LOAD, чтобы приостановить задачу Routine Load.

После успешного изменения задачи Routine Load вы можете:

Проверить изменения, внесенные в задачу Routine Load, используя SHOW ROUTINE LOAD.
Возобновить задачу Routine Load, используя RESUME ROUTINE LOAD.

Вы можете управлять заданиями Routine Load, которые выполняются на таблицах Selena, только как пользователь, имеющий привилегию INSERT на эти таблицы Selena. Если у вас нет привилегии INSERT, следуйте инструкциям, предоставленным в GRANT, чтобы предоставить привилегию INSERT пользователю, которого вы используете для подключения к вашему кластеру Selena.

Синтаксис

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

Параметры

[<db_name>.]<job_name>
- db_name: Необязательный. Имя базы данных Selena.
- 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: Обратите внимание, что Selena поддерживает только изменение смещения разделов Kafka, которые уже были обработаны, но не поддерживает добавление новых разделов Kafka.
  - property.*: Пользовательские параметры для источника данных Kafka, такие как property.kafka_default_offsets.

Примеры

Следующий пример увеличивает значение свойства desired_concurrent_number задачи загрузки до 5 для увеличения параллелизма задач загрузки.
```
ALTER ROUTINE LOAD FOR example_tbl_ordertest
PROPERTIES
(
"desired_concurrent_number" = "5"
);
```

Следующий пример одновременно изменяет свойства задачи загрузки и информацию об источнике данных.

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"
);

Следующий пример одновременно изменяет условие фильтрации и разделы Selena, в которые загружаются данные.
```
ALTER ROUTINE LOAD FOR example_tbl_ordertest
WHERE pay_dt < 2023-06-31
PARTITION (p202306);
```

Синтаксис​

Параметры​

Примеры​

Синтаксис

Параметры

Примеры