AggregatorMax Klasse

Definiert einen Aggregator, der basierend auf Joinschlüsseln den Maximalwert abruft.

Vererbung

Aggregator

AggregatorMax

Konstruktor

AggregatorMax()

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 Höchstwert ab.

Methoden

get_log_property	Ruft das Protokolleigenschaftstupel ab. Gibt nichts zurück, wenn keine Eigenschaft vorhanden ist.
process_public_dataset	Abrufen des Maximalwerts basierend auf Joinschlüsseln.

get_log_property

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

get_log_property()

process_public_dataset

Abrufen des Maximalwerts basierend auf Joinschlüsseln.

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.