AggregatorMax Classe
Définit une agrégation qui obtient la valeur maximale en fonction des clés de jointure.
- Héritage
-
AggregatorMax
Constructeur
AggregatorMax()
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 |
Obtient la valeur minimale en fonction des clés de jointure. |
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
Obtient la valeur minimale en fonction des clés de jointure.
process_public_dataset(env: SparkEnv | PandasEnv, _public_dataset: object, cols: object, join_keys: list)
Paramètres
Nom | Description |
---|---|
env
Obligatoire
|
Environnement d’exécution. |
_public_dataset
Obligatoire
|
Jeu de données public d’entrée. |
cols
Obligatoire
|
Liste des noms de colonnes à récupérer. |
join_keys
Obligatoire
|
Liste de paires de clés de jointure. |
Retours
Type | Description |
---|---|
Jeu de données public agrégé. |