read_state_metadata fonction table

  • Article

S’applique à:check marked yes Databricks Runtime 14.3 et versions ultérieures

Retourne une table avec des lignes qui représentent les métadonnées d’un état de requête de diffusion en continu.

Il s’agit d’une fonction table qui permet de lire les métadonnées d’opérateurs avec état de requête de diffusion en continu. Elle prend uniquement en charge l’exécution sous forme d’une requête par lots.

Syntaxe

read_state_metadata(path)

Arguments

Cette fonction nécessite un appel de paramètre nommé pour les clés d’option.

  • path : littéral STRING avec le chemin d’accès de l’emplacement du point de contrôle de la requête de diffusion en continu.

Retours

Une table des métadonnées d’état a le schéma suivant. Toutes les colonnes sont NOT NULL.

  • operatorId INT NOT NULL

    ID entier de l’opérateur de diffusion en continu avec état.

  • operatorName STRING NOT NULL

    Nom de l’opérateur de diffusion en continu avec état.

  • stateStoreName STRING NOT NULL

    Nom du magasin d’état de l’opérateur.

  • numPartitions INT NOT NULL

    Nombre de partitions du magasin d’état.

  • minBatchId BIGINT NOT NULL

    ID de lot minimal disponible pour l’état d’interrogation. La valeur peut être non valide si la requête de diffusion en continu qui prend le point de contrôle est en cours d’exécution, car cela entraînerait l’exécution du nettoyage.

  • maxBatchId BIGINT NOT NULL

    ID de lot maximal disponible pour l’état d’interrogation. La valeur peut être non valide si la requête de diffusion en continu qui prend le point de contrôle est en cours d’exécution, car la requête validerait d’autres lots.

Exemples

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