That is my understanding as well, but wanted to confirm. My use case is I need to get additional data from an external database(not Source) for the data I am reading off of Kafka Source and aggregate data for a 10min window for a given key. But I did not want to query for every key in that 10min window but query one time and share data between different keys. Is there any way we can achieve this?
Thanks, Sweta On Mon, Jul 19, 2021 at 11:13 PM JING ZHANG <beyond1...@gmail.com> wrote: > Hi sweta, > State of different keys are isolated with each other. It means, you could > read/write the state of current key in > `ProcessFunction`/`KeyedProcessFunction`/`ProcessWindowFunction`, there is > no possible to read/write state of other keys. > > Would you please describe your business demand, let's see if there is > other way to satisfy the requirement. > > Best, > JING ZHANG > > Sweta Kalakuntla <skalakun...@bandwidth.com> 于2021年7月20日周二 上午5:04写道： > >> Hi, >> >> I need to query the database(not a source but for additional information) >> in ProcessFunction. I want to save the results in a state or some other way >> so that I can use the data for other keys in the same window. What are my >> options? >> >> Thanks, >> sweta >> >
