AggregatorMax Classe

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

Herança

Aggregator

AggregatorMax

Construtor

AggregatorMax()

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

Métodos

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

get_log_property

Obter tupla de propriedade log, Nenhum se nenhuma propriedade.

get_log_property()

process_public_dataset

Obtenha 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

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.