Uses of Interface
com.hazelcast.mapreduce.JobCompletableFuture

Packages that use JobCompletableFuture

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.

Uses of JobCompletableFuture in com.hazelcast.mapreduce

Methods in com.hazelcast.mapreduce that return JobCompletableFuture

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

Uses of JobCompletableFuture in com.hazelcast.mapreduce.impl

Methods in com.hazelcast.mapreduce.impl that return JobCompletableFuture

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)

Uses of JobCompletableFuture in com.hazelcast.mapreduce.impl.task

Classes in com.hazelcast.mapreduce.impl.task that implement JobCompletableFuture

class

TrackableJobFuture<V> This is the node based implementation of the job's reactive ICompletableFuture and is returned to the users codebase.

Methods in com.hazelcast.mapreduce.impl.task that return JobCompletableFuture

protected <T> JobCompletableFuture<T>

KeyValueJob.invoke(Collator collator)