Hi Abhishek, state can be emitted from funtions as regular records. There is no way to share state the local state of a task with other tasks of the same operator or with other operators. Flink's key-partitioned state is always scoped to the key of the current record. It is not possible to iterate over all local state. If your function implements the Checkpointed interface, you have one state object for the whole function. In this case, you can see all local state. However, the Checkpointed functions have the limitation that they cannot be rescaled.
Best, Fabian 2017-01-08 17:01 GMT+01:00 abhishekrs <abhis...@tetrationanalytics.com>: > Hi Stephan, > > I want to pursue your idea. How do I emit state from an operator. Operator > for me is a rich function. Or will I need a different style operator? I am > unable to find how to iterate over all state - in open or otherwise (from > an > operator). > > Are there APIs to inspect the savepoints - using offline programs? > > -Abhishek- > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Changing- > parallelism-tp4967p10911.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
