AggregatorMax Classe

Define um agregador que obtém o máximo com base nas chaves de junção.

Herança

Aggregator

AggregatorMax

Construtor

AggregatorMax()

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áximo.

Métodos

get_log_property	Obtenha tupla de propriedade de log, Nenhum se não houver nenhuma propriedade.
process_public_dataset	Obtém o valor máximo com base nas chaves de junção.

get_log_property

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

get_log_property()

process_public_dataset

Obtém o valor máximo com base nas chaves de junção.

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.