AggregatorTop Klas

Definieert een aggregator die de bovenste N ophaalt op basis van joinsleutels.

Initialiseer met de hoogste getallen.

Overname

Aggregator

AggregatorTop

Constructor

AggregatorTop(n: int = 1)

Parameters

Name	Description
n	Default value: 1

Opmerkingen

Aggregators worden doorgaans niet rechtstreeks geïnstantieerd. Geef in plaats daarvan het type aggregator op wanneer u een verrijker zoals het HolidayEnricher object gebruikt.

De process_public_dataset(env, _public_dataset, cols, join_keys) methode haalt de maximumwaarde op.

Methoden

get_log_property	Get log property tuple, None if no property.
process_public_dataset	Haal de bovenste N-waarden op op basis van de invoerdeelnamesleutels.

get_log_property

Get log property tuple, None if no property.

get_log_property()

process_public_dataset

Haal de bovenste N-waarden op op basis van de invoerdeelnamesleutels.

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

Parameters

Name	Description
env Vereist	RuntimeEnv De runtime-omgeving.
_public_dataset Vereist	PublicData De openbare invoergegevensset.
cols Vereist	list De lijst met kolomnamen die moet worden opgehaald.
join_keys Vereist	list Een lijst met joinsleutelparen.

Retouren

Type	Description
	Een geaggregeerde openbare gegevensset.