AggregatorMax 類別

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

繼承

Aggregator

AggregatorMax

建構函式

AggregatorMax()

備註

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

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

方法

get_log_property	取得記錄屬性 Tuple，如果沒有屬性，則為 None。
process_public_dataset	根據聯結索引鍵取得最大值。

get_log_property

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

get_log_property()

process_public_dataset

根據聯結索引鍵取得最大值。

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

參數

名稱	Description
env 必要	RuntimeEnv 運行時間環境。
_public_dataset 必要	PublicData 輸入公用數據集。
cols 必要	list 要擷取的數據行名稱清單。
join_keys 必要	list 聯結金鑰組的清單。

傳回

類型	Description
	匯總的公用數據集。