| Package | Description | 
|---|---|
| com.hazelcast.mapreduce | This package contains the MapReduce API definition for Hazelcast. All map reduce operations running in a distributed manner inside the active Hazelcast cluster. | 
| com.hazelcast.mapreduce.impl | This package contains the default implementation for the map reduce framework
 internals. | 
| com.hazelcast.mapreduce.impl.task | This package contains the base implementation for a standard map reduce job. | 
| Modifier and Type | Method and Description | 
|---|---|
| JobCompletableFuture<Map<KeyIn,List<ValueIn>>> | ReducingJob. submit()Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes | 
| JobCompletableFuture<Map<KeyIn,List<ValueIn>>> | MappingJob. submit()Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes. | 
| JobCompletableFuture<Map<KeyIn,ValueIn>> | ReducingSubmittableJob. submit()Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes. | 
| <ValueOut> JobCompletableFuture<ValueOut> | ReducingJob. submit(Collator<Map.Entry<KeyIn,List<ValueIn>>,ValueOut> collator)Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes and executes the
 collator before returning the final result. | 
| <ValueOut> JobCompletableFuture<ValueOut> | MappingJob. submit(Collator<Map.Entry<KeyIn,List<ValueIn>>,ValueOut> collator)Submits the task to Hazelcast, executes the defined mapper and reducer on all cluster nodes, and executes the
 collator before returning the final result. | 
| <ValueOut> JobCompletableFuture<ValueOut> | ReducingSubmittableJob. submit(Collator<Map.Entry<KeyIn,ValueIn>,ValueOut> collator)Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes and executes the
 collator before returning the final result. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected abstract <T> JobCompletableFuture<T> | AbstractJob. invoke(Collator collator) | 
| JobCompletableFuture<Map<Key,List<Value>>> | AbstractJob.MappingJobImpl. submit() | 
| JobCompletableFuture<Map<Key,List<Value>>> | AbstractJob.ReducingJobImpl. submit() | 
| JobCompletableFuture<Map<Key,Value>> | AbstractJob.ReducingSubmittableJobImpl. submit() | 
| protected <T> JobCompletableFuture<T> | AbstractJob. submit(Collator collator) | 
| <ValueOut> JobCompletableFuture<ValueOut> | AbstractJob.MappingJobImpl. submit(Collator<Map.Entry<Key,List<Value>>,ValueOut> collator) | 
| <ValueOut> JobCompletableFuture<ValueOut> | AbstractJob.ReducingJobImpl. submit(Collator<Map.Entry<Key,List<Value>>,ValueOut> collator) | 
| <ValueOut> JobCompletableFuture<ValueOut> | AbstractJob.ReducingSubmittableJobImpl. submit(Collator<Map.Entry<Key,Value>,ValueOut> collator) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TrackableJobFuture<V>This is the node based implementation of the job's reactive  ICompletableFutureand is returned to the users codebase. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected <T> JobCompletableFuture<T> | KeyValueJob. invoke(Collator collator) | 
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.