public class SearchMapReduce extends MapReduce
MapReduce
operation that uses a Riak Search query as input.
See
Riak Search
on the basho wiki for more information.Constructor and Description |
---|
SearchMapReduce(RawClient client,
String bucket,
String query)
Create a map/reduce using a riak search query as input
|
Modifier and Type | Method and Description |
---|---|
String |
getBucket() |
String |
getQuery() |
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 String getBucket()
public String getQuery()
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.