AggregatorAvg Klas

Definieer een aggregator die een gemiddelde krijgt op basis van joinsleutels.

Overname

Aggregator

AggregatorAvg

Constructor

AggregatorAvg()

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 gemiddelde waarde op.

Methoden

get_log_property	Get log property tuple, None if no property.
process_public_dataset	Het gemiddelde ophalen op basis van de invoer join_keys.

get_log_property

Get log property tuple, None if no property.

get_log_property()

process_public_dataset

Het gemiddelde ophalen op basis van de invoer join_keys.

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.