com.basho.riak.client.query
Class SearchMapReduce

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

All Implemented Interfaces:

RiakOperation<MapReduceResult>

public class SearchMapReduce
extends MapReduce

A MapReduce operation that uses a Riak Search query as input. See Riak Search on the basho wiki for more information.

Author:

russell

Constructor Summary

SearchMapReduce(RawClient client, String bucket, String query)
Create a map/reduce using a riak search query as input

Method Summary

String	getBucket()
String	getQuery()
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

SearchMapReduce

public SearchMapReduce(RawClient client,
                       String bucket,
                       String query)

Create a map/reduce using a riak search query as input

Parameters:

client - the RawClient to execute the m/r job

bucket - the search indexed bucket

query - the search query

Method Detail

getBucket

public String getBucket()

Returns:

the bucket

getQuery

public String getQuery()

Returns:

the query

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