我通过apachespark流访问apachekafka的数据,所以我想将数据存储在 MongoDB 那我怎么才能把它储存起来呢 mongoDB ?
MongoDB
mongoDB
fdbelqdn1#
输出操作非常有限,但是您可以始终使用 foreachRDD() 在此时间范围内,您可以访问任何已处理的rdd。因此,任何自定义逻辑都可以放在这里,即让到mongodb的连接显式执行简单的插入/更新操作。
foreachRDD()
1条答案
按热度按时间fdbelqdn1#
输出操作非常有限,但是您可以始终使用
foreachRDD()
在此时间范围内,您可以访问任何已处理的rdd。因此,任何自定义逻辑都可以放在这里,即让到mongodb的连接显式执行简单的插入/更新操作。