無法使用地圖減少與riak

我是新的Riak，所以請原諒我的錯誤理解。無法使用地圖減少與riak

我能夠添加新條目並按鍵和索引執行查詢。但是我必須實現更復雜的查詢，所以我試圖使用MapReduce。

我有我的應用程序級實體命名Volume，對於現在只有簡單的領域：

public class Volume implements Comparable<Volume>, Serializable { 
    @RiakIndex(name = "id") 
    @JsonProperty("id") 
    private Integer id; 

    @RiakIndex(name = "name") 
    @RiakKey 
    private String name; 

    @RiakIndex(name = "created_at") 
    @JsonProperty("created_at") 
    private long createdAt; 


    // setters, getters.... 
}

這是我如何添加Volume實例了Riak數據庫：

IRiakClient riakClient = RiakFactory.httpClient(); 
Bucket bucket = riakClient.fetchBucket(bucketName).execute(); 
for (int i = 0; i < n; i++) { 
    int id = i; 
    ManagedVolume volume = new ManagedVolume(); 
    volume.setCreatedAt(System.currentTimeMillis()); 
    volume.setId(id); 
    volume.setName("volume" + i); 
    bucket.store(volume).execute(); 
}

現在我可以檢索沒有像以下任何問題的實例。

Collection<String> col = backet.fetchIndex(IntIndex.named("id")).from(3).to(5).execute();

但所有嘗試使用MapReduce失敗：

String str = riakClient.mapReduce(bucketName, "name: volume1") 
    .addMapPhase(new NamedJSFunction("Riak.mapValuesJson")). 
    execute().getResultRaw();

我試圖做到這一點無需添加Riak.mapValuesJson，試圖修改查詢中使用id而不是name和包裹volume`` with quotes (「名稱：\」音量\「」,「name：\'volume \'」etc.) but nothing helps. I always get HTTP status 500 and the following error: {「error」：「map_reduce_error」}'

在這裏我們堆棧跟蹤：

Exception in thread "main" com.basho.riak.client.RiakException: java.io.IOException: {"error":"map_reduce_error"} 
    at com.basho.riak.client.query.MapReduce.execute(MapReduce.java:81) 
    at com.infinidat.riak.TryRiak.search(TryRiak.java:288) 
    at com.infinidat.riak.TryRiak.main(TryRiak.java:66) 
Caused by: java.io.IOException: {"error":"map_reduce_error"} 
    at com.basho.riak.client.raw.http.ConversionUtil.convert(ConversionUtil.java:589) 
    at com.basho.riak.client.raw.http.HTTPClientAdapter.mapReduce(HTTPClientAdapter.java:386) 
    at com.basho.riak.client.query.MapReduce.execute(MapReduce.java:79) 
    ... 2 more

我在Riak的error.log和console.log中發現了以下記錄。

2013-07-23 19:14:12.451 [error] <0.194.0> Supervisor riak_pipe_builder_sup had child undefined started with {riak_pipe_builder,start_link,undefined} at <0.18058.4> exit with reason {{modfun,riak_search,mapred_search,[<<"VolumeBucket">>,<<"name: 1">>]},error,badarg,[{ets,lookup,[schema_table,<<"VolumeBucket">>],[]},{riak_search_config,get_schema,1,[{file,"src/riak_search_config.erl"},{line,69}]},{riak_search_client,parse_query,3,[{file,"src/riak_search_client.erl"},{line,40}]},{riak_search,parse_query,3,[{file,"src/riak_search.erl"},{line,59}]},{riak_search,mapred_search,3,[{file,"src/riak_search.erl"},{line,46}]},{riak_kv_mrc_pipe,send_inputs,3,[{file,"src/riak_kv_mrc..."},...]},...]} in context child_terminated

我相信我在這裏失去了一些東西。可能是配置問題？這是一個非常簡單的查詢。一旦這個工作正常，我顯然希望向更復雜的查詢前進。

來源

2013-07-23 AlexR

您的mapreduce作業指定a Riak Search query as input，如果您的羣集中沒有Riak Search enabled，則這將失敗。在the Java client documentation中有一些示例可以顯示如何指定不同類型的輸入。儘管如此，Riak MapReduce並沒有被設計成一個實時查詢工具，所以我不確定它是否是您正在嘗試完成的正確工具。與直接鍵值查找相比，由於大量節點/分區需要參與每個請求，因此它會爲系統增加更多的負載。這會導致更高的延遲時間，這也意味着它無法擴展以及直接訪問密鑰。

當Riak和其他鍵值存儲，數據訪問模式和查詢模式的數據建模需要與數據結構一起考慮時，與使用關係模型相比，這是非常不同的。一些博客文章，並在相關了Riak對數據建模演示都可以在這裏：

來源

2013-07-24 15:35:48

無法使用地圖減少與riak

回答

相關問題