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 联接键对的列表。

返回

类型	说明
	聚合的公共数据集。