|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface MapReduceManager
MapReduceManager is an internal Infinispan component receiving map/reduce invocations arriving from remote Infinispan nodes.
This interface should never be implemented by clients.
Method Summary | ||
---|---|---|
ExecutorService |
getExecutorService()
ExecutorService provided for local task execution |
|
|
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. |
|
|
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. |
|
|
mapKeysToNodes(DistributionManager dm,
String taskId,
Collection<T> keysToMap,
boolean useIntermediateCompositeKey)
Maps Map/Reduce task intermediate or input keys to nodes on Infinispan cluster |
|
|
reduce(ReduceCommand<KOut,VOut> reducer)
Invoked when ReduceCommand arrives to a target Infinispan node. |
Method Detail |
---|
<KIn,VIn,KOut,VOut> Set<KOut> mapAndCombineForDistributedReduction(MapCombineCommand<KIn,VIn,KOut,VOut> mcc) throws InterruptedException
mcc
- MapCombineCommand sent from MapReduceTask
InterruptedException
<KIn,VIn,KOut,VOut> Map<KOut,List<VOut>> mapAndCombineForLocalReduction(MapCombineCommand<KIn,VIn,KOut,VOut> mcc) throws InterruptedException
Unlike
mapAndCombineForDistributedReduction(MapCombineCommand)
implementations should return a map Map
mcc
- MapCombineCommand sent from MapReduceTask
InterruptedException
<KOut,VOut> Map<KOut,VOut> reduce(ReduceCommand<KOut,VOut> reducer) throws InterruptedException
reducer
- ReduceCommand sent from MapReduceTask
InterruptedException
<T> Map<Address,List<T>> mapKeysToNodes(DistributionManager dm, String taskId, Collection<T> keysToMap, boolean useIntermediateCompositeKey)
dm
- distribution manager to use for locating keys on hash wheeltaskId
- id of the map/reduce taskkeysToMap
- list of input keys to locate in the clusteruseIntermediateCompositeKey
- if true use composite keys for shared intermediate cache
ExecutorService getExecutorService()
ExecutorService
for local tasks
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |