com.hazelcast.mapreduce.impl.task

Class JobTaskConfiguration

java.lang.Object

com.hazelcast.mapreduce.impl.task.JobTaskConfiguration

public class JobTaskConfiguration
extends Object

This class contains all configuration settings for a given map reduce job. This class is immutable and values are set after the job itself is emitted to the job owner.

Constructor Summary

Constructors

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)

Method Summary

Methods

Modifier and Type	Method and Description
int	getChunkSize()
CombinerFactory	getCombinerFactory()
String	getJobId()
Address	getJobOwner()
KeyValueSource	getKeyValueSource()
Mapper	getMapper()
String	getName()
NodeEngine	getNodeEngine()
ReducerFactory	getReducerFactory()
TopologyChangedStrategy	getTopologyChangedStrategy()
boolean	isCommunicateStats()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobTaskConfiguration

public JobTaskConfiguration(Address jobOwner,
                    NodeEngine nodeEngine,
                    int chunkSize,
                    String name,
                    String jobId,
                    Mapper mapper,
                    CombinerFactory combinerFactory,
                    ReducerFactory reducerFactory,
                    KeyValueSource keyValueSource,
                    boolean communicateStats,
                    TopologyChangedStrategy topologyChangedStrategy)

Method Detail

getJobOwner

public Address getJobOwner()

getChunkSize

public int getChunkSize()

getName

public String getName()

getJobId

public String getJobId()

getMapper

public Mapper getMapper()

getCombinerFactory

public CombinerFactory getCombinerFactory()

getReducerFactory

public ReducerFactory getReducerFactory()

getKeyValueSource

public KeyValueSource getKeyValueSource()

getNodeEngine

public NodeEngine getNodeEngine()

isCommunicateStats

public boolean isCommunicateStats()

getTopologyChangedStrategy

public TopologyChangedStrategy getTopologyChangedStrategy()