AggregatorAvg Klasse

Definiert einen Aggregator, der auf der Grundlage von Joinschlüsseln einen Durchschnitt berechnet.

Vererbung

Aggregator

AggregatorAvg

Konstruktor

AggregatorAvg()

Hinweise

Aggregatoren werden in der Regel nicht direkt instanziiert. Geben Sie stattdessen den Typ des Aggregators an, wenn Sie eine Anreicherung wie das HolidayEnricher-Objekt verwenden.

Die process_public_dataset(env, _public_dataset, cols, join_keys)-Methode ruft den Durchschnittswert ab.

Methoden

get_log_property	Ruft das Protokolleigenschaftstupel ab. Gibt nichts zurück, wenn keine Eigenschaft vorhanden ist.
process_public_dataset	Abrufen des Durchschnitts basierend auf den Joinschlüsseln (join_keys) der Eingabe.

get_log_property

Ruft das Protokolleigenschaftstupel ab. Gibt nichts zurück, wenn keine Eigenschaft vorhanden ist.

get_log_property()

process_public_dataset

Abrufen des Durchschnitts basierend auf den Joinschlüsseln (join_keys) der Eingabe.

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

Parameter

Name	Beschreibung
env Erforderlich	RuntimeEnv Die Laufzeitumgebung.
_public_dataset Erforderlich	PublicData Das öffentliche Eingabedataset.
cols Erforderlich	list Die abzurufende Spaltennamenliste.
join_keys Erforderlich	list Liste von Joinschlüsselpaaren

Gibt zurück

Typ	Beschreibung
	Ein aggregiertes öffentliches Dataset.