AggregatorMin Klasa

Definiuje agregator, który uzyskuje minimum na podstawie kluczy sprzężenia.

Konstruktor

AggregatorMin()

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 minimalną wartość na podstawie join_keys.

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

get_log_property()

Pobierz minimalną wartość na podstawie join_keys.

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.