可以使用createTimeSeriesAggregator创建流数据时序聚合引擎,启用updateTime参数。
updateTime参数类型是整型,如果没有指定updateTime,一个数据窗口结束前,不会发生对该数据窗口数据的计算。若要求在当前窗口结束前对当前窗口已有数据进行计算,可指定updateTime。step必须是updateTime的整数倍。要设置updateTime,useSystemTime必须设为false。
具体的参考教程:https://gitee.com/dolphindb/T...