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

Constructors

Constructor and Description
IndexMapReduce(RawClient client, IndexQuery indexQuery)

Method Summary

Methods

Modifier and Type	Method and Description
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