Hi! For this use case it seems that we'll either have to use a custom connector for that external database (if currently there is no such connector in Flink), or have to first read the data into some other sources supported by Flink.
Sweta Kalakuntla <[email protected]> 于2021年7月21日周三 上午10:39写道： > 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 <[email protected]> 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 <[email protected]> 于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 >>> >>
