From 7e08fafd49c8e12b928c36744a86d58e4d92a61d Mon Sep 17 00:00:00 2001 From: "J. Brisbin" Date: Tue, 23 Nov 2010 14:01:35 -0600 Subject: [PATCH] Change test spec to return array from reduce phase --- .../datastore/riak/core/RiakTemplateSpec.groovy | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/spring-datastore-riak/src/test/groovy/org/springframework/datastore/riak/core/RiakTemplateSpec.groovy b/spring-datastore-riak/src/test/groovy/org/springframework/datastore/riak/core/RiakTemplateSpec.groovy index b309851f5..76d74d083 100644 --- a/spring-datastore-riak/src/test/groovy/org/springframework/datastore/riak/core/RiakTemplateSpec.groovy +++ b/spring-datastore-riak/src/test/groovy/org/springframework/datastore/riak/core/RiakTemplateSpec.groovy @@ -160,10 +160,10 @@ class RiakTemplateSpec extends Specification { given: MapReduceJob job = riak.createMapReduceJob() - def mapJs = new JavascriptMapReduceOperation("function(v){ var o=Riak.mapValuesJson(v); return [o[0].integer]; }") + def mapJs = new JavascriptMapReduceOperation("function(v){ ejsLog('/tmp/mapred.log', 'map='+JSON.stringify(v)); var o=Riak.mapValuesJson(v); return [1]; }") def mapPhase = new RiakMapReducePhase("map", "javascript", mapJs) - def reduceJs = new JavascriptMapReduceOperation("function(v){ return v.length; }") + def reduceJs = new JavascriptMapReduceOperation("function(v){ ejsLog('/tmp/mapred.log', 'reduce='+JSON.stringify(v)); return [v.length]; }") def reducePhase = new RiakMapReducePhase("reduce", "javascript", reduceJs) job.addInputs(["test"]). @@ -172,10 +172,11 @@ class RiakTemplateSpec extends Specification { when: println "M/R: ${job.toJson()}" - def result = riak.execute(job, Integer) + def result = riak.execute(job, List) then: - 1 == result + 1 == result.size() + 1 == result[0] }