I have one stream is going to store the state, and I hope another stream can retrieve the state. Is this possible?
I have tried in my unit test that seems like doesn't work.
I have one stream is going to store the state, and I hope another stream can retrieve the state. Is this possible?
I have tried in my unit test that seems like doesn't work.
It is currently not possible that different streams share state. Even different operators which belong to the same stream are not able to share state.
The only thing you could play with is to use static fields to share state across different threads and thus also streams. But this only works if different tasks are executed by the same TaskManager
and, thus, run in the same JVM.
Depending on how you need to use the state, it might be possible to leverage queryable state to share it with another stream.