org.infinispan.distexec.mapreduce

Class MapReduceTask.TaskPart<V>

java.lang.Object

org.infinispan.distexec.mapreduce.MapReduceTask.TaskPart<V>

All Implemented Interfaces:

MapReduceTask.CancellableTaskPart

Direct Known Subclasses:

MapReduceTask.MapTaskPart, MapReduceTask.ReduceTaskPart

Enclosing class:

MapReduceTask<KIn,VIn,KOut,VOut>

private abstract class MapReduceTask.TaskPart<V>
extends java.lang.Object
implements MapReduceTask.CancellableTaskPart

Field Summary

Fields

Modifier and Type	Field and Description
private org.infinispan.remoting.transport.Address	executionTarget
private java.util.concurrent.Future<V>	f

Constructor Summary

Constructors

Constructor and Description
MapReduceTask.TaskPart(org.infinispan.remoting.transport.Address executionTarget)

Method Summary

Methods

Modifier and Type	Method and Description
	attachListener( listener)
boolean	cancel(boolean mayInterruptIfRunning)
abstract void	execute()
V	get()
V	get(long timeout, java.util.concurrent.TimeUnit unit)
protected org.infinispan.remoting.transport.Address	getAddress()
org.infinispan.remoting.transport.Address	getExecutionTarget()
boolean	isCancelled()
boolean	isDone()
protected boolean	locallyExecuted()
void	notifyDone()
private V	retrieveResult(java.lang.Object response)
void	setNetworkFuture(java.util.concurrent.Future<V> future)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.distexec.mapreduce.MapReduceTask.CancellableTaskPart

getUUID

Field Detail

f

private java.util.concurrent.Future<V> f

executionTarget

private final org.infinispan.remoting.transport.Address executionTarget

Constructor Detail

MapReduceTask.TaskPart

public MapReduceTask.TaskPart(org.infinispan.remoting.transport.Address executionTarget)

Method Detail

getExecutionTarget

public org.infinispan.remoting.transport.Address getExecutionTarget()

Specified by:

getExecutionTarget in interface MapReduceTask.CancellableTaskPart

attachListener

public  attachListener( listener)

cancel

public boolean cancel(boolean mayInterruptIfRunning)

isCancelled

public boolean isCancelled()

isDone

public boolean isDone()

get

public V get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

getAddress

protected org.infinispan.remoting.transport.Address getAddress()

locallyExecuted

protected boolean locallyExecuted()

execute

public abstract void execute()

retrieveResult

private V retrieveResult(java.lang.Object response)
                  throws java.util.concurrent.ExecutionException

Throws:

java.util.concurrent.ExecutionException

get

public V get(long timeout,
    java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

notifyDone

public void notifyDone()

setNetworkFuture

public void setNetworkFuture(java.util.concurrent.Future<V> future)