public class JobTrackerConfigReadOnly extends JobTrackerConfig
JobTracker
.DEFAULT_CHUNK_SIZE, DEFAULT_COMMUNICATE_STATS, DEFAULT_MAX_THREAD_SIZE, DEFAULT_QUEUE_SIZE, DEFAULT_RETRY_COUNT, DEFAULT_TOPOLOGY_CHANGED_STRATEGY
Modifier and Type | Method and Description |
---|---|
void |
setChunkSize(int chunkSize)
Sets the number of emitted values before a chunk is send to the reducers.
|
void |
setCommunicateStats(boolean communicateStats)
Set to true if statistics (for example, about processed entries)
should be transmitted to the job emitter, false otherwise.
|
void |
setMaxThreadSize(int maxThreadSize)
Sets the maximum thread pool size of this
JobTracker . |
JobTrackerConfigReadOnly |
setName(String name)
Sets the name of this
JobTracker . |
void |
setQueueSize(int queueSize)
Sets the maximum size of the queue; the maximum number of tasks that can wait to be processed.
|
void |
setRetryCount(int retryCount)
retry count is currently not used but reserved for later use where the framework will
automatically try to restart / retry operations from a available savepoint.
|
void |
setTopologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Sets how the map reduce framework will react on topology
changes while executing a job.
|
getAsReadOnly, getChunkSize, getMaxThreadSize, getName, getQueueSize, getRetryCount, getTopologyChangedStrategy, isCommunicateStats
public JobTrackerConfigReadOnly setName(String name)
JobTrackerConfig
JobTracker
.setName
in class JobTrackerConfig
name
- the name of the JobTracker
.public void setMaxThreadSize(int maxThreadSize)
JobTrackerConfig
JobTracker
.setMaxThreadSize
in class JobTrackerConfig
maxThreadSize
- the maximum thread pool size of the JobTracker
.public void setRetryCount(int retryCount)
JobTrackerConfig
setRetryCount
in class JobTrackerConfig
public void setChunkSize(int chunkSize)
JobTrackerConfig
setChunkSize
in class JobTrackerConfig
chunkSize
- The number of emitted values before a chunk is sent to the reducers.public void setQueueSize(int queueSize)
JobTrackerConfig
setQueueSize
in class JobTrackerConfig
queueSize
- The maximum size of the queue.public void setCommunicateStats(boolean communicateStats)
JobTrackerConfig
setCommunicateStats
in class JobTrackerConfig
communicateStats
- True if statistics (for example, about processed entries) are transmitted to the job emitter,
false otherwise.public void setTopologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
JobTrackerConfig
setTopologyChangedStrategy
in class JobTrackerConfig
topologyChangedStrategy
- How the map reduce framework will react on topology
changes while executing a job.Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.