如何用Spark的Mongo-Hadoop连接器删除文档（记录）

我正在使用Mongo-Hadoop连接器来使用Spark和MongoDB.I想从MongoDB中删除RDD中的文档，看起来有一个MongoUpdateWritable to支持文档更新。有没有办法使用Mongo-Hadoop连接器进行删除？如何用Spark的Mongo-Hadoop连接器删除文档（记录）

感谢

来源

2016-09-14 Tom

如果你只想在RDD删除记录使用Spark API的功能，如地图，减少过滤器...

如果你想保存后的结果，使用MongoUpdateWriteble 。

看看基础知识：Mongo-Hadoop-Spark

来源

2016-09-14 07:59:22

感谢@Cristu的答复。我想要做的是从MongoDB中删除包含在RDD中的文档（RDD中的BSON对象用作查询来查找MongoDB中的文档）。看起来Mongo-Hadoop-Spark不支持这一点。你的意思是我自己写删除逻辑吗？ – Tom

不客气！如果您提供了一个代码示例，也许我可以帮助您在需要时进行编码。 –

谢谢@Cristu，我可以使用Mongo-Hadoop-Spark做文档插入和更新，但是我没有找到如何删除它。所以我问我是否需要编写自己的逻辑来删除。 – Tom

如何用Spark的Mongo-Hadoop连接器删除文档（记录）

回答

相关问题