I wonder what is the canonical way to accomplish the following: Given a Flink UDF, how to report a metric `y` which is a function of some (keyed) state `X`? That is, `y=f(X)`. Most commonly, we are interested in the size of the state X.
For instance, consider a `CoFlatMap` function with: - `X` being a `MapState` - `y` (the metric) consisting of the aggregated size (i.e., the total size of the `MapState`, for all keys) -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/