Hi:
I am working on a Flink application and need to collect the number of events of
certain type/second (per unit of time) as a metric. I was hoping to use
Flink's metric framework with a gauge but did not find any implementation that
will reset the count after it is reported.
The example:
https://ci.apache.org/projects/flink/flink-docs-release-1.8/monitoring/metrics.html#gauge
shows how to use a gauge but does not reset the gauge after the metrics
framework has reported the value every at the specified interval. So, unless
it is reset by the application (after the call to getValue), it will continue
to increment.
I was wondering if there is any resettable gauge implementation available that
integrates with the Flink metrics framework.
Please let me know if there are any advice/pointers.
Thanks
Mans