Поделиться через

ALTER STREAMING TABLE

Область применения:флажок Databricks SQL

Позволяет выполнить одно из следующих действий:

  • Добавьте расписание обновления существующей потоковой таблицы.
  • Измените существующее расписание обновления для потоковой таблицы.
  • Отмените расписание обновления для потоковой таблицы. Если расписание удалено, объект необходимо обновить вручную, чтобы отразить последние данные.

Чтобы добавить или изменить комментарий к таблице или его столбцам, используйте COMMENT ON.

Синтаксис

ALTER STREAMING TABLE table_name
  {
    { ADD | ALTER } SCHEDULE [ REFRESH ] schedule_clause |
    DROP SCHEDULE |
    ALTER COLUMN clause |
    SET ROW FILTER clause |
    DROP ROW FILTER |
    SET TAGS clause |
    UNSET TAGS clause |
  }

  schedule_clause
  { EVERY number { HOUR | HOURS | DAY | DAYS | WEEK | WEEKS } |
    CRON cron_string [ AT TIME ZONE timezone_id ] }

Параметры

  • table_name

    Имя потоковой таблицы для изменения её определения. Имя не должно содержать временную спецификацию.

  • SCHEDULE [ REFRESH ] schedule_clause

    Позволяет добавить расписание или изменить расписание потоковой таблицы.

    • EVERY number { HOUR | HOURS | DAY | DAYS | WEEK | WEEKS }

      Чтобы запланировать периодические обновления, используйте синтаксис EVERY. Если указан синтаксис EVERY, то потоковая таблица или материализованное представление периодически обновляется с заданным интервалом на основе указанного значения, например HOUR, HOURS, DAY, DAYS, WEEKили WEEKS. В следующей таблице перечислены принятые целые значения для number.

      Единица времени Целое значение
      HOUR or HOURS 1 <= H <= 72
      DAY or DAYS 1 <= D <= 31
      WEEK or WEEKS 1 <= W <= 8

      Примечание.

      Семантические и множественные формы включенной единицы времени семантики.

    • CRON cron_string [ AT TIME ZONE timezone_id ]

      Чтобы запланировать обновление, используя значение quartz cron . Допустимые time_zone_values принимаются. Функция AT TIME ZONE LOCAL не поддерживается.

      Если AT TIME ZONE нет, используется часовой пояс сеанса. Если AT TIME ZONE отсутствует, а часовой пояс сеанса не задан, возникает ошибка. SCHEDULE семантически эквивалентен SCHEDULE REFRESH.

  • ИЗМЕНИТЬ COLUMN

    Это важно

    Эта функция доступна в общедоступной предварительной версии.

    Изменяет свойство столбца.

  • пункт SETROW FILTER

    Это важно

    Эта функция доступна в общедоступной предварительной версии.

    Добавляет функцию фильтра строк в таблицу потоковой передачи. Все последующие запросы к таблице потоковой передачи получают подмножество строк, где функция оценивает логическое TRUEзначение. Это может быть полезно для точного контроля доступа, где функция может проверить удостоверение или членство в группах вызывающего пользователя, чтобы определить, следует ли фильтровать определенные строки.

  • DROP ROW FILTER

    Это важно

    Эта функция доступна в общедоступной предварительной версии.

    Удаляет фильтр строк в потоковой таблице, если таковой есть. Будущие запросы возвращают все строки из таблицы без автоматической фильтрации.

  • SET TAGS ( { tag_name = tag_value } [, ...] )

    Это важно

    Эта функция доступна в общедоступной предварительной версии.

    Примените теги к таблице потока данных. Вам необходимо иметь APPLY TAG разрешение на добавление тегов в таблицу стриминга.

    • tag_name

      Литерал STRING. tag_name должен быть уникальным в таблице или столбце потоковой передачи.

    • tag_value

      Литерал STRING.

  • UNSET TAGS ( tag_name [, ...] )

    Это важно

    Эта функция доступна в общедоступной предварительной версии.

    Удалите теги из таблицы потоковой передачи. Необходимо иметь APPLY TAG разрешение на удаление тегов из потоковой таблицы.

    • tag_name

      Литерал STRING. Элемент tag_name должен быть уникальным в потоковой таблице или столбце.

Примеры

-- Adds a schedule to refresh the streaming table once a day
-- at midnight in Los Angeles
> ALTER STREAMING TABLE my_st
  ADD SCHEDULE CRON '0 0 0 * * ? *' AT TIME ZONE 'America/Los_Angeles';

-- Alters the schedule to run every 15 minutes for a streaming table
> ALTER STREAMING TABLE my_st
  ALTER SCHEDULE EVERY 15 MINUTES;

-- Drops the schedule for a streaming table
> ALTER STREAMING TABLE my_st
  DROP SCHEDULE;