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 |
---|---|
<KIn,VIn,KOut,VOut> |
CommandsFactoryImpl.buildMapCombineCommand(String taskId,
Mapper<KIn,VIn,KOut,VOut> m,
Reducer<KOut,VOut> r,
Collection<KIn> keys) |
<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.
|
Modifier and Type | Method and Description |
---|---|
protected <KIn,VIn,KOut,VOut> |
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> |
MapReduceManagerImpl.map(MapCombineCommand<KIn,VIn,KOut,VOut> mcc) |
<KIn,VIn,KOut,VOut> |
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> |
MapReduceManagerImpl.mapAndCombineForDistributedReduction(MapCombineCommand<KIn,VIn,KOut,VOut> mcc) |
<KIn,VIn,KOut,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> |
MapReduceManagerImpl.mapAndCombineForLocalReduction(MapCombineCommand<KIn,VIn,KOut,VOut> mcc) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.