0

単純なフィルターを使用して Raik オブジェクトを取得しようとしています。オブジェクトをバケットに保存する前にバケットで検索を有効にして、次のことを試しました。

MapReduceResult 結果 = riakClient. mapReduce("サービスプロバイダー", "名前:oved1"). addMapPhase(new NamedJSFunction("Riak.mapValuesJson"), true).execute();

私はこの例外を受け取ります:

com.basho.riak.client.RiakException: java.io.IOException: {"error":"map_reduce_error"} com.basho.riak.client.query.MapReduce.execute(MapReduce.java:80) で com.att .cso.omss.datastore.riak.controllers.RiakBaseController.getAllServiceProvider(RiakBaseController.java:339) com.att.cso.omss.datastore.riak.App.serviceProviderTests(App.java:64) com.att.cso .omss.datastore.riak.App.main(App.java:38) 原因: java.io.IOException: {"error":"map_reduce_error"} at com.basho.riak.client.raw.http.ConversionUtil. convert(ConversionUtil.java:588) で com.basho.riak.client.raw.http.HTTPClientAdapter.mapReduce(HTTPClientAdapter.java:386) で com.basho.riak.client.query.MapReduce.execute(MapReduce.java: 78) ... 3 つ以上

私は何が欠けているのですか？

4

1 に答える 1

1

この問題を修正できました...

明らかに、将来検索する必要があるオブジェクトを保存する前に、次の 2 つのことを行う必要があります。

  1. app.config (/etc/riak) で有効な検索:

{riak_search, [{enabled, true}]}

  1. バケットで検索を有効にします。

バケット バケット = riakClient.createBucket(バケット名).enableForSearch().execute();

それを行った後、これは値を返します：

      MapReduceResult result = riakClient.
            mapReduce(bucketName, "name:9"). 
            addMapPhase(new NamedJSFunction("Riak.mapValuesJson"), true).
            execute();
于 2012-08-16T07:21:59.293 に答える