AggregatorMin 類別

定義匯總工具，以根據聯結索引鍵取得最小值。

繼承

Aggregator

AggregatorMin

建構函式

AggregatorMin()

備註

匯總工具通常不會直接具現化。 請改用擴充器，例如 HolidayEnricher 物件，指定匯總工具的類型。

方法 process_public_dataset(env, _public_dataset, cols, join_keys) 會取得最大值。

方法

get_log_property	取得記錄屬性元組，如果沒有屬性，則為 None。
process_public_dataset	根據join_keys取得最小值。

get_log_property

取得記錄屬性元組，如果沒有屬性，則為 None。

get_log_property()

process_public_dataset

根據join_keys取得最小值。

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

參數

env

RuntimeEnv

必要

執行時間環境。

_public_dataset

PublicData

必要

輸入公用資料集。

cols

list

必要

要擷取的資料行名稱清單。

join_keys

list

必要

聯結金鑰組的清單。

傳回

匯總的公用資料集。