需要面试准备
某个流式特征流水线把事件 (ts, value) 聚合到单个滚动窗口 [window_start, window_end)。流水线允许操作员选择一个触发策略,决定运行中的聚合何时被发往下游。请实现 solution(events, window_start, window_end, policy, policy_param) -> list[dict]。
(ts, value)
[window_start, window_end)
solution(events, window_start, window_end, policy, policy_param) -> list[dict]