get (Observation)

Hämtar de observerade måtten.

Väntar tills den observerade datauppsättningen har slutfört sin första åtgärd. Endast resultatet av den första åtgärden är tillgängligt. Efterföljande åtgärder ändrar inte resultatet.

Syntax

get

Retur

dict

Exempel

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}