我正在寻找从一个国产流媒体服务器迁移到apache flink。我们有一个类似于apachestorm的drpc接口，可以针对处理拓扑中的状态运行查询。举个例子：我有一堆传感器，我正在运行移动平均线。我想在拓扑上运行一个查询，并返回平均值高于固定值的所有传感器。flink中是否有等效的功能，如果没有，实现等效功能的最佳方法是什么？
daupos2t1#
在下一个版本中，他们将提供一个名为queryable state的现成解决方案。下面是一个例子https://github.com/apache/flink/blob/master/flink-tests/src/test/java/org/apache/flink/test/query/queryablestateitcase.java但我建议你应该先多读一读，然后再看例子。
xjreopfe2#
现成的flink现在没有提供查询操作内部状态的解决方案。不过，您很幸运，因为有两种解决方案：我们做了一个允许查询状态的有状态字数示例。可在以下位置获取：https://github.com/dataartisans/query-window-example对于flink的一个即将发布的版本，我们也在研究可查询状态用例的通用解决方案。这将允许查询任何内部操作的状态。另外，在您的例子中，使用窗口操作周期性地将值输出到elasticsearch之类的东西也就足够了。结果可以简单地从elasticsearch中查询出来。
2条答案
按热度按时间daupos2t1#
在下一个版本中，他们将提供一个名为queryable state的现成解决方案。下面是一个例子
https://github.com/apache/flink/blob/master/flink-tests/src/test/java/org/apache/flink/test/query/queryablestateitcase.java
但我建议你应该先多读一读，然后再看例子。
xjreopfe2#
现成的flink现在没有提供查询操作内部状态的解决方案。不过，您很幸运，因为有两种解决方案：我们做了一个允许查询状态的有状态字数示例。可在以下位置获取：https://github.com/dataartisans/query-window-example
对于flink的一个即将发布的版本，我们也在研究可查询状态用例的通用解决方案。这将允许查询任何内部操作的状态。
另外，在您的例子中，使用窗口操作周期性地将值输出到elasticsearch之类的东西也就足够了。结果可以简单地从elasticsearch中查询出来。