AggregatorTop Klasse

Definiert einen Aggregator, der die ersten n Elemente basierend auf Joinschlüsseln abruft.

Initialisieren sie mit spitzen Zahlen.

Vererbung

Aggregator

AggregatorTop

Konstruktor

AggregatorTop(n: int = 1)

Parameter

Name	Beschreibung
n	Standardwert: 1

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 der ersten n Werte basierend auf den Eingabejoinschlüsseln.

get_log_property

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

get_log_property()

process_public_dataset

Abrufen der ersten n Werte basierend auf den Eingabejoinschlü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.