MongoDB as a Sink;

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

MongoDB as a Sink;

Aissa Elaffani
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 ?
Reply | Threaded
Open this post in threaded view
|

Re: MongoDB as a Sink;

Aljoscha Krettek
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 ?
>