Uses of Interface
com.hazelcast.mapreduce.ReducingJob

Packages that use ReducingJob

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 ReducingJob in com.hazelcast.mapreduce

Methods in com.hazelcast.mapreduce that return ReducingJob

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