Search Java Classes and Packages
#Org.infinispan.distexec Classes and Interfaces - 22 results found.
| 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 |