Hadoop mapreduce on MongoDB using java

Question

我正在研究一个具有树结构的MongoDB结构..如此链接所示（见文档）

我想知道地图方法中的键中将传递什么。它是树中最顶层的父级吗，我应该迭代以获取我的值列表。

我有一个树结构，以公司为父级，公司名称，网站，产品等作为子级。产品将依次将产品名称作为其子项。

那么，如果我需要公司名称作为密钥，我应该如何使用 java 获取它？

这里的关键是什么 - 公司？

如果有任何示例程序或文档可以在java中通过mongoDB进行mapreduce，任何人都可以尽快提供我吗？

谢谢

Answer 1

谢谢特丽莎。上面的链接正在执行MongoDB中可用的内置地图缩减。我想要一个使用Hadoop和MongoDB的Map Reduce示例。我终于想通了。

public static class MongoMapper extends
        Mapper<Object, BasicDBObject, Text, BSONWritable> {

    public void map(Object key, BasicDBObject value, Context context)
            throws IOException, InterruptedException {

        //This gives all the documents of the company
        BasicDBObject company = (BasicDBObject) value.get("company");
        // This gets the company name
        name = (String) company.get("name");
        //This gives the phone number 
        phone = (String) company.get("phone");

如果我们需要访问公司的产品列表，我们可以使用 BasicDBList 进行检索

// This will give the list of products and we can use product.get()
// to get the product name and other details. 
BasicDBList product = (BasicDBList) company.get("products");

我提到了这个幻灯片共享链接。

http://www.slideshare.net/spf13/introduction-to-mongodb-and-hadoop