public class BucketMapReduce extends MapReduce implements Iterable<KeyFilter>
IRiakClient.mapReduce(String)
Constructor and Description |
---|
BucketMapReduce(RawClient client,
String bucket)
Create a Map Reduce job over the specified
bucket to be executed by the specified RawClient . |
Modifier and Type | Method and Description |
---|---|
BucketMapReduce |
addKeyFilter(KeyFilter keyFilter)
Add a
KeyFilter to the inputs for the Map/Reduce job |
BucketMapReduce |
addKeyFilters(KeyFilter... keyFilters)
Add one or some
KeyFilter s to this map/reduce operations inputs |
String |
getBucket()
Get the bucket input for the M/R job
|
Iterator<KeyFilter> |
iterator()
Unmodifiable copy iterator view of the list of
KeyFilter s for
this M/R operation. |
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, validate
public BucketMapReduce(RawClient client, String bucket)
bucket
to be executed by the specified RawClient
.
Use IRiakClient.mapReduce(String)
to create your BucketMapReduceclient
- the RawClient
to usebucket
- the input to the M/R jobpublic String getBucket()
public Iterator<KeyFilter> iterator()
KeyFilter
s for
this M/R operation. Does not read or write through to internal
BucketInput state.public BucketMapReduce addKeyFilters(KeyFilter... keyFilters)
KeyFilter
s to this map/reduce operations inputskeyFilters
- var arg of KeyFilter
spublic BucketMapReduce addKeyFilter(KeyFilter keyFilter)
KeyFilter
to the inputs for the Map/Reduce jobkeyFilter
- the KeyFilter
to addprotected 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.