在 RIAK 上获取 MapReduce 结果（使用 Java 客户端）

Question

我在 RIAK 上存储 Person POJO（4 个字符串字段 - id、name、lastUpdate、Data），然后尝试使用 MapReduce 获取这些对象。

我的做法与 Basho 文档非常相似：

    BucketMapReduce m = riakClient.mapReduce("person");
    m.addMapPhase(new NamedJSFunction("Riak.mapByFields"), true);
    MapReduceResult result = m.execute();
    Collection<Person> tmp = result.getResult(Person.class);

调用了 Person 的 String 构造函数：

public Person(String str){}

（我必须有这个构造函数，否则我会因为它丢失而出现异常） 在那里，我将对象作为字符串 - 一个字符串中的对象字段带有一个奇怪的分隔符。

为什么我没有将对象自动转换为我的 POJO？我真的需要遍历字符串并反序列化它吗？我做错了什么吗？s

Answer 1

您正在使用的 JS 函数并没有按照您的想法执行 :) 它基于具有特定值的字段选择对象，您必须将其作为参数提供给阶段。

我认为您正在寻找的是mapValuesJson，它将完成您似乎想做的事情。

此外，您的 POJO 中根本不需要构造函数。

下面的代码应该为您指明正确的方向（显然这是超级简单的，POJO 中的所有公共字段都没有注释）：

public class App {

    public static void main( String[] args ) throws IOException, RiakException
    {
        IRiakClient client = RiakFactory.httpClient();
        Bucket b = client.fetchBucket("test_mr").execute();

        b.store("myobject", new Person()).execute();
        IRiakObject o = b.fetch("myobject").execute();
        System.out.println(o.getValueAsString());


        BucketMapReduce m = client.mapReduce("test_mr");
        m.addMapPhase(new NamedJSFunction("Riak.mapValuesJson"), true);
        MapReduceResult result = m.execute();
        System.out.println(result.getResultRaw());
        Collection<Person> tmp = result.getResult(Person.class);

        for (Person p : tmp)
        {
            System.out.println(p.data);
        }


        client.shutdown();
    }
}

class Person 
{
    public String id = "12345";
    public String name = "my name";
    public String lastUpdate = "some time";
    public String data = "some data";


}