REFRESH (MATERIALIZOVANÁ TABULKA ZOBRAZENÍ A STREAMOVÁNÍ)

Platí pro:zaškrtnutí označeného ano Databricks SQL

Důležité

Tato funkce je ve verzi Public Preview.

Aktualizujte data pro streamovanou tabulku nebo materializované zobrazení. Data se ve výchozím nastavení aktualizují synchronně. Stav aktualizace můžete sledovat spuštěním DESCRIBE EXTENDEDpříkazu .

Syntaxe

REFRESH { MATERIALIZED VIEW | [ STREAMING ] TABLE } table_name [ FULL | { SYNC | ASYNC }]

Parametry

  • Table_name

    Identifikuje materializované zobrazení nebo tabulku streamování, která se má aktualizovat. Název nesmí obsahovat dočasnou specifikaci. Pokud objekt nejde najít, Azure Databricks vyvolá TABLE_OR_VIEW_NOT_FOUND chybu.

  • PLNÉ

    Zda provést úplnou aktualizaci, která zkrátí tabulku a zpracuje všechna data dostupná ve zdroji s nejnovější definicí tabulky streamování. Materializovaná zobrazení nepodporují úplné aktualizace.

    Nedoporučuje se volat úplné aktualizace zdrojů, které nezachovají celou historii dat nebo mají krátké doby uchovávání, například Kafka, protože úplná aktualizace zkracuje stávající data. Pokud už data nejsou ve zdroji dostupná, možná nebudete moct obnovit stará data.

  • SYNCHRONIZACE

    Určuje, jestli se má provést synchronní aktualizace. Příkaz blokuje, dokud se nevytvořilo materializované zobrazení a počáteční načtení dat se dokončí.

    Toto je výchozí chování.

  • ASYNCHRONNÍ

    Určuje, jestli se má provést asynchronní aktualizace, která spustí úlohu na pozadí u rozdílových živých tabulek. Příkaz se vrátí bezprostředně před dokončením načítání dat s odkazem na kanál Delta Live Tables, který zálohuje materializované zobrazení nebo streamovanou tabulku. Stav aktualizace můžete zobrazit na tomto odkazu.

    Je nutné zadat ASYNC , zda chcete provádět asynchronní aktualizace. Operace se provádí synchronně, pokud není zadáno žádné klíčové slovo.

Příklady

-- Refreshes the materialized view to reflect the latest available data
> REFRESH MATERIALIZED VIEW catalog.schema.view_name;

-- Refreshes the streaming table to process the latest available data
-- The current catalog and schema will be used to qualify the table
> REFRESH STREAMING TABLE st_name;

-- Truncates the table and processes all data from scratch for the streaming table
> REFRESH TABLE cat.db.st_name FULL;