一套引擎级联的流程如何作用在批量数据上(使用批计算方式)？

就是现在写了一连串流数据计算引擎级联， quotes-> ..-> ..-> ..-->res

当对quotes数据回放，那等于是用流计算的方式输出了最后的res
如何不使用数据回放，对一个几百万量级的批数据(schema和quotes相同)应用这套计算逻辑使用批计算的方式，计算出最后的结果？

0 条评论

默认排序时间排序

1 个回答

Yating Xie 2022-04-04 17:51

可以通过改写为SQL语句来实现批计算，metrics里的因子实现可以直接复用，引擎串联可以改写为SQL语句的子查询。

https://gitee.com/dolphindb/Tutorials_CN/blob/master/reactive_state_engine.md 这个教程的第三章序言部分举例说明了使用函数或表达式实现金融高频因子，代入不同的计算引擎进行历史数据或流数据的计算。代入SQL引擎，可以实现对历史数据的计算；代入响应式状态引擎，可以实现对流数据的计算。供参考

一套引擎级联的流程 如何作用在批量数据上(使用批计算方式)？

1 个回答

相似问题

一套引擎级联的流程如何作用在批量数据上(使用批计算方式)？