| Interface | Description |
|---|---|
| Collator<KOut,VOut,R> |
Collator collates results from Reducers executed on Infinispan cluster and assembles a final
result returned to an invoker of MapReduceTask.
|
| Collector<K,V> |
OutputCollector is the intermediate key/value result data output collector given to each
Mapper |
| Mapper<KIn,VIn,KOut,VOut> |
Implementation of a Mapper class is a component of a MapReduceTask invoked once for each input
entry K,V.
|
| MapReduceManager |
MapReduceManager is an internal Infinispan component receiving map/reduce invocations arriving
from remote Infinispan nodes.
|
| MapReduceManagerImpl.CollectableCollector<K,V> | |
| MapReduceTask.CancellableTaskPart | |
| Reducer<KOut,VOut> |
Reduces intermediate key/value results from map phase of MapReduceTask.
|
| Class | Description |
|---|---|
| MapReduceCacheLoaderTask | |
| MapReduceManagerFactory |
MapReduceManagerFactory is a default factory class for
MapReduceManager. |
| MapReduceManagerImpl |
Default implementation of
MapReduceManager. |
| MapReduceManagerImpl.DefaultCollector<KOut,VOut> | |
| MapReduceManagerImpl.DeltaAwareList<E> | |
| MapReduceManagerImpl.IntermediateCompositeKey<V> |
IntermediateCompositeKey
|
| MapReduceManagerImpl.IntermediateKeyFilter<T> | |
| MapReduceTask<KIn,VIn,KOut,VOut> |
MapReduceTask is a distributed task allowing a large scale computation to be transparently
parallelized across Infinispan cluster nodes.
|
| SecurityActions |
SecurityActions for the org.infinispan.distexec.mapreduce package.
|