Package | Description |
---|---|
com.basho.riak.pbc.mapreduce |
The legacy, low-level Protocol Buffers query classes for Map Reduce.
|
Modifier and Type | Method and Description |
---|---|
MapReduceBuilder |
MapReduceBuilder.link(String bucket,
boolean keep)
Adds a link phase to the job
|
MapReduceBuilder |
MapReduceBuilder.link(String bucket,
String tag,
boolean keep)
Adds a link phase to the job
|
MapReduceBuilder |
MapReduceBuilder.map(MapReduceFunction function,
boolean keep)
Adds a map phase to the job
|
MapReduceBuilder |
MapReduceBuilder.map(MapReduceFunction function,
Object arg,
boolean keep)
Adds a map phase to the job
|
MapReduceBuilder |
MapReduceBuilder.reduce(MapReduceFunction function,
boolean keep)
Adds a reduce phase to the job
|
MapReduceBuilder |
MapReduceBuilder.reduce(MapReduceFunction function,
Object arg,
boolean keep)
Adds a reduce phase to the job
|
MapReduceBuilder |
MapReduceBuilder.setBucket(String newBucket)
Sets the name of the Riak bucket the map/reduce job will process
|
MapReduceBuilder |
MapReduceBuilder.setRiakClient(RiakClient client) |
MapReduceBuilder |
MapReduceBuilder.setRiakObjects(Collection<RiakObject> objects) |
MapReduceBuilder |
MapReduceBuilder.setRiakObjects(Map<String,Set<String>> objects)
Sets a collection of Riak object (bucket name/key pair) as the map/reduce
job as inputs
|
MapReduceBuilder |
MapReduceBuilder.setSearch(String search)
Sets the name of the Riak bucket that will be searched and the query that
will be executed
|
Copyright © 2014. All Rights Reserved.