Sdílet prostřednictvím

read_statestore funkce s hodnotou tabulky

  • Článek

Platí pro:zaškrtnutí označeného ano Databricks SQL zaškrtnutí označeného ano 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 pro nastavení možnosti. 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 Key row of the stateful operator stored in the state checkpoint.
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'
  );