Hi.
If you can cache the data i state it’s the preferred way. Then you read all you
values from a store do a key by and store them in state in a coprocessfunction.
If you need to do a lookup for every row you have to use the AsyncIO function
Med venlig hilsen / Best regards
Lasse Nedergaard
>
The Open method would be a great! And close method could close it when
operator closes!
Also for external calls AsyncIO is a great operator. Give that a look.
Regards,
Taher Koitawala
On Sat, May 30, 2020, 10:17 PM Aissa Elaffani
wrote:
> Hello Guys,
> I want to enrich a data stream with some
Hello Guys,
I want to enrich a data stream with some mongoDB data, and I am willing to
use the RichFlatMapFunction, and I am lost , i don't know where to
configure the connection with my MongoDB. Can anyone Help me in this ?
Best,
Aissa
