AggregatorMax Třída

Definuje agregátor, který získá maximální hodnotu na základě klíčů spojení.

Konstruktor

AggregatorMax()

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á maximální hodnotu.

get_log_property	Získejte řazenou kolekci členů vlastnosti protokolu, žádná, pokud žádná vlastnost.
process_public_dataset	Získejte maximální hodnotu na základě klíčů spojení.

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

get_log_property()

Získejte maximální hodnotu na základě klíčů spojení.

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.