AggregatorTop 類別

定義匯總工具，此匯總工具會根據聯結索引鍵取得前 N 個。

使用頂端數位初始化。

繼承

Aggregator

AggregatorTop

建構函式

AggregatorTop(n: int = 1)

參數

名稱	Description
n	預設值: 1

備註

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

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

方法

get_log_property	取得記錄屬性 Tuple，如果沒有屬性，則為 None。
process_public_dataset	根據輸入聯結索引鍵取得前 N 個值。

get_log_property

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

get_log_property()

process_public_dataset

根據輸入聯結索引鍵取得前 N 個值。

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
	匯總的公用數據集。