AggregatorAvg Classe

Defina um agregador que obtenha uma média com base em chaves de junçã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 usar um enriquecedor, 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 tupla de propriedade log, Nenhum se nenhuma propriedade.
process_public_dataset	Obtenha uma média com base no join_keys de entrada.

get_log_property

Obter tupla de propriedade log, Nenhum se nenhuma propriedade.

get_log_property()

process_public_dataset

Obtenha uma 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

Name	Description
env Necessário	RuntimeEnv O ambiente de tempo de execução.
_public_dataset Necessário	PublicData O conjunto de dados público de entrada.
cols Necessário	list A lista de nomes de colunas a ser recuperada.
join_keys Necessário	list Uma lista de pares de chaves de junção.

Devoluções

Tipo	Description
	Um conjunto de dados públicos agregados.