spark流到mongodb

j8ag8udp  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(371)

我通过apachespark流访问apachekafka的数据,所以我想将数据存储在 MongoDB 那我怎么才能把它储存起来呢 mongoDB ?

fdbelqdn

fdbelqdn1#

输出操作非常有限,但是您可以始终使用 foreachRDD() 在此时间范围内,您可以访问任何已处理的rdd。因此,任何自定义逻辑都可以放在这里,即让到mongodb的连接显式执行简单的插入/更新操作。

相关问题