请问flink的将mongodb的数据作为datasource的代码用scala实现怎么写？

（用java来实现也可以）

http://www.manongjc.com/article/32361.html

看看这个

你这个主要是sink,我想要的是mongodb作为datasource.

是flink读取MongoDB的数据吗

是，flink读取MongoDB的数据，然后做sink处理。