org.springframework.data.keyvalue.riak.mapreduce
Class RiakMapReduceJob

java.lang.Object
  org.springframework.data.keyvalue.riak.mapreduce.AbstractRiakMapReduceJob
      org.springframework.data.keyvalue.riak.mapreduce.RiakMapReduceJob

All Implemented Interfaces:

Callable, MapReduceJob

public class RiakMapReduceJob
extends AbstractRiakMapReduceJob

An implementation of MapReduceJob for the Riak data store.

Author:

J. Brisbin

Field Summary

protected RiakTemplate

riakTemplate

Fields inherited from class org.springframework.data.keyvalue.riak.mapreduce.AbstractRiakMapReduceJob

inputs, log, phases

Constructor Summary

RiakMapReduceJob(RiakTemplate riakTemplate)

Method Summary

Object	call()
RiakTemplate	getRiakTemplate()
void	setRiakTemplate(RiakTemplate riakTemplate)

Methods inherited from class org.springframework.data.keyvalue.riak.mapreduce.AbstractRiakMapReduceJob

addInputs, addPhase, getInputs, getPhases, toJson

Methods inherited from class java.lang.Object

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

Field Detail

riakTemplate

protected RiakTemplate riakTemplate

Constructor Detail

RiakMapReduceJob

public RiakMapReduceJob(RiakTemplate riakTemplate)

Method Detail

getRiakTemplate

public RiakTemplate getRiakTemplate()

setRiakTemplate

public void setRiakTemplate(RiakTemplate riakTemplate)

call

public Object call()
            throws Exception

Throws:

Exception