| 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.