Hi, I have a stream which starts from a source and is keyed by a field f. With the stream process function, I can emit the processed record downstream and also update state based on the records it received for the same key.
Now I have another stream which starts from another source and is of the same type as the first stream and it is also keyed by the same field f. In its process function I want to access the last state updated by the first stream's process function for the same key, do some processing (update the state) and also send the record downstream. Is there any way I can achieve this in Flink by connecting to the same state store ? Is there any concept of global state in Flink if I cannot achieve this by using keyed states associated with an operator's process function ? Any other way you can think of achieving the same ? Thanks Sachin
