3

我正在使用 Mongo-Hadoop 连接器来处理 Spark 和 MongoDB。我想从 MongoDB 中删除 RDD 中的文档,看起来有一个 MongoUpdateWritable 来支持文档更新。有没有办法使用 Mongo-Hadoop 连接器进行删除?

谢谢

4

1 回答 1

2

如果您只想删除 RDD 中的记录,请使用 Spark API 的功能,例如 map、reduce、filter...

如果您想稍后保存结果,请使用 MongoUpdateWriteble。

查看基础知识:Mongo-Hadoop-Spark

于 2016-09-14T07:59:22.377 回答