AggregatorAvg Classe

Definire un aggregatore che ottiene una media in base alle chiavi di join.

Ereditarietà

Aggregator

AggregatorAvg

Costruttore

AggregatorAvg()

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

Metodi

get_log_property	Ottiene la tupla delle proprietà del log, Nessuna se nessuna proprietà.
process_public_dataset	Ottenere la media in base al join_keys di input.

get_log_property

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

get_log_property()

process_public_dataset

Ottenere la media in base al join_keys 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.