Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.distexec.mapreduce |
Modifier and Type | Method and Description |
---|---|
<KOut,VOut> |
CommandsFactoryImpl.buildReduceCommand(String taskId,
String destintationCache,
Reducer<KOut,VOut> r,
Collection<KOut> keys) |
<KOut,VOut> |
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.
|
Modifier and Type | Method and Description |
---|---|
protected <V> org.infinispan.distexec.mapreduce.MapReduceTask.ReduceTaskPart<V> |
MapReduceTask.createReducePart(ReduceCommand<KOut,VOut> cmd,
Address target,
String destCacheName) |
<KOut,VOut> |
MapReduceManager.reduce(ReduceCommand<KOut,VOut> reducer)
Invoked when ReduceCommand arrives to a target Infinispan node.
|
<KOut,VOut> |
MapReduceManagerImpl.reduce(ReduceCommand<KOut,VOut> reduceCommand) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.