ALTER STREAMING TABLE

Platí pro: Databricks SQL

Umožňuje provádět některou z následujících akcí:

• Přidejte plán nebo trigger pro aktualizaci existující tabulky streamování.
• Změna existujícího plánu aktualizace nebo triggeru pro tabulku streamování
• Vypusťte plán aktualizace nebo trigger pro tabulku streamování. Pokud neexistuje žádný plán nebo aktivační událost, je potřeba objekt aktualizovat ručně, aby odrážel nejnovější data.

Pokud chcete přidat nebo změnit komentář ke streamovací tabulce, použijte COMMENT ON.

Poznámka:

Změna datové sady vytvořené kanálem způsobem, který je v rozporu s definicí SQL, může způsobit vrácení některých změn. Viz Použití ALTER příkazů s deklarativními kanály Sparku Lakeflow.

Syntaxe

ALTER STREAMING TABLE table_name
  {
    { ADD | ALTER } schedule
    DROP SCHEDULE |
    ALTER COLUMN column_clause |
    SET ROW FILTER clause |
    DROP ROW FILTER |
    SET TAGS clause |
    UNSET TAGS clause |
  }

  schedule
  { SCHEDULE [ REFRESH ] schedule_clause |
    TRIGGER ON UPDATE [ AT MOST EVERY trigger_interval ] }

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

  column_clause
    column_identifier
    { COMMENT clause |
      SET MASK clause |
      DROP MASK |
      SET TAGS clause |
      UNSET TAGS clause }

Parametry

• table_name

  Název tabulky streamovacích dat, u které se má změnit definice. Název nesmí obsahovat dočasnou specifikaci.

• rozvrh

  Přidejte nebo upravte SCHEDULE příkaz nebo TRIGGER příkaz v tabulce.

  Poznámka:

  Pomocí tohoto příkazu nemůžete upravit plán tabulky streamování vytvořené pomocí deklarativních kanálů Sparku Lakeflow. Použijte editor kanálu.

  • SCHEDULE [ REFRESH ] schedule_clause

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

      Pokud chcete naplánovat aktualizaci, která se pravidelně provádí, použijte EVERY syntaxi. Pokud je zadaná syntaxe EVERY, aktualizuje se streamovaná tabulka nebo materializované zobrazení pravidelně v zadaném intervalu na základě zadané hodnoty, například HOUR, HOURS, DAY, DAYS, WEEKnebo WEEKS. V následující tabulce jsou uvedeny celočíselné hodnoty pro number.

      Časová jednotka	Celočíselná hodnota
      HOUR or HOURS	1 <= H <= 72
      DAY or DAYS	1 <= D <= 31
      WEEK or WEEKS	1 < = W < = 8

      Poznámka:

      Jednotné a množné číslo zahrnuté časové jednotky jsou sémanticky ekvivalentní.

    • CRON cron_string [ AT TIME ZONE timezone_id ]

      Pro naplánování aktualizace pomocí hodnoty quartz cron. Jsou přijímány platné time_zone_values . AT TIME ZONE LOCAL není podporováno.

      Pokud AT TIME ZONE chybí, použije se časové pásmo relace. Pokud AT TIME ZONE chybí a pokud není nastavené časové pásmo relace, vyvolá se chyba. SCHEDULE je sémanticky ekvivalentní SCHEDULE REFRESH.

  • TRIGGER ON UPDATE [ AT MOST EVERY trigger_interval ]

    Důležité

    Funkce TRIGGER ON UPDATE je v beta verzi.

    Nastaví tabulku tak, aby se aktualizovala při aktualizaci nadřazeného zdroje dat, a to maximálně jednou za minutu. Nastavte hodnotu tak AT MOST EVERY , aby vyžadovala alespoň minimální čas mezi aktualizacemi.

    Nadřazené zdroje dat musí být externí nebo spravované tabulky Delta (včetně materializovaných zobrazení nebo streamovaných tabulek) nebo spravovaná zobrazení, jejichž závislosti jsou omezené na podporované typy tabulek.

    Povolení událostí souborů může zvýšit výkon triggerů a zvýšit některé limity pro aktualizace triggerů.

    Jedná se trigger_interval o příkaz INTERVAL , který je alespoň 1 minuta.

    TRIGGER ON UPDATE má následující omezení

    • Maximálně 10 nadřazených zdrojů dat na tabulku streamování při použití TRIGGER ON UPDATE.
    • Pomocí triggeru ON UPDATElze zadat maximálně 1000 streamovaných tabulek nebo materializovaných zobrazení.
    • Výchozí AT MOST EVERY hodnota klauzule je 1 minuta a nesmí být menší než 1 minuta.

