首先要引入mongodb-spark-connector的maven依赖具体的可见這个api网址:,然后基本上就可以按照api上面的内容来进行spark操作了这里面已经有spark读入mongodb数据转化为rdd的操作了。
有一些补充的或许有用(?)的代码放在这里。
假设已经插入下面数据:
使用$set
只更新特定的字段
该例子介绍使用$inc
修改符增加特定值。
该例子介绍使用updateMany
更新符合条件的多个文档
版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。