Apache Flinkからのデータの照会

Question

自宅でストリーミングするサーバーからApache Flinkに移行する予定です。私たちが持っていることの1つは、処理トポロジで保持されている状態に対してクエリを実行するためのDRPCインターフェイスのようなApache Stormです。

したがって、たとえば：移動平均を実行しているセンサーがたくさんあります。私は、トポロジに関するクエリを実行して、その平均値が固定値を上回るすべてのセンサを返したいとします。

同等の機能がFlinkに存在するか、そうでない場合、同等の機能を実現する最善の方法は何ですか？

Answer 1

すぐに使用できるFlinkには、今すぐ内部操作の状態を照会するためのソリューションはありません。しかし、2つの解決策があるので、あなたは幸いです。ステートフルな単語カウントの例を使って、状態を照会することができます。これは次のサイトから入手できます：https://github.com/dataArtisans/query-window-example

今後のバージョンのFlinkでは、クエリ可能な状態のユースケースに対する一般的な解決策も検討中です。これにより、内部操作の状態を照会することができます。

また、ウィンドウ操作を使用して、Elasticsearchなどの値に定期的に値を出力するだけでもかまいません。その結果は、単にElasticsearchから照会することができます。

Answer 2

次回リリースでは、クエリ可能状態と呼ばれるすぐに使用できるソリューションが提供されています。 はここに例
https://github.com/apache/flink/blob/master/flink-tests/src/test/java/org/apache/flink/test/query/QueryableStateITCase.java

あるしかし、私は、あなたがそれをよりまず例を参照してくださいについてお読みください示唆しています。