AggregatorTop Třída

Definuje agregátor, který získá horní N na základě spojovacích klíčů.

Inicializace s nejvyššími čísly

Konstruktor

AggregatorTop(n: int = 1)

Name	Description
n	Default value: 1

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 nejvyšší hodnoty N na základě vstupních spojovacích klíčů.

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

get_log_property()

Získejte nejvyšší hodnoty N na základě vstupních spojovacích klíčů.

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.