get (osservazione)

Ottiene le metriche osservate.

Attende che il set di dati osservato termini la prima azione. È disponibile solo il risultato della prima azione. Le azioni successive non modificano il risultato.

Sintassi

get

Restituzioni

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}