I'm also not aware of a MongoDB sink in Flink. The code provided by
Jingsong applies to the "SinkFunction" interface of Flink. That's a good
starting point to implement a custom Sink.
On Wed, May 6, 2020 at 9:46 AM Jingsong Li wrote:
> Hi,
>
> My impression
Hi,
My impression is that MongoDB's API is not complicated. So you can
implement a MongoDB sink. Something like:
@Override
public void invoke(Row value, Context context) throws Exception {
Map map = new HashMap<>();
for (int i = 0; i < fieldNames.length; i++) {
my solution:
First, Flink sinks data to Kafka;
Second, MongoDB reads data from Kafka. Over.
-- --
??: "Aissa Elaffani"
Hello ,
I want to sink my data to MongoDB but as far as I know there is no sink
connector to MongoDB. How can I implement a MongoDB sink ? If there is any
other solutions, I hope you can share with me.
