5

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

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

Flink に同等のものはありますか、そうでない場合、同等の機能を実現する最善の方法は何ですか?

4

2 に答える 2

2

次のリリースでは、Queryable State と呼ばれるすぐに使えるソリューションが付属しています。ここに例があり
ます https://github.com/apache/flink/blob/master/flink-tests/src/test/java/org/apache/flink/test/query/QueryableStateITCase.java

しかし、最初にそれについてもっと読んでから、例を見ることをお勧めします。

于 2016-09-07T15:14:03.773 に答える