如何用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連接器刪除文檔（記錄）

回答

相關問題