AggregatorAvg Klass
Definiera en aggregator som får ett genomsnitt baserat på kopplingsnycklar.
Konstruktor
AggregatorAvg()Kommentarer
Aggregeringar instansieras vanligtvis inte direkt. Ange i stället typen av aggregator när du använder en berikare, till exempel HolidayEnricher objektet.
Metoden process_public_dataset(env, _public_dataset, cols, join_keys) hämtar det genomsnittliga värdet.
Metoder
| get_log_property |
Hämta loggegenskapstuppeln, Ingen om ingen egenskap. |
| process_public_dataset |
Hämta medelvärde baserat på indata join_keys. |
get_log_property
Hämta loggegenskapstuppeln, Ingen om ingen egenskap.
get_log_property()process_public_dataset
Hämta medelvärde baserat på indata join_keys.
process_public_dataset(env: SparkEnv | PandasEnv, _public_dataset: object, cols: object, join_keys: list)Parametrar
| Name | Description |
|---|---|
|
env
Obligatorisk
|
Körningsmiljön. |
|
_public_dataset
Obligatorisk
|
Den inmatade offentliga datamängden. |
|
cols
Obligatorisk
|
Listan med kolumnnamn som ska hämtas. |
|
join_keys
Obligatorisk
|
En lista över kopplingsnyckelpar. |
Returer
| Typ | Description |
|---|---|
|
En aggregerad offentlig datamängd. |