Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
org.infinispan.distexec.mapreduce |
Map/Reduce APIs
|
Modifier and Type | Method and Description |
---|---|
DistributionManager |
AdvancedCache.getDistributionManager()
Retrieves a reference to the
DistributionManager if the cache is configured
to use Distribution. |
Modifier and Type | Method and Description |
---|---|
protected <KIn> Set<KIn> |
MapReduceManagerImpl.filterLocalPrimaryOwner(Set<KIn> nodeLocalKeys,
DistributionManager dm) |
protected <T> Map<? extends Collection<T>> |
MapReduceTask.mapKeysToNodes(DistributionManager dm,
Collection<T> keysToMap,
boolean useIntermediateCompositeKey) |
<T> Map<List<T>> |
MapReduceManager.mapKeysToNodes(DistributionManager dm,
String taskId,
Collection<T> keysToMap)
Maps Map/Reduce task intermediate or input keys to nodes on Infinispan cluster
|
<T> Map<List<T>> |
MapReduceManagerImpl.mapKeysToNodes(DistributionManager dm,
String taskId,
Collection<T> keysToMap) |
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.