大家好,我是mongodb和hadoop的新手。我想写一个mapreduce程序,从hdfs读取输入,并将其输出写入mongodb。我也尝试了MongoHadoop连接器,但在使用连接器时,我不知道如何编写从hdfs获取输入的mapreduce。我只能编写将mongodb用于输入和输出的mapreduce。这将是如果我能得到样本代码或任何参考,更多的帮助-谢谢
nfeuvbwi1#
您可以使用mongodb作为数据的源和目标。因此,可以使用mongodbhadoop连接器将hdfs中的数据加载到mongo中http://docs.mongodb.org/ecosystem/tools/hadoop/您可以在他们的github存储库中找到示例https://github.com/mongodb/mongo-hadoop/tree/master/examples
1条答案
按热度按时间nfeuvbwi1#
您可以使用mongodb作为数据的源和目标。因此,可以使用mongodbhadoop连接器将hdfs中的数据加载到mongo中http://docs.mongodb.org/ecosystem/tools/hadoop/
您可以在他们的github存储库中找到示例https://github.com/mongodb/mongo-hadoop/tree/master/examples