Hi,
yes, that is correct. You need to implement a SinkFunction. For getting
started you can take a look at the Elasticsearch connector because
Elasticsearch and MongoDB are roughly similar in terms of how you work
with them, i.e. they are both key-value stores.
Best,
Aljoscha
On 06.05.20 02:36, Aissa Elaffani wrote:
Hello Guys,
I am looking for some help concerning my flink sink, i want te output to be
stocked in MongoDB database. As far as I know, there is no sink
conector for MongoDB, and I need to implement one by my self, and i don't
know how to do that. Can you please help me in this ?