AggregatorAvg Klas
Definieer een aggregator die een gemiddelde krijgt op basis van joinsleutels.
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
|
De runtime-omgeving. |
|
_public_dataset
Vereist
|
De openbare invoergegevensset. |
|
cols
Vereist
|
De lijst met kolomnamen die moet worden opgehaald. |
|
join_keys
Vereist
|
Een lijst met joinsleutelparen. |
Retouren
| Type | Description |
|---|---|
|
Een geaggregeerde openbare gegevensset. |