| Package | Description | 
|---|---|
| com.hazelcast.config | 
 Provides classes for configuring HazelcastInstance. 
 | 
| 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.client | 
 This package contains request and response classes for communication between cluster
 members and Hazelcast native clients 
 | 
| com.hazelcast.mapreduce.impl.operation | 
 This package contains all remote operations that are needed to control work on
 supervising or worker nodes. 
 | 
| com.hazelcast.mapreduce.impl.task | 
 This package contains the base implementation for a standard map reduce job. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static TopologyChangedStrategy | 
JobTrackerConfig.DEFAULT_TOPOLOGY_CHANGED_STRATEGY
Define how a map reduce job behaves. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
TopologyChangedStrategy | 
JobTrackerConfig.getTopologyChangedStrategy()
Gets how the map reduce framework will react on topology
 changes while executing a job. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
JobTrackerConfigReadOnly.setTopologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)  | 
void | 
JobTrackerConfig.setTopologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Sets how the map reduce framework will react on topology
 changes while executing a job. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static TopologyChangedStrategy | 
TopologyChangedStrategy.valueOf(String name)
Returns the enum constant of this type with the specified name. 
 | 
static TopologyChangedStrategy[] | 
TopologyChangedStrategy.values()
Returns an array containing the constants of this enum type, in
the order they are declared. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ReducingJob<EntryKey,KeyIn,ValueIn> | 
ReducingJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Defines the strategy to handle topology changes while executing the map reduce job. 
 | 
MappingJob<EntryKey,KeyIn,ValueIn> | 
MappingJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Defines the strategy to handle topology changes while executing the map reduce job. 
 | 
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> | 
ReducingSubmittableJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Defines the strategy to handle topology changes while executing the map reduce job. 
 | 
Job<KeyIn,ValueIn> | 
Job.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Defines the strategy to handle topology changes while executing the map reduce job. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
protected TopologyChangedStrategy | 
AbstractJob.topologyChangedStrategy  | 
| Modifier and Type | Method and Description | 
|---|---|
Job<KeyIn,ValueIn> | 
AbstractJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)  | 
MappingJob<EntryKey,Key,Value> | 
AbstractJob.MappingJobImpl.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)  | 
ReducingJob<EntryKey,Key,Value> | 
AbstractJob.ReducingJobImpl.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)  | 
ReducingSubmittableJob<EntryKey,Key,Value> | 
AbstractJob.ReducingSubmittableJobImpl.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected TopologyChangedStrategy | 
ClientMapReduceRequest.topologyChangedStrategy  | 
| Constructor and Description | 
|---|
ClientMapReduceRequest(String name,
                      String jobId,
                      Collection keys,
                      KeyPredicate predicate,
                      Mapper mapper,
                      CombinerFactory combinerFactory,
                      ReducerFactory reducerFactory,
                      KeyValueSource keyValueSource,
                      int chunkSize,
                      TopologyChangedStrategy topologyChangedStrategy)  | 
| Constructor and Description | 
|---|
KeyValueJobOperation(String name,
                    String jobId,
                    int chunkSize,
                    KeyValueSource<K,V> keyValueSource,
                    Mapper mapper,
                    CombinerFactory combinerFactory,
                    ReducerFactory reducerFactory,
                    boolean communicateStats,
                    TopologyChangedStrategy topologyChangedStrategy)  | 
| Modifier and Type | Method and Description | 
|---|---|
TopologyChangedStrategy | 
JobTaskConfiguration.getTopologyChangedStrategy()  | 
| Constructor and Description | 
|---|
JobTaskConfiguration(Address jobOwner,
                    NodeEngine nodeEngine,
                    int chunkSize,
                    String name,
                    String jobId,
                    Mapper mapper,
                    CombinerFactory combinerFactory,
                    ReducerFactory reducerFactory,
                    KeyValueSource keyValueSource,
                    boolean communicateStats,
                    TopologyChangedStrategy topologyChangedStrategy)  | 
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.