Riak simple SearchMapReduce arroja IOException

Question

Estoy intentando buscar objetos de Raik usando filtros simples. He habilitado la búsqueda en el depósito antes de almacenar objetos en él, e intento lo siguiente:

Resultado MapReduceResult = riakClient. mapReduce ("serviceProvider", "name: oved1"). addMapPhase (nueva NamedJSFunction ("Riak.mapValuesJson"), verdadera) .execute ();

Obtengo esta excepción:

com.basho.riak.client.RiakException: java.io.IOException: {"error": "map_reduce_error"} en com.basho.riak.client.query.MapReduce.execute (MapReduce.java:80) en com.att .cso.omss.datastore.riak.controllers.RiakBaseController.getAllServiceProvider (RiakBaseController.java:339) en com.att.cso.omss.datastore.riak.App.serviceProviderTests (App.java:64) en com.att.cso .omss.datastore.riak.App.main (App.java:38) Causado por: java.io.IOException: {"error": "map_reduce_error"} en com.basho.riak.client.raw.http.ConversionUtil. convert (ConversionUtil.java:588) en com.basho.riak.client.raw.http.HTTPClientAdapter.mapReduce (HTTPClientAdapter.java:386) en com.basho.riak.client.query.MapReduce.execute (MapReduce.java: 78) ... 3 más

¿Alguna idea de lo que me estoy perdiendo?

Answer 1

Pude solucionar este problema ...

aparentemente, debe hacer dos cosas antes de almacenar objetos que deben ser buscados en el futuro:

1. Habilitado la búsqueda en app.config (/ etc / riak):

{riak_search, [{enabled, true}]}

1. Habilitar la búsqueda en el cubo

Bucket bucket = riakClient.createBucket (bucketName) .enableForSearch (). Execute ();

Después de hacer eso, esto devuelve valores:

      MapReduceResult result = riakClient.
            mapReduce(bucketName, "name:9"). 
            addMapPhase(new NamedJSFunction("Riak.mapValuesJson"), true).
            execute();