I am looking for a way to access streaming engine state (Flink) in my beam transformations. I understand this can be accessed only though the runtime context. Has any one tried accessing flink runtime context in beam? May be roll it up as a custom API of some sort. Might need some changes in FlinkRunner is my hunch.
Thanks, Aparup
