从Apache Flink查询数据

Question

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

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

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

Answer 1

开箱即用的 Flink 目前没有提供用于查询操作内部状态的解决方案。不过，您很幸运，因为有两种解决方案： 我们做了一个允许查询状态的状态字数统计示例。此处提供： https: //github.com/dataArtisans/query-window-example

对于即将推出的 Flink 版本之一，我们还在研究可查询状态用例的通用解决方案。这将允许查询任何内部操作的状态。

另外，在您的情况下，使用窗口操作定期将值输出到 Elasticsearch 之类的东西是否也足够了。然后可以简单地从 Elasticsearch 查询结果。