read_statestore fungsi dengan nilai tabel

Berlaku untuk:centang ditandai ya Databricks SQL centang ditandai ya Databricks Runtime 14.3 ke atas

Fungsi bernilai tabel untuk membaca rekaman dari penyimpanan status kueri streaming. Relasi yang dikembalikan hanya mendukung berjalan sebagai kueri batch.

Sintaks

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

Argumen

read_statestore memerlukan pemanggilan parameter bernama untuk parameter opsionalnya.

  • path: A STRING literal. Jalur lokasi titik pemeriksaan kueri streaming.
  • option_key: Nama opsi untuk dikonfigurasi. Anda perlu menggunakan backtick (') untuk opsi yang berisi titik -titik (.).
  • option_value: Ekspresi konstanta untuk mengatur opsi ke. Menerima literal dan fungsi skalar.

Semua option_valuetidak peka huruf besar/kecil.

option_key Jenis Default Deskripsi
batchId BIGINT id batch terbaru Mewakili batch target untuk dibaca. Opsi ini digunakan saat pengguna ingin melakukan perjalanan waktu. Batch harus diterapkan tetapi belum dibersihkan.
OperatorId BIGINT 0 Mewakili operator target untuk dibaca. Opsi ini digunakan saat kueri menggunakan beberapa operator stateful.
storeName STRING 'DEFAULT' Mewakili sisi target untuk dibaca. Opsi ini digunakan saat pengguna ingin membaca status dari gabungan stream-stream.
joinSide STRING 'None' Mewakili sisi target untuk dibaca. Opsi ini digunakan saat pengguna ingin membaca status dari gabungan stream-stream. Salah satu dari: 'Left', 'Right', 'None'.

Mengembalikan

Fungsi mengembalikan tataan hasil dengan kolom berikut.

Catatan

Kolom berlapis untuk kunci dan nilai sangat bergantung pada skema input operator stateful dan jenis operator.

Nama Jenis data Dapat diubah ke null Standard Deskripsi
id STRUCT No Baris kunci operator stateful yang disimpan di titik pemeriksaan status.
value STRUCT Ya Baris nilai operator stateful yang disimpan di titik pemeriksaan status.
partition_id INTEGER No Partisi yang berisi rekaman.
shardId STRING No Pengidentifikasi unik untuk bagian (shard) tempat data dibaca.
sequenceNumber BIGINT No Pengidentifikasi unik rekaman dalam pecahannya.
approximateArrivalTimestamp TIMESTAMP No Perkiraan waktu rekaman dimasukkan ke dalam aliran.

Contoh

-- 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'
  );
  • Last updated on