从Apache Flink query数据


0

我正在寻找从一个国产 streaming服务器迁移到Apache Flink。我们有一个类似于apachestorm的DRPC接口,可以针对处理拓扑中的状态运行 query。

举个例子:我有一堆传感器,我正在运行移动平均线。我想在拓扑上运行一个 query,并返回平均值高于固定值的所有传感器。

Flink中是否有等效的功能,如果没有,实现等效功能的最佳方法是什么?

2 答案


0

现成的Flink现在没有提供 query操作内部状态的解决方案。不过,您很幸运,因为有两种解决方案:我们做了一个允许 query状态的有状态字数示例。可在以下位置获取:https://github.com/dataArtisans/query-window-example

对于Flink的一个即将发布的版本,我们也在研究可 query状态用例的通用解决方案。这将允许 query任何内部操作的状态。

另外,在您的例子中,使用窗口操作周期性地将值输出到Elasticsearch之类的东西也就足够了。结果可以简单地从Elasticsearch中 query出来。


0

在下一个版本中,他们将提供一个名为Queryable State的现成解决方案。

但我建议你应该先多读一读,然后再看例子。


我来回答

写文章

提问题

面试题