AggregatorMin Class

  • Reference

Defines an aggregator that get the minimum based on join keys.

Inheritance
Aggregator
AggregatorMin

Constructor

AggregatorMin()

Remarks

Aggregators are typically not instantiated directly. Instead, specify the the type of aggregator when using using an enricher such as the HolidayEnricher object.

The process_public_dataset(env, _public_dataset, cols, join_keys) method gets the maximum value.

Methods

get_log_property

Get log property tuple, None if no property.
process_public_dataset

Get minimum value based on join_keys.

get_log_property

Get log property tuple, None if no property.

get_log_property()

process_public_dataset

Get minimum value based on join_keys.

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

Parameters

env
RuntimeEnv
Required

The runtime environment.

_public_dataset
PublicData
Required

The input public dataset.

cols
list
Required

The column name list to retrieve.

join_keys
list
Required

A list of join key pairs.

Returns

An aggregated public dataset.