riak1

public static boolean fetchAll(String bucket, Collection<String> keys,
            StringBuilder response)
    {
        PBClientConfig conf = new PBClientConfig.Builder()
                        .withHost("127.0.0.1")
                        .withPort(8091)
                        .build();
        try
        {

            IRiakClient iriakClient = RiakFactory.newClient(conf);

            BucketKeyMapReduce reduce = iriakClient.mapReduce();
            while (valuesIter.hasNext())
            {
                String value = valuesIter.next();
                reduce.addInput(bucket, value);
            }
            MapReduceResult result = reduce.execute();
            .... // code to send the result to caller
        }....