AggregatorAvg Klasa

Zdefiniuj agregator, który pobiera średnio na podstawie kluczy sprzężenia.

Konstruktor

AggregatorAvg()

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 średnią wartość.

get_log_property	Pobierz krotkę właściwości dziennika, Brak, jeśli nie ma właściwości.
process_public_dataset	Uzyskaj średnią na podstawie join_keys wejściowych.

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

get_log_property()

Uzyskaj średnią na podstawie join_keys wejściowych.

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.