public class BucketKeyMapReduce extends MapReduce implements Iterable<String[]>
IRiakClient.mapReduce()
Constructor and Description |
---|
BucketKeyMapReduce(RawClient client)
The
RawClient to execute the Map/Reduce query
Use IRiakClient.mapReduce() as a factory to create your map/reduce operation. |
Modifier and Type | Method and Description |
---|---|
BucketKeyMapReduce |
addInput(String bucket,
String key)
Add a bucket, key input to the query
|
BucketKeyMapReduce |
addInput(String bucket,
String key,
String keyData)
Add a bucket, key, keydata to the list of inputs for the m/r query
|
Iterator<String[]> |
iterator()
An
UnmodifiableIterator view of the inputs for this Map/Reduce job. |
protected void |
validate()
Check that this map/reduce job is valid
|
protected void |
writeInput(com.fasterxml.jackson.core.JsonGenerator jsonGenerator)
Override to write the input specification of the M/R job.
|
addLinkPhase, addLinkPhase, addMapPhase, addMapPhase, addMapPhase, addMapPhase, addReducePhase, addReducePhase, addReducePhase, addReducePhase, execute, timeout
public BucketKeyMapReduce(RawClient client)
RawClient
to execute the Map/Reduce query
Use IRiakClient.mapReduce()
as a factory to create your map/reduce operation.client
- public BucketKeyMapReduce addInput(String bucket, String key, String keyData)
bucket
- key
- keyData
- public BucketKeyMapReduce addInput(String bucket, String key)
bucket
- key
- public Iterator<String[]> iterator()
UnmodifiableIterator
view of the inputs for this Map/Reduce job.protected void writeInput(com.fasterxml.jackson.core.JsonGenerator jsonGenerator) throws IOException
MapReduce
writeInput
in class MapReduce
jsonGenerator
- a Jackson JsonGenerator
to write the input spec toIOException
Copyright © 2013. All Rights Reserved.