|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ReduceCommand | |
---|---|
org.infinispan.commands | Commands that operate on the cache, either locally or remotely. |
org.infinispan.distexec.mapreduce |
Uses of ReduceCommand in org.infinispan.commands |
---|
Methods in org.infinispan.commands that return ReduceCommand | ||
---|---|---|
|
CommandsFactory.buildReduceCommand(String taskId,
String destinationCache,
Reducer<KOut,VOut> r,
Collection<KOut> keys)
Builds a ReduceCommand used for migration and reduce phase execution of MapReduce tasks. |
|
|
CommandsFactoryImpl.buildReduceCommand(String taskId,
String destintationCache,
Reducer<KOut,VOut> r,
Collection<KOut> keys)
|
Uses of ReduceCommand in org.infinispan.distexec.mapreduce |
---|
Methods in org.infinispan.distexec.mapreduce with parameters of type ReduceCommand | ||
---|---|---|
protected
|
MapReduceTask.createReducePart(ReduceCommand<KOut,VOut> cmd,
Address target,
String destCacheName)
|
|
|
MapReduceManager.reduce(ReduceCommand<KOut,VOut> reducer)
Invoked when ReduceCommand arrives to a target Infinispan node. |
|
|
MapReduceManagerImpl.reduce(ReduceCommand<KOut,VOut> reduceCommand)
|
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV NEXT | FRAMES NO FRAMES |