AggregatorAvg Classe

Define um agregador que obtém uma média com base em chaves de junção.

Herança

Aggregator

AggregatorAvg

Construtor

AggregatorAvg()

Comentários

Os agregadores geralmente não são instanciados diretamente. Em vez disso, especifique o tipo de agregador ao usar um enriquecedor, como o objeto HolidayEnricher.

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

Métodos

get_log_property	Obtenha tupla de propriedade de log, Nenhum se não houver nenhuma propriedade.
process_public_dataset	Obter a média com base as join_keys de entrada.

get_log_property

Obtenha tupla de propriedade de log, Nenhum se não houver nenhuma propriedade.

get_log_property()

process_public_dataset

Obter a média com base as join_keys de entrada.

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

Parâmetros

Nome	Description
env Obrigatório	RuntimeEnv O ambiente de runtime.
_public_dataset Obrigatório	PublicData O conjunto de dados público de entrada.
cols Obrigatório	list A lista de nomes de coluna a ser recuperada.
join_keys Obrigatório	list Uma lista de pares de chaves de junção.

Retornos

Tipo	Description
	Um conjunto de dados público agregado.