AggregatorMax Klasse
Definiert einen Aggregator, der basierend auf Joinschlüsseln den Maximalwert abruft.
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
|
Die Laufzeitumgebung. |
|
_public_dataset
Erforderlich
|
Das öffentliche Eingabedataset. |
|
cols
Erforderlich
|
Die abzurufende Spaltennamenliste. |
|
join_keys
Erforderlich
|
Liste von Joinschlüsselpaaren |
Gibt zurück
| Typ | Beschreibung |
|---|---|
|
Ein aggregiertes öffentliches Dataset. |