AggregatorAvg 类

定义基于联接键获取平均值的聚合器。

继承

Aggregator

AggregatorAvg

构造函数

AggregatorAvg()

注解

通常不会直接实例化聚合器。 而是在使用扩充器（如 HolidayEnricher 对象）时指定聚合器的类型。

process_public_dataset(env, _public_dataset, cols, join_keys) 方法获取平均值。

方法

get_log_property	获取日志属性元组；如果没有属性，则为“无”。
process_public_dataset	根据输入 join_keys 获取平均值。

get_log_property

获取日志属性元组；如果没有属性，则为“无”。

get_log_property()

process_public_dataset

根据输入 join_keys 获取平均值。

process_public_dataset(env: Union[azureml.opendatasets.environ.SparkEnv, azureml.opendatasets.environ.PandasEnv], _public_dataset: object, cols: object, join_keys: list)

参数

env

RuntimeEnv

必需

运行时环境。

_public_dataset

PublicData

必需

输入公共数据集。

cols

list

必需

要检索的列名列表。

join_keys

list

必需

联接键对的列表。

返回

聚合的公共数据集。