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