public class JobTrackerConfig extends Object
JobTracker
.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_CHUNK_SIZE
Default value of chunk size.
|
static boolean |
DEFAULT_COMMUNICATE_STATS
Default boolean value of communication statics.define how a map reduce job behaves
|
static int |
DEFAULT_MAX_THREAD_SIZE
Default size of thread.
|
static int |
DEFAULT_QUEUE_SIZE
Default value of Queue size.
|
static int |
DEFAULT_RETRY_COUNT
Default value of retry counter.
|
static TopologyChangedStrategy |
DEFAULT_TOPOLOGY_CHANGED_STRATEGY
Define how a map reduce job behaves.
|
Constructor and Description |
---|
JobTrackerConfig() |
JobTrackerConfig(JobTrackerConfig source) |
Modifier and Type | Method and Description |
---|---|
JobTrackerConfig |
getAsReadOnly() |
int |
getChunkSize() |
int |
getMaxThreadSize() |
String |
getName() |
int |
getQueueSize() |
int |
getRetryCount() |
TopologyChangedStrategy |
getTopologyChangedStrategy() |
boolean |
isCommunicateStats() |
void |
setChunkSize(int chunkSize) |
void |
setCommunicateStats(boolean communicateStats) |
void |
setMaxThreadSize(int maxThreadSize) |
JobTrackerConfig |
setName(String name) |
void |
setQueueSize(int queueSize) |
void |
setRetryCount(int retryCount) |
void |
setTopologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy) |
public static final int DEFAULT_MAX_THREAD_SIZE
public static final int DEFAULT_RETRY_COUNT
public static final int DEFAULT_CHUNK_SIZE
public static final int DEFAULT_QUEUE_SIZE
public static final boolean DEFAULT_COMMUNICATE_STATS
public static final TopologyChangedStrategy DEFAULT_TOPOLOGY_CHANGED_STRATEGY
public JobTrackerConfig()
public JobTrackerConfig(JobTrackerConfig source)
public JobTrackerConfig setName(String name)
public String getName()
public int getMaxThreadSize()
public void setMaxThreadSize(int maxThreadSize)
public int getRetryCount()
public void setRetryCount(int retryCount)
public int getChunkSize()
public void setChunkSize(int chunkSize)
public JobTrackerConfig getAsReadOnly()
public int getQueueSize()
public void setQueueSize(int queueSize)
public boolean isCommunicateStats()
public void setCommunicateStats(boolean communicateStats)
public TopologyChangedStrategy getTopologyChangedStrategy()
public void setTopologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Copyright © 2014 Hazelcast, Inc.. All Rights Reserved.