Infinispan Distribution 5.2.6.Final-redhat-2

Uses of Class
org.infinispan.commands.read.MapCombineCommand

Packages that use MapCombineCommand
org.infinispan.commands Commands that operate on the cache, either locally or remotely. 
org.infinispan.distexec.mapreduce   
 

Uses of MapCombineCommand in org.infinispan.commands
 

Methods in org.infinispan.commands that return MapCombineCommand
<KIn,VIn,KOut,VOut>
MapCombineCommand<KIn,VIn,KOut,VOut>
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.
<KIn,VIn,KOut,VOut>
MapCombineCommand<KIn,VIn,KOut,VOut>
CommandsFactoryImpl.buildMapCombineCommand(String taskId, Mapper<KIn,VIn,KOut,VOut> m, Reducer<KOut,VOut> r, Collection<KIn> keys)
           
 

Uses of MapCombineCommand in org.infinispan.distexec.mapreduce
 

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)
           
 


Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.