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

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

All Implemented Interfaces:

Callable, MapReduceJob

public class AsyncRiakMapReduceJob
extends AbstractRiakMapReduceJob

An implementation of MapReduceJob for the Riak data store.

Author:

J. Brisbin

Field Summary

protected AsyncRiakTemplate

riakTemplate

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

inputs, log, phases

Constructor Summary

AsyncRiakMapReduceJob(AsyncRiakTemplate riakTemplate)

Method Summary

Object	call()
AsyncRiakTemplate	getAsyncRiakTemplate()
void	setAsyncRiakTemplate(AsyncRiakTemplate 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 AsyncRiakTemplate riakTemplate

Constructor Detail

AsyncRiakMapReduceJob

public AsyncRiakMapReduceJob(AsyncRiakTemplate riakTemplate)

Method Detail

getAsyncRiakTemplate

public AsyncRiakTemplate getAsyncRiakTemplate()

setAsyncRiakTemplate

public void setAsyncRiakTemplate(AsyncRiakTemplate riakTemplate)

call

public Object call()
            throws Exception

Throws:

Exception