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.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)
Deprecated.
|
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)
Deprecated.
Returns the enum constant of this type with the specified name.
|
static TopologyChangedStrategy[] |
TopologyChangedStrategy.values()
Deprecated.
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)
Deprecated.
Defines the strategy to handle topology changes while executing the map reduce job.
|
MappingJob<EntryKey,KeyIn,ValueIn> |
MappingJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Deprecated.
Defines the strategy to handle topology changes while executing the map reduce job.
|
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> |
ReducingSubmittableJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Deprecated.
Defines the strategy to handle topology changes while executing the map reduce job.
|
Job<KeyIn,ValueIn> |
Job.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Deprecated.
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) |
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 © 2020 Hazelcast, Inc.. All Rights Reserved.