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.

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.