With an initial `y`, I think you could compute new `y` on new stream value. Upon recovering from checkpoint, may be `KeyedStateBackend.applyToAllKeys` could help you to rebuild an initial `y`.
Best, Kezhu Wang On February 17, 2021 at 13:09:39, Salva Alcántara (salcantara...@gmail.com) wrote: 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/
