AggregatorMin Klasse
Definiert einen Aggregator, der das Minimum basierend auf Joinschlüsseln abruft.
Konstruktor
AggregatorMin()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 |
Ruft den Mindestwert basierend auf join_keys ab. |
get_log_property
Ruft das Protokolleigenschaftstupel ab. Gibt nichts zurück, wenn keine Eigenschaft vorhanden ist.
get_log_property()process_public_dataset
Ruft den Mindestwert basierend auf join_keys ab.
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. |