Hi Joris,
I don't think that the approach of "add methods in operator class code that
can be called from the main Flink program" will work.
The most efficient approach would be implementing a ProcessFunction that
counts in 1-min time buckets (using event-time semantics) and updates the
metrics.
I
Hi,
We want to collect metrics for stream processing, typically counts aggregated
over 1-minute buckets. However, we want these 1-minute boundaries determined by
timestamps within the data records. Flink metrics do not handle this so we want
to roll our own. How to proceed ? Some of our team me
