建议用响应式状态引擎,因子使用 tm 系列函数去实现。
我现在想当时序引擎的上游表每进来一条数据(即触发方式和状态引擎一样),则触发createTimeSeriesEngine计算从当前数据开始往前10秒的窗口,请问如何实现?
我参考了createTimeSeriesEngine所有参数,发现有两个可能有用
1、useSystemTime=false ,但文档说触发计算的数据并不会参与该次计算, 而我要的是触发计算的数据 也会参与该次计算
2、设置forceTriggerTime, 但没完全看懂,暂不知道设置该参数能否满足我的要求