AggregatorMax Classe

Definisce un aggregatore che ottiene il massimo in base alle chiavi di join.

Ereditarietà

Aggregator

AggregatorMax

Costruttore

AggregatorMax()

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	Ottiene il valore massimo in base alle chiavi di join.

get_log_property

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

get_log_property()

process_public_dataset

Ottiene il valore massimo in base alle chiavi di join.

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.