TimeNearestSelector 类

定义时间最近的选择器，对不同的时间粒度进行舍入。

使用时间粒度进行初始化。

继承

EnricherTimeSelector

TimeNearestSelector

构造函数

TimeNearestSelector(_granularity: TimeGranularity, enable_telemetry: bool = True)

参数

名称	说明
_granularity 必需
enable_telemetry	默认值: True

方法

process

通过指定的聚合器，使用公共数据扩充客户数据。

process

通过指定的聚合器，使用公共数据扩充客户数据。

process(env: RuntimeEnv, customer_data: TimeData, public_data: TimeData, aggregator: Aggregator, join_keys: list | None = None, debug: bool = False)

参数

名称	说明
env 必需	RuntimeEnv 运行时环境。
customer_data 必需	TimeData TimeData 数据派生类的实例。
public_data 必需	TimeData TimeData 数据派生类的实例。
aggregator 必需	Aggregator 聚合器。
join_keys	list 联接键对的列表。 默认值: None
debug	bool 指示是否要打印调试日志。 默认值: False

返回

类型	说明
tuple	一个元组，其中包含已更改的客户数据类实例、已更改的公共数据类实例和联接键对的列表。