Implementation of MapReduce over HTTP

[kender-janrain]

Hi there! I've put together an implementation of MapReduce that I'd like to submit. The interface is fairly straight forward, here's an example.

implicit val actorSystem = ActorSystem()
val riakClient = RiakClient(actorSystem, "localhost", 8098)

def src(name: String) = Source.fromInputStream(getClass.getClassLoader.getResourceAsStream(name)).mkString

val result = {
    import RiakMapReduce._
    riakClient.mapReduce(InputBucket("bucket"))
        .map(JsBuiltin("Riak.mapValuesJson"))
        .reduce(JsSource(src("reduce1.js")))
        .map(JsSource(src("map2.js")))
        .reduce(JsSource(src("reduce2.js")))
        .result[List[Int]]
}
println(Await.result(result, 10.seconds))

If you like the interface and the methodology of the implementation, I'd be happy to provide specs as well.

[agemooij]

Hi Kender

First of all, thanks you very much for being the first to submit a pull request for riak-scala-client. I'm a bit busy at the moment but I'll have a look at your code as soon as possible, probably this weekend, and get back to you.