com.basho.riak.client.query
Class IndexMapReduce

java.lang.Object
  com.basho.riak.client.query.MapReduce
      com.basho.riak.client.query.IndexMapReduce

All Implemented Interfaces:

RiakOperation<MapReduceResult>

public class IndexMapReduce
extends MapReduce

A MapReduce operation that takes a 2i index query as input

Author:

russell

Constructor Summary

IndexMapReduce(RawClient client, IndexQuery indexQuery)

Method Summary

protected void

writeInput(org.codehaus.jackson.JsonGenerator jsonGenerator) Override to write the input specification of the M/R job.

Methods inherited from class com.basho.riak.client.query.MapReduce

addLinkPhase, addLinkPhase, addMapPhase, addMapPhase, addMapPhase, addMapPhase, addReducePhase, addReducePhase, addReducePhase, addReducePhase, execute, timeout, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IndexMapReduce

public IndexMapReduce(RawClient client,
                      IndexQuery indexQuery)

Parameters:

client -

Method Detail

writeInput

protected void writeInput(org.codehaus.jackson.JsonGenerator jsonGenerator)
                   throws IOException

Description copied from class: MapReduce

Override to write the input specification of the M/R job.

Specified by:

writeInput in class MapReduce

Parameters:

jsonGenerator - a Jackson JsonGenerator to write the input spec to

Throws:

IOException