read_state_metadata
table-valued 函式
適用於: Databricks SQL Databricks Runtime 14.3 和更新版本
傳回 table,其數據列代表串流查詢狀態的元數據。
用於提取串流查詢狀態運算符元數據的 table 值函數。 它只支援以批次查詢的形式執行。
語法
read_state_metadata(path)
引數
此函式需要 選項索引鍵的具名參數調用 。
-
path
STRING
:具有串流查詢檢查點位置路徑的常值。
傳回
狀態元數據 table 具有下列 schema。 所有 columns 欄位都不能為 NULL。
operatorId INT NOT NULL
具狀態串流運算子的整數標識碼。
operatorName STRING NOT NULL
具狀態串流運算子的名稱。
stateStoreName STRING NOT NULL
運算子狀態存放區的名稱。
numPartitions INT NOT NULL
狀態存放區的分割區數目。
minBatchId BIGINT NOT NULL
可供查詢狀態的最小批次識別碼。 如果擷取檢查點的串流查詢正在執行,該值可能會無效,因為它會導致清除執行。
maxBatchId BIGINT NOT NULL
可供查詢狀態的最大批次識別碼。 如果擷取檢查點的串流查詢正在執行,此值可能會無效,因為查詢會認可進一步批次。
範例
- Read state metadata from the checkpoint
> SELECT * FROM read_state_metadata('/checkpoint/path');