org.springframework.data.keyvalue.riak.groovy
Class RiakMapReduceOperation
java.lang.Object
org.springframework.data.keyvalue.riak.groovy.RiakMapReduceOperation
- All Implemented Interfaces:
- Callable
public class RiakMapReduceOperation
- extends Object
- implements Callable
- Author:
- J. Brisbin
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
protected final org.apache.commons.logging.Log log
riak
protected AsyncRiakTemplate riak
job
protected AsyncRiakMapReduceJob job
timeout
protected Long timeout
completed
protected groovy.lang.Closure completed
failed
protected groovy.lang.Closure failed
RiakMapReduceOperation
public RiakMapReduceOperation(AsyncRiakTemplate riak,
AsyncRiakMapReduceJob job)
getJob
public AsyncRiakMapReduceJob getJob()
setJob
public void setJob(AsyncRiakMapReduceJob job)
getTimeout
public Long getTimeout()
setTimeout
public void setTimeout(Long timeout)
getCompleted
public groovy.lang.Closure getCompleted()
setCompleted
public void setCompleted(groovy.lang.Closure completed)
getFailed
public groovy.lang.Closure getFailed()
setFailed
public void setFailed(groovy.lang.Closure failed)
call
public Object call()
throws Exception
- Specified by:
call
in interface Callable
- Throws:
Exception
Copyright © 2010-2011 SpringSource. All Rights Reserved.