AggregatorAvg Třída

Definujte agregátor, který získá průměr na základě klíčů spojení.

Konstruktor

AggregatorAvg()

Agregátory se obvykle nespravují přímo. Místo toho zadejte typ agregátoru při použití rozšíření, jako HolidayEnricher je například objekt.

Metoda process_public_dataset(env, _public_dataset, cols, join_keys) získá průměrnou hodnotu.

get_log_property	Získejte řazenou kolekci členů vlastnosti protokolu, žádná, pokud žádná vlastnost.
process_public_dataset	Získejte průměr na základě vstupního join_keys.

Získejte řazenou kolekci členů vlastnosti protokolu, žádná, pokud žádná vlastnost.

get_log_property()

Získejte průměr na základě vstupního join_keys.

process_public_dataset(env: SparkEnv | PandasEnv, _public_dataset: object, cols: object, join_keys: list)

Name	Description
env Vyžadováno	RuntimeEnv Prostředí runtime.
_public_dataset Vyžadováno	PublicData Vstupní veřejná datová sada.
cols Vyžadováno	list Seznam názvů sloupců, který chcete načíst.
join_keys Vyžadováno	list Seznam párů spojovacích klíčů.

Typ	Description
	Agregovaná veřejná datová sada.