AggregatorAvg Classe

Permet de définir un agrégateur qui obtient une moyenne basée sur les clés de jointure.

Héritage

Aggregator

AggregatorAvg

Constructeur

AggregatorAvg()

Remarques

En règle générale, les agrégateurs ne sont pas instanciés directement. À la place, spécifiez le type d’agrégateur quand vous utilisez un enrichisseur tel que l’objet HolidayEnricher.

La méthode process_public_dataset(env, _public_dataset, cols, join_keys) obtient la valeur moyenne.

Méthodes

get_log_property	Permet d’obtenir le tuple de propriété de journal, None en l’absence de propriété.
process_public_dataset	Permet d’obtenir une moyenne en fonction des join_keys d’entrée.

get_log_property

Permet d’obtenir le tuple de propriété de journal, None en l’absence de propriété.

get_log_property()

process_public_dataset

Permet d’obtenir une moyenne en fonction des join_keys d’entrée.

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

Paramètres

Nom	Description
env Obligatoire	RuntimeEnv Environnement d’exécution.
_public_dataset Obligatoire	PublicData Jeu de données public d’entrée.
cols Obligatoire	list Liste des noms de colonnes à récupérer.
join_keys Obligatoire	list Liste de paires de clés de jointure.

Retours

Type	Description
	Jeu de données public agrégé.