Uses of Interface
com.hazelcast.mapreduce.Job

Packages that use Job

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

Methods in com.hazelcast.mapreduce that return Job

Job<KeyIn,ValueIn>	Job.chunkSize(int chunkSize) Defines the number of elements per chunk.
Job<KeyIn,ValueIn>	Job.keyPredicate(KeyPredicate<KeyIn> predicate) Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on.
<K,V> Job<K,V>	JobTracker.newJob(KeyValueSource<K,V> source) Builds a Job instance for the given KeyValueSource instance.
Job<KeyIn,ValueIn>	Job.onKeys(Iterable<KeyIn> keys) Defines keys to execute the mapper and a possibly defined reducer against.
Job<KeyIn,ValueIn>	Job.onKeys(KeyIn... keys) Defines keys to execute the mapper and a possibly defined reducer against.
Job<KeyIn,ValueIn>	Job.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy) Defines the strategy to handle topology changes while executing the map reduce job.