get (Observation)

Obtient les métriques observées.

Attend que le dataset 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

Renvoie

dict

Exemples

Python

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}