get (Observation)

Mendapatkan metrik yang diamati.

Menunggu hingga himpunan data yang diamati menyelesaikan tindakan pertamanya. Hanya hasil tindakan pertama yang tersedia. Tindakan berikutnya tidak mengubah hasilnya.

Sintaksis

get

Pengembalian Barang

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}