Methods in org.infinispan.commands that return MapCombineCommand |
|
CommandsFactory.buildMapCombineCommand(String taskId,
Mapper<KIn,VIn,KOut,VOut> m,
Reducer<KOut,VOut> r,
Collection<KIn> keys)
Builds a MapCombineCommand used for migration and map phase execution of MapReduce tasks. |
|
CommandsFactoryImpl.buildMapCombineCommand(String taskId,
Mapper<KIn,VIn,KOut,VOut> m,
Reducer<KOut,VOut> r,
Collection<KIn> keys)
|
Methods in org.infinispan.distexec.mapreduce with parameters of type MapCombineCommand |
protected
<KIn,VIn,KOut,VOut>
Set<KOut> |
|
MapReduceManagerImpl.combine(MapCombineCommand<KIn,VIn,KOut,VOut> mcc,
org.infinispan.distexec.mapreduce.MapReduceManagerImpl.CollectableCollector<KOut,VOut> collector)
|
protected
<V> org.infinispan.distexec.mapreduce.MapReduceTask.MapTaskPart<V> |
|
MapReduceTask.createTaskMapPart(MapCombineCommand<KIn,VIn,KOut,VOut> cmd,
Address target,
boolean distributedReduce)
|
protected
<KIn,VIn,KOut,VOut>
org.infinispan.distexec.mapreduce.MapReduceManagerImpl.CollectableCollector<KOut,VOut> |
|
MapReduceManagerImpl.map(MapCombineCommand<KIn,VIn,KOut,VOut> mcc)
|
<KIn,VIn,KOut,VOut>
Set<KOut> |
|
MapReduceManager.mapAndCombineForDistributedReduction(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>
Set<KOut> |
|
MapReduceManagerImpl.mapAndCombineForDistributedReduction(MapCombineCommand<KIn,VIn,KOut,VOut> mcc)
|
<KIn,VIn,KOut,VOut>
Map<KOut,List<VOut>> |
|
MapReduceManager.mapAndCombineForLocalReduction(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. |
<KIn,VIn,KOut,VOut>
Map<KOut,List<VOut>> |
|
MapReduceManagerImpl.mapAndCombineForLocalReduction(MapCombineCommand<KIn,VIn,KOut,VOut> mcc)
|