AggregatorMin Classe

Définit un agrégateur qui obtient la valeur minimale basée sur les clés de jointure.

Héritage

Aggregator

AggregatorMin

Constructeur

AggregatorMin()

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

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 la valeur minimale en fonction de join_keys.

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 la valeur minimale en fonction de join_keys.

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

Paramètres

env

RuntimeEnv

Obligatoire

Environnement d’exécution.

_public_dataset

PublicData

Obligatoire

Jeu de données public d’entrée.

cols

list

Obligatoire

Liste des noms de colonnes à récupérer.

join_keys

list

Obligatoire

Liste de paires de clés de jointure.

Retours

Jeu de données public agrégé.