Share via

read_state_metadata table-valued 函式

  • 發行項

適用於：check marked yes 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');