• DROP SCHEDULE

  Odebere časový plán z tabulky streamování.

• ALTER COLUMN clause

  Viz klauzule ALTERCOLUMN.

• SET ROW FILTER klauzule

  Důležité

  Tato funkce je ve verzi Public Preview.

  Přidá funkci filtru řádků do tabulky streamování. Všechny následné dotazy do streamované tabulky obdrží podmnožinu řádků, ve kterých se funkce vyhodnotí jako logické TRUE. To může být užitečné pro jemně odstupňované řízení přístupu, kdy funkce může zkontrolovat identitu nebo členství ve skupině uživatele, který funkci vyvolává, a určit, zda se mají určité řádky filtrovat.

  Filtry řádků přidané po vytvoření se po příští aktualizaci rozšíří pouze do podřízených tabulek. U průběžných kanálů to vyžaduje restartování kanálu.

• DROP ROW FILTER

  Důležité

  Tato funkce je ve verzi Public Preview.

  Odstraní filtr řádků z tabulky pro streamování, pokud existuje. Budoucí dotazy vrátí všechny řádky z tabulky bez automatického filtrování.

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

  Důležité

  Tato funkce je ve verzi Public Preview.

  Použijte značky u tabulky streamování. Musíte mít APPLY TAG oprávnění k přidání značek do streamované tabulky.

  • tag_name

    Literál STRING. tag_name musí být jedinečný v tabulce streamování.

  • tag_value

    Literál STRING.

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

  Důležité

  Tato funkce je ve verzi Public Preview.

  Odeberte značky ze streamované tabulky. Musíte mít APPLY TAG oprávnění k odebrání značek ze streamovací tabulky.

  • tag_name

    Literál STRING. tag_name musí být jedinečný v tabulce streamování.

Klauzule ALTER COLUMN

Důležité

Tato funkce je ve verzi Public Preview.

Změní vlastnost nebo umístění sloupce.

Syntaxe

  ALTER COLUMN
    column_identifier
    { COMMENT comment |
      SET MASK mask_clause |
      DROP MASK |
      SET TAGS clause |
      UNSET TAGS clause }

Parametry

• column_identifier

  Název sloupce, který má být změněn.

• COMMENT comment

  Změní popis column_name sloupce. comment musí být STRING literál.

• SET Klauzule MASK

  Přidá funkci masky sloupce pro anonymizaci citlivých dat. Všechny následné dotazy z tohoto sloupce obdrží výsledek vyhodnocení této funkce místo původní hodnoty sloupce. To může být užitečné pro podrobné řízení přístupu, kdy funkce může zkontrolovat identitu nebo skupinové členství vyvolávajícího uživatele a určit, zda má být hodnota zredigována.

  Masky sloupců přidané po vytvoření se po příští aktualizaci rozšíří pouze do podřízených tabulek. U průběžných kanálů to vyžaduje restartování kanálu.

• DROP MASK

  Odebere masku sloupce pro tento sloupec( pokud existuje). Budoucí dotazy z tohoto sloupce obdrží původní hodnoty sloupce.

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

  Použijte značky u sloupce. Ke přidávání značek do sloupce potřebujete APPLY TAG oprávnění.

  • tag_name

    Literál STRING. Musí tag_name být jedinečný v tabulce nebo sloupci.

  • tag_value

    Literál STRING.

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

  Odstraňte zadané značky ze sloupce. Musíte mít APPLY TAG oprávnění k odebrání značek ze sloupce.

  • tag_name

    Literál STRING. Musí tag_name být jedinečný v tabulce nebo sloupci.

Příklady

-- Adds a schedule to refresh the streaming table whenever its upstream data gets updated.
> ALTER STREAMING TABLE my_st
    ADD TRIGGER ON UPDATE;

-- Alters the schedule to refresh the streaming table when its upstream data
-- gets updated, with no more than one update per hour.
> ALTER STREAMING TABLE my_st
    ALTER TRIGGER ON UPDATE AT MOST EVERY INTERVAL 1 hour;

-- Alters the schedule to run every one hour.
> ALTER STREAMING TABLE my_st
  ALTER SCHEDULE EVERY 1 HOUR;

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

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

-- Adds a column comment
> ALTER STREAMING TABLE my_st
    ALTER COLUMN column_name COMMENT 'test'

Související články

• CREATE STREAMING TABLE
• Správa ČASOVÝCH PÁSEM