Spring Data Key-Value

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

java.lang.Object
  extended by org.springframework.data.keyvalue.riak.mapreduce.AbstractRiakMapReduceJob
      extended by 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 <[email protected]>

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

Spring Data Key-Value

Copyright © 2010-2011 SpringSource. All Rights Reserved.