public interface MapReduceManager
This interface should never be implemented by clients.
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.ExecutorService |
getExecutorService()
ExecutorService provided for local task execution
|
<KIn,VIn,KOut,VOut> |
mapAndCombineForDistributedReduction(org.infinispan.commands.read.MapCombineCommand<KIn,VIn,KOut,VOut> mcc)
Invoked when MapCombineCommand arrives to a target Infinispan node and returns set of
intermediate keys that needs to be reduced.
|
<KIn,VIn,KOut,VOut> |
mapAndCombineForLocalReduction(org.infinispan.commands.read.MapCombineCommand<KIn,VIn,KOut,VOut> mcc)
Invoked when MapCombineCommand arrives to a target Infinispan node and returns map of resulting
values that need to be reduced.
|
<T> java.util.Map<org.infinispan.remoting.transport.Address,java.util.List<T>> |
mapKeysToNodes(org.infinispan.distribution.DistributionManager dm,
java.lang.String taskId,
java.util.Collection<T> keysToMap,
boolean useIntermediateCompositeKey)
Maps Map/Reduce task intermediate or input keys to nodes on Infinispan cluster
|
<KOut,VOut> |
reduce(org.infinispan.commands.read.ReduceCommand<KOut,VOut> reducer)
Invoked when ReduceCommand arrives to a target Infinispan node.
|
<KIn,VIn,KOut,VOut> java.util.Set<KOut> mapAndCombineForDistributedReduction(org.infinispan.commands.read.MapCombineCommand<KIn,VIn,KOut,VOut> mcc) throws java.lang.InterruptedException
mcc
- MapCombineCommand sent from MapReduceTaskjava.lang.InterruptedException
<KIn,VIn,KOut,VOut> java.util.Map<KOut,java.util.List<VOut>> mapAndCombineForLocalReduction(org.infinispan.commands.read.MapCombineCommand<KIn,VIn,KOut,VOut> mcc) throws java.lang.InterruptedException
Unlike mapAndCombineForDistributedReduction(MapCombineCommand)
implementations should return a map Map
mcc
- MapCombineCommand sent from MapReduceTaskjava.lang.InterruptedException
<KOut,VOut> java.util.Map<KOut,VOut> reduce(org.infinispan.commands.read.ReduceCommand<KOut,VOut> reducer) throws java.lang.InterruptedException
reducer
- ReduceCommand sent from MapReduceTaskjava.lang.InterruptedException
<T> java.util.Map<org.infinispan.remoting.transport.Address,java.util.List<T>> mapKeysToNodes(org.infinispan.distribution.DistributionManager dm, java.lang.String taskId, java.util.Collection<T> keysToMap, boolean useIntermediateCompositeKey)
dm
- distribution manager to use for locating keys on hash wheeltaskId
- id of the map/reduce taskkeysToMap
- list of input keys to locate in the clusteruseIntermediateCompositeKey
- if true use composite keys for shared intermediate cachejava.util.concurrent.ExecutorService getExecutorService()
ExecutorService
for local tasks