Condividi tramite

read_statestore funzione con valori di tabella

  • Articolo

Si applica a:segno di spunta sì Databricks SQL segno di spunta sì Databricks Runtime 14.3 e versioni successive

Funzione con valori di tabella per la lettura dei record dall'archivio di stato delle query di streaming. La relazione restituita supporta solo l'esecuzione come query batch.

Sintassi

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

Argomenti

read_statestore richiede la chiamata di parametri denominati per i parametri facoltativi.

  • path: valore STRING literal. Percorso del percorso del checkpoint della query di streaming.
  • option_key: nome dell'opzione da configurare. È necessario usare i backtick (') per le opzioni che contengono punti (.).
  • option_value: espressione costante su cui impostare l'opzione . Accetta valori letterali e funzioni scalari.

Tutte le option_valuemaiuscole e minuscole non fanno distinzione tra maiuscole e minuscole.

option_key Type Default Descrizione
batchId BIGINT ID batch più recente Rappresenta il batch di destinazione da cui leggere. Questa opzione viene usata quando gli utenti vogliono eseguire il viaggio in tempo. È necessario eseguire il commit del batch ma non è ancora stato pulito.
OperatorId BIGINT 0 Rappresenta l’operatore di destinazione da cui leggere. Questa opzione viene usata quando la query usa più operatori con stato.
storeName STRING 'DEFAULT' Rappresenta il lato di destinazione da cui leggere. Questa opzione viene usata quando gli utenti vogliono leggere lo stato dall'aggiunta al flusso di flusso.
joinSide STRING 'None' Rappresenta il lato di destinazione da cui leggere. Questa opzione viene usata quando gli utenti vogliono leggere lo stato dall'aggiunta al flusso di flusso. Uno dei seguenti: 'Left', 'Right', 'None'.

Valori restituiti

La funzione restituisce un set di risultati con le colonne seguenti.

Nota

Le colonne annidate per chiave e valore dipendono in modo pesante dallo schema di input dell'operatore con stato e dal tipo di operatore.

Nome Tipo di dati Nullable Standard Descrizione
id STRUCT No Riga chiave dell'operatore con stato archiviata nel checkpoint di stato.
value STRUCT Sì Riga valore dell'operatore con stato archiviata nel checkpoint di stato.
partition_id INTEGER No Partizione che contiene il record.
shardId STRING No Identificatore univoco per la partizione da cui sono stati letti i dati.
sequenceNumber BIGINT No Identificatore univoco del record all'interno della partizione.
approximateArrivalTimestamp TIMESTAMP No Ora approssimativa in cui il record è stato inserito nel flusso.

Esempi

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