AggregatorAvg Classe

Defina um agregador que obtém uma média com base nas chaves de associação.

Herança

Aggregator

AggregatorAvg

Construtor

AggregatorAvg()

Observações

Normalmente, os agregadores não são instanciados diretamente. Em vez disso, especifique o tipo de agregador ao utilizar um melhorador, como o HolidayEnricher objeto .

O process_public_dataset(env, _public_dataset, cols, join_keys) método obtém o valor médio.

Métodos

get_log_property	Obter cadeia de identificação de propriedades de registo, Nenhuma se não existir nenhuma propriedade.
process_public_dataset	Obtenha a média com base no join_keys de entrada.

get_log_property

Obter cadeia de identificação de propriedades de registo, Nenhuma se não existir nenhuma propriedade.

get_log_property()

process_public_dataset

Obtenha a média com base no join_keys de entrada.

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

Parâmetros

env

RuntimeEnv

Necessário

O ambiente de runtime.

_public_dataset

PublicData

Necessário

O conjunto de dados público de entrada.

cols

list

Necessário

A lista de nomes de coluna a obter.

join_keys

list

Necessário

Uma lista de pares de chaves de associação.

Devoluções

Um conjunto de dados público agregado.