read_statestore funkce s hodnotou tabulky

Platí pro: Databricks SQL Databricks Runtime 14.3 a vyšší

Tabulková funkce pro čtení záznamů z úložiště stavu streamovacích dotazů. Vrácený vztah podporuje pouze spuštění jako dávkové dotaz.

Syntaxe

read_statestore ( path [, option_key => option_value ] [ ... ] )

Argumenty

read_statestore vyžaduje pro své volitelné parametry volání pojmenovaného parametru .

• path: A STRING literal. Cesta umístění kontrolního bodu dotazu streamování.
• option_key: Název možnosti konfigurace. Pro možnosti, které obsahují tečky (.), musíte použít backticks (').
• option_value: Konstantní výraz, kterým se nastavuje možnost. Přijímá literály a skalární funkce.

Všechna option_valuepísmena nerozlišují.

option_key	Typ	Výchozí	Popis
batchId	BIGINT	nejnovější ID dávky	Představuje cílovou dávku, ze které se má číst. Tato možnost se používá, když uživatelé chtějí provést časovou cestu. Dávka by se měla potvrdit, ale ještě se nevyčistí.
OperatorId	BIGINT	0	Představuje cílový operátor pro čtení. Tato možnost se používá, když dotaz používá více stavových operátorů.
storeName	STRING	'DEFAULT'	Představuje cílovou stranu, ze které se má číst. Tato možnost se používá, když uživatelé chtějí číst stav z propojení stream-stream.
joinSide	STRING	'None'	Představuje cílovou stranu, ze které se má číst. Tato možnost se používá, když uživatelé chtějí číst stav z propojení stream-stream. Jeden z: 'Left', 'Right', 'None'.

Návraty

Funkce vrátí sadu výsledků s následujícími sloupci.

Poznámka:

Vnořené sloupce pro klíč a hodnotu silně závisí na vstupním schématu stavového operátoru a typu operátoru.

Name	Datový typ	Vynulovatelné	Standard	Popis
id	STRUCT	No	Klíčový řádek stavového operátoru uložený v kontrolním bodě stavu.
value	STRUCT	Ano	Řádek hodnoty stavového operátoru uloženého v kontrolním bodu stavu
partition_id	INTEGER	No	Oddíl, který obsahuje záznam.
shardId	STRING	No	Jedinečný identifikátor horizontálního oddílu, ze kterého byla data načtena.
sequenceNumber	BIGINT	No	Jedinečný identifikátor záznamu v rámci jeho fragmentu.
approximateArrivalTimestamp	TIMESTAMP	No	Přibližný čas vložení záznamu do datového proudu

Příklady

-- Read from state
> SELECT * FROM read_statestore('/checkpoint/path');

-- Read from state with storeName option
> SELECT * FROM read_statestore(
      '/checkpoint/path',
      operatorId => 0,
      batchId => 2,
      storeName => 'default'
  );

-- Read from state with joinSide option

> SELECT * FROM read_statestore(
      '/checkpoint/path',
      joinSide => 'left'
  );

Související funkce

• read_files tabulkově hodnotová funkce
• read_kafka tabulkově hodnotová funkce
• read_kinesis streamovací funkce vracející hodnotu tabulky