read_state_metadata tabelwaarde, functie

  • Artikel

Van toepassing op:check marked yes Databricks Runtime 14.3 en hoger

Retourneert een tabel met rijen die de metagegevens van een streamingquerystatus vertegenwoordigen.

Een tabelwaardefunctie voor het lezen van metagegevens van stateful operators voor streamingquery's. Het biedt alleen ondersteuning voor uitvoeren als batchquery.

Syntaxis

read_state_metadata(path)

Argumenten

Voor deze functie is aanroepen van benoemde parameters vereist voor de optiesleutels.

  • path: Een STRING letterlijke waarde met het pad van de locatie van het controlepunt voor streamingquery's.

Retourneert

Een tabel met statusmetagegevens heeft het volgende schema. Alle kolommen zijn NIET NULL.

  • operatorId INT NOT NULL

    Een geheel getal-id van de stateful streaming-operator.

  • operatorName STRING NOT NULL

    Naam van de stateful streaming-operator.

  • stateStoreName STRING NOT NULL

    Naam van het statusarchief van de operator.

  • numPartitions INT NOT NULL

    Aantal partities van het statusarchief.

  • minBatchId BIGINT NOT NULL

    De minimale batch-id die beschikbaar is voor het uitvoeren van querystatussen. De waarde kan ongeldig zijn als de streamingquery die het controlepunt uitvoert, wordt uitgevoerd, omdat het opschonen zou veroorzaken.

  • maxBatchId BIGINT NOT NULL

    De maximale batch-id die beschikbaar is voor querystatus. De waarde kan ongeldig zijn als de streamingquery die het controlepunt uitvoert, wordt uitgevoerd, omdat de query verdere batches doorvoert.

Voorbeelden

- Read state metadata from the checkpoint
> SELECT * FROM read_state_metadata('/checkpoint/path');