AggregatorTop Classe
Define um agregador que obtém os N principais com base nas chaves de junção.
Inicialize com os números principais.
- Herança
-
AggregatorTop
Construtor
AggregatorTop(n: int = 1)Parâmetros
| Nome | Description |
|---|---|
|
n
|
Valor padrão: 1
|
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 |
Obter os principais N valores com base nas chaves de junção 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 os principais N valores com base nas chaves de junção de entrada.
process_public_dataset(env: SparkEnv | PandasEnv, _public_dataset: object, cols: object, join_keys: list)Parâmetros
| Nome | Description |
|---|---|
|
env
Obrigatório
|
O ambiente de runtime. |
|
_public_dataset
Obrigatório
|
O conjunto de dados público de entrada. |
|
cols
Obrigatório
|
A lista de nomes de coluna a ser recuperada. |
|
join_keys
Obrigatório
|
Uma lista de pares de chaves de junção. |
Retornos
| Tipo | Description |
|---|---|
|
Um conjunto de dados público agregado. |