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 пользователю, которого вы используете для подключения к вашему cluster 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 поддерживает только изменение offset партиций 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. Следующий пример одновременно изменяет условие фильтрации и партиции Selena, в которые загружаются данные.

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