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

Question

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

我这样做非常相似，芭蕉文档：

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

人的字符串构造函数被调用：

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"; 


}