get (Beobachtung)

Ruft die beobachteten Metriken ab.

Wartet, bis das beobachtete Dataset seine erste Aktion beendet hat. Nur das Ergebnis der ersten Aktion ist verfügbar. Nachfolgende Aktionen ändern das Ergebnis nicht.

Syntax

get

Rückkehr

dict

Beispiele

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}