KeyBy State

[Govindarajan Srinivasaraghavan]

Hi,

I have a keyby state but the key can change quite frequently for the same user and I need the previous keyBy state value for the user if there is a key change. 

Right now I'm using redis cache for the global state. Is there a way to achieve this within flink?

[Fabian Hueske-2]

Hi,

there is no built-in support for key changes.
You might be able to feedback a changed key with an iteration edge, but not sure how well that works.

Best, Fabian

2017-08-01 7:32 GMT+02:00 Govindarajan Srinivasaraghavan <[hidden email]>:

Hi,

I have a keyby state but the key can change quite frequently for the same user and I need the previous keyBy state value for the user if there is a key change. 

Right now I'm using redis cache for the global state. Is there a way to achieve this within flink?