flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ken Krugler <kkrugler_li...@transpac.com>
Subject Iterating over keys in state backend
Date Thu, 27 Apr 2017 01:02:47 GMT
Is there a way to iterate over all of the key/value entries in the state backend, from within
the operator that’s making use of the same?

E.g. I’ve got a ReducingState, and on a timed interval (inside of the onTimer method) I
need to iterate over all KV state and emit the N “best” entries.

What’s the recommended approach?


— Ken

View raw message