適用於:
Databricks SQL
Databricks Runtime 14.3 及更高版本
傳回數據表,其中包含代表串流查詢狀態元數據的數據列。
表值函數,用於讀取具有狀態的串流查詢運算符的元數據。 它只支援以批次查詢的形式執行。
語法
read_state_metadata(path)
引數
此函式需要針對選項鍵使用具名參數調用。
- 帶有串流查詢檢查點位置路徑的
pathSTRING文字常量。
退貨
狀態元數據的數據表具有下列架構。 所有欄位均為 NOT 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');