AggregatorMin Klasse

Referenz

Definiert einen Aggregator, der das Minimum basierend auf Joinschlüsseln abruft.

Vererbung: Aggregator

AggregatorMin

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	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.

Freigeben über