Sdílet prostřednictvím


AggregatorMin Třída

Definuje agregátor, který získá minimum na základě klíčů join.

Dědičnost
AggregatorMin

Konstruktor

AggregatorMin()

Poznámky

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.

Metody

get_log_property

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

process_public_dataset

Získejte minimální hodnotu na základě join_keys.

get_log_property

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

get_log_property()

process_public_dataset

Získejte minimální hodnotu na základě join_keys.

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

Parametry

Name Description
env
Vyžadováno

Prostředí runtime.

_public_dataset
Vyžadováno

Vstupní veřejná datová sada.

cols
Vyžadováno

Seznam názvů sloupců, který chcete načíst.

join_keys
Vyžadováno

Seznam párů spojovacích klíčů.

Návraty

Typ Description

Agregovaná veřejná datová sada.