Uses of Interface
com.hazelcast.mapreduce.MappingJob

Packages that use MappingJob

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

Methods in com.hazelcast.mapreduce that return MappingJob

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