Package | Description |
---|---|
com.basho.riak.client.http |
The legacy, low-level HTTP REST RiakClient and associated classes, consider using the high-level
IRiakClient |
com.basho.riak.client.http.request |
Riak request classes for the legacy HTTP REST client, consider using the high-level
IRiakClient |
Modifier and Type | Method and Description |
---|---|
MapReduceBuilder |
RiakClient.mapReduceOverBucket(String bucket) |
MapReduceBuilder |
RiakClient.mapReduceOverObjects(Map<String,Set<String>> objects)
Same as
RiakClient.mapReduceOverBucket(String) , except over a set
of objects instead of a bucket. |
MapReduceBuilder |
RiakClient.mapReduceOverSearch(String bucket,
String search)
Same as
RiakClient.mapReduceOverBucket(String) , except over a
riak-search query instead of a bucket. |
Modifier and Type | Method and Description |
---|---|
MapReduceBuilder |
MapReduceBuilder.keyFilter(MapReduceFilter... filters)
Adds a map phase to the job
|
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 search query the map/reduce job will process
|
Copyright © 2014. All Rights Reserved.