Uses of Interface
com.hazelcast.mapreduce.ReducingSubmittableJob

Packages that use ReducingSubmittableJob

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.

Uses of ReducingSubmittableJob in com.hazelcast.mapreduce

Methods in com.hazelcast.mapreduce that return ReducingSubmittableJob

ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	ReducingSubmittableJob.chunkSize(int chunkSize) Defines the number of elements per chunk.
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	ReducingSubmittableJob.keyPredicate(KeyPredicate<EntryKey> predicate) Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on.
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	ReducingSubmittableJob.onKeys(EntryKey... keys) Defines keys to execute the mapper and a possibly defined reducer against.
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	ReducingSubmittableJob.onKeys(Iterable<EntryKey> keys) Defines keys to execute the mapper and a possibly defined reducer against.
<ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut>	ReducingJob.reducer(ReducerFactory<KeyIn,ValueIn,ValueOut> reducerFactory) Defines the ReducerFactory for this task.
<ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut>	MappingJob.reducer(ReducerFactory<KeyIn,ValueIn,ValueOut> reducerFactory) Defines the ReducerFactory for this task.
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	ReducingSubmittableJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy) Defines the strategy to handle topology changes while executing the map reduce job.

Uses of ReducingSubmittableJob in com.hazelcast.mapreduce.impl

Classes in com.hazelcast.mapreduce.impl that implement ReducingSubmittableJob

protected class

AbstractJob.ReducingSubmittableJobImpl<EntryKey,Key,Value> This class is just used to comply to the public DSL style API

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

ReducingSubmittableJob<EntryKey,Key,Value>	AbstractJob.ReducingSubmittableJobImpl.chunkSize(int chunkSize)
ReducingSubmittableJob<EntryKey,Key,Value>	AbstractJob.ReducingSubmittableJobImpl.keyPredicate(KeyPredicate<EntryKey> predicate)
ReducingSubmittableJob<EntryKey,Key,Value>	AbstractJob.ReducingSubmittableJobImpl.onKeys(EntryKey... keys)
ReducingSubmittableJob<EntryKey,Key,Value>	AbstractJob.ReducingSubmittableJobImpl.onKeys(Iterable<EntryKey> keys)
<ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut>	AbstractJob.MappingJobImpl.reducer(ReducerFactory<Key,Value,ValueOut> reducerFactory)
<ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut>	AbstractJob.ReducingJobImpl.reducer(ReducerFactory<Key,Value,ValueOut> reducerFactory)
ReducingSubmittableJob<EntryKey,Key,Value>	AbstractJob.ReducingSubmittableJobImpl.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)