AggregatorTop Klasa

Definiuje agregator, który pobiera górną N na podstawie kluczy sprzężenia.

Zainicjuj za pomocą pierwszych liczb.

Konstruktor

AggregatorTop(n: int = 1)

Nazwa	Opis
n	Domyślna wartość: 1

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 n pierwszych wartości na podstawie kluczy sprzężenia wejściowego.

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

get_log_property()

Pobierz n pierwszych wartości na podstawie kluczy sprzężenia wejściowego.

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.