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.