AggregatorTop Classe

Definisce un aggregatore che ottiene la prima N in base alle chiavi di join.

Inizializzare con i numeri principali.

Ereditarietà

Aggregator

AggregatorTop

Costruttore

AggregatorTop(n: int = 1)

Parametri

Nome	Descrizione
n	Valore predefinito: 1

Commenti

Gli aggregatori in genere non vengono create direttamente istanze. Specificare invece il tipo di aggregatore quando si usa un enricher, ad esempio l'oggetto HolidayEnricher .

Il process_public_dataset(env, _public_dataset, cols, join_keys) metodo ottiene il valore massimo.

Metodi

get_log_property	Ottiene la tupla delle proprietà del log, Nessuna se nessuna proprietà.
process_public_dataset	Ottenere i primi N valori in base alle chiavi di join di input.

get_log_property

Ottiene la tupla delle proprietà del log, Nessuna se nessuna proprietà.

get_log_property()

process_public_dataset

Ottenere i primi N valori in base alle chiavi di join di input.

process_public_dataset(env: SparkEnv | PandasEnv, _public_dataset: object, cols: object, join_keys: list)

Parametri

Nome	Descrizione
env Necessario	RuntimeEnv Ambiente di runtime.
_public_dataset Necessario	PublicData Set di dati pubblico di input.
cols Necessario	list Elenco dei nomi di colonna da recuperare.
join_keys Necessario	list Elenco di coppie chiave di join.

Restituisce

Tipo	Descrizione
	Set di dati pubblico aggregato.