小编No *_*One的帖子

我期待从本土流媒体服务器迁移到Apache Flink.我们有一件事就是像DRPC接口这样的Apache Storm,可以针对处理拓扑中保存的状态运行查询.

例如:我有一堆传感器,我正在运行移动平均线.我想在拓扑上运行查询并返回平均值高于固定值的所有传感器.

在Flink中是否存在等价物,或者如果没有,实现等效功能的最佳方法是什么？