实时计算K线

以窗口时间1分钟计算vwap价格为例,10:00更新了聚合结果以后,那么下一次更新至少要等到10:01。按照计算规则,这一分钟内即使发生了很多交易,也不会触发任何计算。这在很多金融交易场景中是无法接受的,希望以更高的频率更新信息,为此引入了时序聚合引擎的updateTime参数。

需要说明的是,时序聚合引擎要求在使用updateTime参数时,必须使用keyedTable作为输出表。

那么问题来了,如果我后续还需要根据这个k线数据表计算技术指标,怎么办?  keyedTable 不是streamtable,不能被后续订阅 ?

请先 登录 后评论

1 个回答

peter

有两种方案
1. keyedTable如果是最终结果的话,每次全量读取数据计算
2. 使用streamtable,在自己的脚本中实现数据去重,比如写入一个redis中

请先 登录 后评论