| 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  
ICompletableFuture
 and is returned to the users codebase. | 
| Modifier and Type | Method and Description | 
|---|---|
protected <T> JobCompletableFuture<T> | 
KeyValueJob.invoke(Collator collator)  | 
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.