get (Observatie)

Haalt de waargenomen metrische gegevens op.

Wacht totdat de waargenomen gegevensset de eerste actie heeft voltooid. Alleen het resultaat van de eerste actie is beschikbaar. Volgende acties wijzigen het resultaat niet.

Syntaxis

get

Retouren

dict

Examples

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}