org.infinispan.distexec.mapreduce

Class MapReduceTask.ReduceTaskPart<V>

java.lang.Object

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

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

All Implemented Interfaces:

java.util.concurrent.Future<V>, NotifyingFuture<V>, NotifyingNotifiableFuture<V>, MapReduceTask.CancellableTaskPart

Enclosing class:

MapReduceTask<KIn,VIn,KOut,VOut>

private class MapReduceTask.ReduceTaskPart<V>
extends MapReduceTask.TaskPart<V>

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	cacheName
private org.infinispan.commands.read.ReduceCommand<KOut,VOut>	rc

Constructor Summary

Constructors

Constructor and Description
MapReduceTask.ReduceTaskPart(org.infinispan.remoting.transport.Address executionTarget, org.infinispan.commands.read.ReduceCommand<KOut,VOut> command, java.lang.String destinationCacheName)

Method Summary

Methods

Modifier and Type	Method and Description
void	execute()
java.util.UUID	getUUID()
private java.util.Map<KOut,VOut>	invokeReduceLocally(Cache<java.lang.Object,java.lang.Object> dstCache)

Methods inherited from class org.infinispan.distexec.mapreduce.MapReduceTask.TaskPart

attachListener, cancel, get, get, getAddress, getExecutionTarget, isCancelled, isDone, locallyExecuted, notifyDone, notifyException, setFuture

Methods inherited from class java.lang.Object

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

Field Detail

rc

private final org.infinispan.commands.read.ReduceCommand<KOut,VOut> rc

cacheName

private final java.lang.String cacheName

Constructor Detail

MapReduceTask.ReduceTaskPart

public MapReduceTask.ReduceTaskPart(org.infinispan.remoting.transport.Address executionTarget,
                            org.infinispan.commands.read.ReduceCommand<KOut,VOut> command,
                            java.lang.String destinationCacheName)

Method Detail

execute

public void execute()

Specified by:

execute in class MapReduceTask.TaskPart<V>

invokeReduceLocally

private java.util.Map<KOut,VOut> invokeReduceLocally(Cache<java.lang.Object,java.lang.Object> dstCache)

getUUID

public java.util.UUID getUUID()