| Package | Description | 
|---|---|
| com.hazelcast.client.proxy | This package contains client side proxy implementations of the different Hazelcast data structures
 and operation types | 
| 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. | 
| com.hazelcast.mapreduce.impl.task | This package contains the base implementation for a standard map reduce job. | 
| Modifier and Type | Method and Description | 
|---|---|
| <K,V> Job<K,V> | ClientMapReduceProxy. newJob(KeyValueSource<K,V> source) | 
| Modifier and Type | Method and Description | 
|---|---|
| Job<KeyIn,ValueIn> | Job. chunkSize(int chunkSize)Defines the number of elements per chunk. | 
| Job<KeyIn,ValueIn> | Job. keyPredicate(KeyPredicate<? super KeyIn> predicate)Defines the  KeyPredicateimplementation to preselect keys the MapReduce task will be executed on. | 
| <K,V> Job<K,V> | JobTracker. newJob(KeyValueSource<K,V> source)Builds a  Jobinstance for the givenKeyValueSourceinstance. | 
| Job<KeyIn,ValueIn> | Job. onKeys(Iterable<? extends 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. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AbstractJob<KeyIn,ValueIn>Base class for all map reduce job implementations | 
| Modifier and Type | Method and Description | 
|---|---|
| Job<KeyIn,ValueIn> | AbstractJob. chunkSize(int chunkSize) | 
| Job<KeyIn,ValueIn> | AbstractJob. keyPredicate(KeyPredicate<? super KeyIn> predicate) | 
| Job<KeyIn,ValueIn> | AbstractJob. onKeys(Iterable<? extends KeyIn> keys) | 
| Job<KeyIn,ValueIn> | AbstractJob. onKeys(KeyIn... keys) | 
| Job<KeyIn,ValueIn> | AbstractJob. topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | KeyValueJob<KeyIn,ValueIn>This class is the internal representation of a map reduce job. | 
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.