ALTER STREAMING TABLE

A következőkre vonatkozik: Databricks SQL

Lehetővé teszi az alábbi műveletek bármelyikének végrehajtását:

• Ütemezés vagy eseményindító hozzáadása meglévő streamelési tábla frissítéséhez.
• Egy streamelési tábla meglévő frissítési ütemezésének vagy eseményindítójának módosítása.
• A streamelési tábla frissítési ütemezésének vagy eseményindítójának elvetése. Ha nincs ütemezés vagy eseményindító, az objektumot manuálisan kell frissíteni, hogy tükrözze a legújabb adatokat.

Ha megjegyzést szeretne hozzáadni vagy módosítani egy streamelési táblához, használja a következőt COMMENT ON: .

Feljegyzés

A folyamat által létrehozott adatkészletek olyan módon történő módosítása, amely ellentmond a definiált SQL-nek, bizonyos módosítások visszaállítását okozhatja. Lásd: Parancsok használata ALTER a Lakeflow Spark deklaratív csővezetékeivel.

Szemantika

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 }

Paraméterek

• table_name

  A streamelési tábla neve a definíció módosításához. A név nem tartalmazhat időbeli specifikációt.

• menetrend

  Adjon hozzá vagy módosítson egy vagy SCHEDULE több TRIGGER utasítást a táblában.

  Feljegyzés

  Ezzel a paranccsal nem módosíthatja a Lakeflow Spark Deklaratív folyamatokkal létrehozott streamelési táblák ütemezését. Használja a folyamatszerkesztőt.

  • SCHEDULE [ REFRESH ] schedule_clause

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

      A rendszeres frissítés ütemezéséhez használja EVERY szintaxist. Ha EVERY szintaxis van megadva, a streamelési táblázat vagy a materializált nézet rendszeres időközönként frissül a megadott érték alapján, például HOUR, HOURS, DAY, DAYS, WEEKvagy WEEKS. Az alábbi táblázat a numberelfogadott egész számértékeket sorolja fel.

      Időegység	Egész számérték
      HOUR or HOURS	1 <= H <= 72
      DAY or DAYS	1 <= D <= 31
      WEEK or WEEKS	1 <= W <= 8

      Feljegyzés

      A belefoglalt időegység egyes és többes formái szemantikailag egyenértékűek.

    • CRON cron_string [ AT TIME ZONE timezone_id ]

      A frissítés ütemezése Quartz cron érték használatával. A rendszer érvényes time_zone_values fogad el. AT TIME ZONE LOCAL nem támogatott.

      Ha AT TIME ZONE hiányzik, a munkamenet időzónája lesz használatban. Ha AT TIME ZONE hiányzik, és a munkamenet időzónája nincs beállítva, hibaüzenet jelenik meg. SCHEDULE szemantikailag egyenértékű a SCHEDULE REFRESH.

  • TRIGGER ON UPDATE [ AT MOST EVERY trigger_interval ]

    Fontos

    A TRIGGER ON UPDATE funkció bétaverzióban érhető el.

    Beállítja a táblázat frissítését egy felsőbb rétegbeli adatforrás frissítésekor, legfeljebb percenként egyszer. Állítson be egy értéket AT MOST EVERY , amely legalább egy minimális időt igényel a frissítések között.

    A felsőbb rétegbeli adatforrásoknak külső vagy felügyelt Delta-tábláknak kell lenniük (beleértve a materializált nézeteket vagy streamelő táblákat), vagy felügyelt nézeteknek, amelyek függőségei a támogatott táblatípusokra korlátozódnak.

    A fájlesemények engedélyezésével az eseményindítók teljesítményesebbek lehetnek, és növelik a triggerfrissítések korlátait.

    Az trigger_intervalINTERVALLUM utasítás legalább 1 perc.

    TRIGGER ON UPDATE az alábbi korlátozásokkal rendelkezik:

    • A TRIGGER ON UPDATEhasználata esetén streamelési táblánként legfeljebb 10 streamelő adatforrást lehet használni.
    • A TRIGGER ON UPDATEhasználatával legfeljebb 1000 streamelési táblázat vagy materializált nézet adható meg.
    • A AT MOST EVERY záradék alapértelmezés szerint 1 perc, és nem lehet kevesebb, mint 1 perc.

