org.infinispan.distexec.mapreduce

Class MapReduceTask.MapTaskPart<V>

java.lang.Object

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

org.infinispan.distexec.mapreduce.MapReduceTask.MapTaskPart<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.MapTaskPart<V>
extends MapReduceTask.TaskPart<V>

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	distributedReduce
private org.infinispan.commands.read.MapCombineCommand<KIn,VIn,KOut,VOut>	mcc

Constructor Summary

Constructors

Constructor and Description
MapReduceTask.MapTaskPart(org.infinispan.remoting.transport.Address executionTarget, org.infinispan.commands.read.MapCombineCommand<KIn,VIn,KOut,VOut> command, boolean distributedReduce)

Method Summary

Methods

Modifier and Type	Method and Description
void	execute()
java.util.UUID	getUUID()
private java.util.Set<KOut>	invokeMapCombineLocally()
private java.util.Map<KOut,java.util.List<VOut>>	invokeMapCombineLocallyForLocalReduction()

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

mcc

private final org.infinispan.commands.read.MapCombineCommand<KIn,VIn,KOut,VOut> mcc

distributedReduce

private final boolean distributedReduce

Constructor Detail

MapReduceTask.MapTaskPart

public MapReduceTask.MapTaskPart(org.infinispan.remoting.transport.Address executionTarget,
                         org.infinispan.commands.read.MapCombineCommand<KIn,VIn,KOut,VOut> command,
                         boolean distributedReduce)

Method Detail

execute

public void execute()

Specified by:

execute in class MapReduceTask.TaskPart<V>

invokeMapCombineLocallyForLocalReduction

private java.util.Map<KOut,java.util.List<VOut>> invokeMapCombineLocallyForLocalReduction()
                                                                                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

invokeMapCombineLocally

private java.util.Set<KOut> invokeMapCombineLocally()
                                             throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getUUID

public java.util.UUID getUUID()