Poznámka:
Přístup k této stránce vyžaduje autorizaci. Můžete se zkusit přihlásit nebo změnit adresáře.
Přístup k této stránce vyžaduje autorizaci. Můžete zkusit změnit adresáře.
Platí pro:
Databricks SQL
Databricks Runtime 14.3 a vyšší
Vrátí tabulku s řádky, které představují metadata stavu dotazu streamování.
Funkce s hodnotou tabulky pro čtení metadat stavových operátorů u streamovacích dotazů. Podporuje pouze spouštění jako dávkový dotaz.
Syntaxe
read_state_metadata(path)
Argumenty
Tato funkce vyžaduje vyvolání pojmenovaného parametru pro klíče možností.
-
pathSTRING: Literál s cestou umístění kontrolního bodu dotazu streamování.
Návraty
Tabulka stavových metadat má následující schéma. Všechny sloupce nemají hodnotu NULL.
operatorId INT NOT NULLCeločíselné ID stavového operátoru streamování.
operatorName STRING NOT NULLNázev operátoru stavového streamování
stateStoreName STRING NOT NULLNázev úložiště stavu operátora.
numPartitions INT NOT NULLPočet oddílů stavového úložiště
minBatchId BIGINT NOT NULLMinimální ID dávky, které je k dispozici pro dotazování stavu. Hodnota může být neplatná, pokud je spuštěn streamovací dotaz, který provádí kontrolní bod, protože to by vyvolalo spuštění úklidu.
maxBatchId BIGINT NOT NULLMaximální ID dávky, které je k dispozici pro dotazování stavu. Hodnota může být neplatná, pokud je streamovací dotaz, který provádí kontrolní bod, spuštěn, protože dotaz potvrdí další dávky.
Příklady
-- Read state metadata from the checkpoint
> SELECT * FROM read_state_metadata('/checkpoint/path');
Související články
- CREATE STREAMING TABLE
-
read_kafkatabulkově hodnotová funkce