AggregatorAvg Clase

Define un agregador que obtiene un promedio basado en claves de combinación.

Herencia

Aggregator

AggregatorAvg

Constructor

AggregatorAvg()

Comentarios

Normalmente, no se crea una instancia de los agregadores directamente. En su lugar, especifique el tipo de agregador al usar un enriquecedor como el objeto HolidayEnricher.

El método process_public_dataset(env, _public_dataset, cols, join_keys) obtiene el valor medio.

Métodos

get_log_property	Obtenga la tupla de la propiedad de registro; None si no hay ninguna propiedad.
process_public_dataset	Obtiene el promedio en función de la entrada join_keys.

get_log_property

Obtenga la tupla de la propiedad de registro; None si no hay ninguna propiedad.

get_log_property()

process_public_dataset

Obtiene el promedio en función de la entrada join_keys.

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

Parámetros

env

RuntimeEnv

Requerido

Entorno de ejecución.

_public_dataset

PublicData

Requerido

Conjunto de datos público de entrada.

cols

list

Requerido

Lista de nombres de columna que se recuperará.

join_keys

list

Requerido

Lista de pares de claves de combinación.

Devoluciones

Conjunto de datos público agregado.