get (Observation)

Obtient les métriques observées.

Attend que le jeu de données observé termine sa première action. Seul le résultat de la première action est disponible. Les actions suivantes ne modifient pas le résultat.

Syntaxe

get

Retours

dict

Exemples

from pyspark.sql.functions import col, count, lit, max
from pyspark.sql import Observation

df = spark.createDataFrame([["Alice", 2], ["Bob", 5]], ["name", "age"])
observation = Observation("my metrics")
observed_df = df.observe(observation, count(lit(1)).alias("count"), max(col("age")))
observed_df.count()
# 2
observation.get
# {'count': 2, 'max(age)': 5}