2016-10-23 15 views
0

私は、多数のファイルを読み込んでそれらをcassandraにスローするためにDataSet APIを使用しています。apache flink DataSetウィンドウアグリゲーション

手順の1つでは、私はたくさんのHTTP要求を出しています。送信する1秒あたりの要求数を知りたいと思います。

Stream APIを使用すると、スライディングウィンドウを使用するとかなり簡単ですが、DataSet APIを使用して同じことを行うにはどうすればよいですか?

答えて

0

Flink's metrics systemをご覧ください。速度、つまり特定のイベントがどのくらいの頻度で発生するかを測定するメーター指標タイプを備えています。

残念ながら、MeterメトリックはまだFlinkリリースには含まれていませんが、現在のマスターブランチ(Flink 1.2 SNAPSHOT)でのみ使用できます。だからあなたはFlinkを自分で作る必要があります。詳細は、documentationを参照してください。

関連する問題