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

Field Summary

protected groovy.lang.Closure	completed
protected groovy.lang.Closure	failed
protected AsyncRiakMapReduceJob	job
protected org.apache.commons.logging.Log	log
protected AsyncRiakTemplate	riak
protected Long	timeout

Constructor Summary

RiakMapReduceOperation(AsyncRiakTemplate riak, AsyncRiakMapReduceJob job)

Method Summary

Object	call()
groovy.lang.Closure	getCompleted()
groovy.lang.Closure	getFailed()
AsyncRiakMapReduceJob	getJob()
Long	getTimeout()
void	setCompleted(groovy.lang.Closure completed)
void	setFailed(groovy.lang.Closure failed)
void	setJob(AsyncRiakMapReduceJob job)
void	setTimeout(Long timeout)

Methods inherited from class java.lang.Object

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

Field Detail

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

Constructor Detail

RiakMapReduceOperation

public RiakMapReduceOperation(AsyncRiakTemplate riak,
                              AsyncRiakMapReduceJob job)

Method Detail

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