| 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.aggregation | 
 This package contains the aggregation API and the convenience helper classes
 to retrieve predefined aggregation implementations. 
 | 
| com.hazelcast.mapreduce.aggregation.impl | 
 This package contains a set of predefined aggregation implementations 
 | 
| 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 | 
|---|---|
<ValueOut> JobCompletableFuture<ValueOut> | 
ReducingJob.submit(Collator<Map.Entry<KeyIn,List<ValueIn>>,ValueOut> collator)
Deprecated.  
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)
Deprecated.  
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)
Deprecated.  
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 | 
|---|---|
Collator<Map.Entry,Result> | 
Aggregation.getCollator()
Deprecated.  
Returns the Collator implementation used in this aggregation. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected abstract <T> JobCompletableFuture<T> | 
AbstractJob.invoke(Collator collator)  | 
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 | Method and Description | 
|---|---|
protected <T> JobCompletableFuture<T> | 
KeyValueJob.invoke(Collator collator)  | 
| Constructor and Description | 
|---|
TrackableJobFuture(String name,
                  String jobId,
                  JobTracker jobTracker,
                  NodeEngine nodeEngine,
                  Collator collator)  | 
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.