從Apache Flink查詢數據

Question

我期待從本地流式服務器遷移到Apache Flink。我們擁有的一件事就是像Apache一樣的DRM界面，以針對處理拓撲中保存的狀態運行查詢。

例如：我有一堆傳感器，我正在運行一個移動平均值。我想在拓撲上運行查詢，並返回所有平均值高於固定值的傳感器。

在Flink中是否存在等價物，或者如果不存在，實現等效功能的最佳方法是什麼？

Answer 1

開箱即用的Flink沒有提供查詢內部操作狀態的解決方案。然而，你很幸運，因爲有兩種解決方案：我們做了一個有狀態字數統計的例子，它允許查詢狀態。這可在這裏：https://github.com/dataArtisans/query-window-example

對於即將到來的Flink版本之一，我們也正在研究可查詢狀態用例的通用解決方案。這將允許查詢任何內部操作的狀態。

另外，在您的情況下，是否可以僅使用窗口操作週期性地將值輸出到像Elasticsearch之類的東西。結果可以簡單地從Elasticsearch中查詢。

Answer 2

他們在下一個版本中使用名爲Queryable State的開箱即用解決方案。 下面是一個例子
https://github.com/apache/flink/blob/master/flink-tests/src/test/java/org/apache/flink/test/query/QueryableStateITCase.java

但我建議你應該閱讀更多關於它的第一次再看到的例子。