栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

在RIAK上获取MapReduce结果(使用Java客户端)

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

在RIAK上获取MapReduce结果(使用Java客户端)

您正在使用的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";}


转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/440736.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号