public class IndexMapReduce extends MapReduce
MapReduce
operation that takes a 2i index query as inputConstructor and Description |
---|
IndexMapReduce(RawClient client,
IndexQuery indexQuery) |
Modifier and Type | Method and Description |
---|---|
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 IndexMapReduce(RawClient client, IndexQuery indexQuery)
client
- 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 © 2014. All Rights Reserved.