Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Tweak M/R tests

Browse Source
This commit is contained in:
J. Brisbin
2010-11-29 13:38:23 -06:00
parent f8e471cf34
commit 07d2703e69
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-data-riak/src/test/groovy/org/springframework/data/riak/core/RiakTemplateSpec.groovy
View File

@@ -182,15 +182,16 @@ class RiakTemplateSpec extends Specification {
given:
MapReduceJob job = riak.createMapReduceJob()
def mapJs = new JavascriptMapReduceOperation("function(v){ return [1]; }")
def mapJs = new JavascriptMapReduceOperation("function(m){ return [1]; }")
def mapPhase = new RiakMapReducePhase("map", "javascript", mapJs)
def reduceJs = new JavascriptMapReduceOperation("function(v){ return [v.length]; }")
def reduceJs = new JavascriptMapReduceOperation("function(r){ return [1]; }")
def reducePhase = new RiakMapReducePhase("reduce", "javascript", reduceJs)
job.addInputs(["test"]).
addPhase(mapPhase).
addPhase(reducePhase)
println job.toJson()
when:
def result = riak.execute(job, Integer)
@@ -204,10 +205,10 @@ class RiakTemplateSpec extends Specification {
given:
MapReduceJob job = riak.createMapReduceJob()
def mapJs = new JavascriptMapReduceOperation("function(v){ return [1]; }")
def mapJs = new JavascriptMapReduceOperation("function(m){ return [1]; }")
def mapPhase = new RiakMapReducePhase("map", "javascript", mapJs)
def reduceJs = new JavascriptMapReduceOperation("function(v){ return [v.length]; }")
def reduceJs = new JavascriptMapReduceOperation("function(r){ return [1]; }")
def reducePhase = new RiakMapReducePhase("reduce", "javascript", reduceJs)
job.addInputs(["test"]).