AggregatorMax Klasa

Definiuje agregator, który uzyskuje maksymalną wartość na podstawie kluczy sprzężenia.

Konstruktor

AggregatorMax()

Agregatory zwykle nie są tworzone bezpośrednio. Zamiast tego określ typ agregatora podczas używania wzbogacacza, takiego jak HolidayEnricher obiekt.

Metoda process_public_dataset(env, _public_dataset, cols, join_keys) pobiera maksymalną wartość.

get_log_property	Pobierz krotkę właściwości dziennika, Brak, jeśli nie ma właściwości.
process_public_dataset	Pobierz maksymalną wartość na podstawie kluczy sprzężenia.

Pobierz krotkę właściwości dziennika, Brak, jeśli nie ma właściwości.

get_log_property()

Pobierz maksymalną wartość na podstawie kluczy sprzężenia.

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

Nazwa	Opis
env Wymagane	RuntimeEnv Środowisko uruchomieniowe.
_public_dataset Wymagane	PublicData Wejściowy publiczny zestaw danych.
cols Wymagane	list Lista nazw kolumn do pobrania.
join_keys Wymagane	list Lista par kluczy sprzężenia.

Typ	Opis
	Zagregowany publiczny zestaw danych.