Name | Description | Type | Package | Framework |
Collator | Collator collates results from Reducers executed on Infinispan cluster and assembles a final result returned to an invoker of MapReduceTask. | Interface | org.infinispan.distexec.mapreduce | Infinispan |
Collector | OutputCollector is the intermediate key/value result data output collector given to each MapperSince:5. | Interface | org.infinispan.distexec.mapreduce | Infinispan |
DefaultExecutorService | Infinispan's implementation of an ExecutorService and DistributedExecutorService. | Class | org.infinispan.distexec | Infinispan |
DistributedCallable | A task that returns a result and may throw an exception capable of being executed in another JVM. | Interface | org.infinispan.distexec | Infinispan |
DistributedExecutionCompletionService | A CompletionService that uses a supplied DistributedExecutorService to execute tasks. | Class | org.infinispan.distexec | Infinispan |
DistributedExecutorService | An ExecutorService that provides methods to submit tasks for execution on a cluster of Infinispan Every DistributedExecutorService is bound to one particular cache. | Interface | org.infinispan.distexec | Infinispan |
DistributedTask | DistributedTask describes all relevant attributes of a distributed task, most importantly its execution policy, fail over policy and its timeout. | Interface | org.infinispan.distexec | Infinispan |
DistributedTaskBuilder | DistributedTaskBuilder is a factory interface for DistributedTaskSince:5. | Interface | org.infinispan.distexec | Infinispan |
DistributedTaskExecutionPolicy | enum DistributedTaskExecutionPolicyDistributedTaskExecutionPolicy allows task to specify its custom task execution policy across | Class | org.infinispan.distexec | Infinispan |
DistributedTaskFailoverPolicy | DistributedTaskFailoverPolicy allows pluggable fail over target selection for a failed remotely executed distributed task. | Interface | org.infinispan.distexec | Infinispan |
FailoverContext | As DistributedTask might potentially fail on subset of executing nodes FailureContext provides details of such task failure. | Interface | org.infinispan.distexec | Infinispan |
Mapper | entry K,V. | Interface | org.infinispan.distexec.mapreduce | Infinispan |
MapReduceCacheLoaderTask | This is an internal class, not intended to be used by clients. | Class | org.infinispan.distexec.mapreduce | Infinispan |
MapReduceException | An exception indicating Map/Reduce job failureSince:7. | Class | org.infinispan.distexec.mapreduce | Infinispan |
MapReduceManager | MapReduceManager is an internal Infinispan component receiving map/reduce invocations arriving from remote Infinispan nodes. | Interface | org.infinispan.distexec.mapreduce | Infinispan |
MapReduceManagerFactory | MapReduceManagerFactory is a default factory class for MapReduceManager. | Class | org.infinispan.distexec.mapreduce | Infinispan |
MapReduceManagerImpl | Default implementation of MapReduceManager. | Class | org.infinispan.distexec.mapreduce | Infinispan |
MapReduceManagerImpl .DeltaAwareListExternalizer | Class | org.infinispan.distexec.mapreduce.MapReduceManagerImpl | Infinispan | |
MapReduceManagerImpl .DeltaListExternalizer | Class | org.infinispan.distexec.mapreduce.MapReduceManagerImpl | Infinispan | |
MapReduceManagerImpl .IntermediateKey | IntermediateCompositeKeySee Also:Serialized Form | Class | org.infinispan.distexec.mapreduce.MapReduceManagerImpl | Infinispan |
MapReduceTask | MapReduceTask is a distributed task allowing a large scale computation to be transparently parallelized across Infinispan cluster nodes. | Class | org.infinispan.distexec.mapreduce | Infinispan |
Reducer | Reduces intermediate key/value results from map phase of MapReduceTask. | Interface | org.infinispan.distexec.mapreduce | Infinispan |