目标:保存的历史数据不能有重复,由于保存1分钟数据量庞大,我现在只保存5分钟时段,再由5分钟时段OHLC转各时段数据。
问题:例如现在是9:42时,流数据表用keyedStreamTable即时下载保存数据,此刻的5分钟K线其实是9:42时这时刻数据,不是9:45的最终数据,如果此时写库入后,到真正9:45时时就保存不了,因为keyedStreamTable已将9.42时的数据当9.45写入,不可更新。我的目标是像keyedTable一样,同一个5分钟时段写N次,都能保存最新最后的数据。
请问应该如何实现?
可以使用createTimeSeriesAggregator创建流数据时序聚合引擎,启用updateTime参数。
updateTime参数类型是整型,如果没有指定updateTime,一个数据窗口结束前,不会发生对该数据窗口数据的计算。若要求在当前窗口结束前对当前窗口已有数据进行计算,可指定updateTime。step必须是updateTime的整数倍。要设置updateTime,useSystemTime必须设为false。
具体的参考教程:https://gitee.com/dolphindb/T...