AggregatorAvg クラス

結合キーに基づいて平均を求めるアグリゲーターを定義します。

継承

Aggregator

AggregatorAvg

コンストラクター

AggregatorAvg()

注釈

通常、アグリゲーターは直接インスタンス化されません。 そのため、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 結合キー ペアの一覧。

戻り値

型	説明
	集計済みのパブリック データセット。