You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Aissa Elaffani <ai...@gmail.com> on 2020/05/06 00:36:59 UTC

MongoDB as a Sink;

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 ?

Re: MongoDB as a Sink;

Posted by Aljoscha Krettek <al...@apache.org>.

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