• DROP SCHEDULE

  Eltávolít egy ütemezést a streamelési táblából.

• ALTER COLUMN clause

  Lásd ALTER COLUMN utasítás.

• SET ROW FILTER záradék

  Fontos

  Ez a funkció nyilvános előzetes verzióban van.

  Sorszűrő függvényt ad hozzá a streamelési táblához. A streamelési táblára irányuló összes további lekérdezés megkapja azoknak a soroknak a részhalmazát, ahol a függvény logikai értékre vonatkoztatva TRUE-ként értékel. Ez hasznos lehet részletes hozzáférés-vezérlési célokra, ahol a függvény megvizsgálhatja a meghívást hívó felhasználó identitását vagy csoporttagságát annak megállapításához, hogy szűrjön-e bizonyos sorokat.

  A létrehozás után hozzáadott sorszűrők csak a következő frissítés után propagálnak az alsóbb rétegbeli táblákba. Folyamatos folyamatok esetén ez folyamat újraindítást igényel.

• DROP ROW FILTER

  Fontos

  Ez a funkció nyilvános előzetes verzióban van.

  Ha van ilyen, eltávolítja a sorszűrőt a streamelési táblából. A jövőbeli lekérdezések automatikus szűrés nélkül adják vissza a tábla összes sorát.

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

  Fontos

  Ez a funkció nyilvános előzetes verzióban van.

  Címkék alkalmazása a streamelési táblára. Ahhoz, hogy címkéket adhasson hozzá a streamelési táblához, rendelkeznie kell APPLY TAG engedéllyel.

  • tag_name

    Egy szó szerinti STRING. A tag_name streamelési táblán belül egyedinek kell lennie.

  • tag_value

    Egy szó szerinti STRING.

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

  Fontos

  Ez a funkció nyilvános előzetes verzióban van.

  Címkék eltávolítása a streamelési táblából. Rendelkeznie APPLY TAG kell engedéllyel ahhoz, hogy eltávolítsa a címkéket a streamelési táblából.

  • tag_name

    Egy szó szerinti STRING. A tag_name streamelési táblán belül egyedinek kell lennie.

ALTER COLUMN záradék

Fontos

Ez a funkció nyilvános előzetes verzióban van.

Módosít egy tulajdonságot vagy egy oszlop helyét.

Szemantika

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

Paraméterek

• column_identifier

  A módosítani kívánt oszlop neve.

• COMMENT comment

  Módosítja a column_name oszlop leírását. comment egy literál kell, hogy legyen STRING.

• SET MASZK záradék

  Olyan oszlopmaszk funkciót ad hozzá, amely lehetővé teszi a bizalmas adatok anonimizálását. Az oszlop minden további lekérdezése megkapja a függvény kiértékelésének eredményét az oszlopon az oszlop eredeti értéke helyett. Ez hasznos lehet részletes hozzáférés-vezérlési célokra, ahol a függvény megvizsgálhatja az invokáló felhasználó identitását vagy csoporttagságát annak megállapításához, hogy az értéket újra kívánja-e használni.

  A létrehozás után hozzáadott oszlopmaszkok csak a következő frissítés után terjednek át a lefelé irányuló táblákra. Folyamatos folyamatok esetén ez folyamat újraindítást igényel.

• DROP MASK

  Eltávolítja az oszlophoz tartozó oszlopmaszkot, ha van ilyen. Az oszlop jövőbeli lekérdezései megkapják az oszlop eredeti értékeit.

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

  Címkék alkalmazása az oszlopra. Az oszlophoz címkék hozzáadásához APPLY TAG engedéllyel kell rendelkeznie.

  • tag_name

    Egy szó szerinti STRING. A tag_name egyedinek kell lennie a táblában vagy oszlopban.

  • tag_value

    Egy szó szerinti STRING.

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

  Távolítsa el a megadott címkéket az oszlopból. Az oszlop címkéinek eltávolításához APPLY TAG engedéllyel kell rendelkeznie.

  • tag_name

    Egy szó szerinti STRING. A tag_name egyedinek kell lennie a táblában vagy oszlopban.

Példák

-- 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'

Kapcsolódó cikkek

• CREATE STREAMING TABLE
• IDŐZÓNA kezelése