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.
|
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.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.