Package com.linkedin.venice.hadoop.mapreduce.engine

Class MapReduceEngineTaskConfigProvider

java.lang.Object

com.linkedin.venice.hadoop.mapreduce.engine.MapReduceEngineTaskConfigProvider

All Implemented Interfaces:

EngineTaskConfigProvider

public class MapReduceEngineTaskConfigProvider
extends Object
implements EngineTaskConfigProvider

An implementation of EngineTaskConfigProvider to get information about a running job on the MapReduce engine.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	MAPRED_TASK_ID_PROP_NAME
static final String	MAPREDUCE_JOB_NAME_PROP_NAME

Constructor Summary

Constructors

Constructor	Description
MapReduceEngineTaskConfigProvider(org.apache.hadoop.mapred.JobConf jobConf)

Method Summary

Modifier and Type	Method	Description
String	getJobName()
Properties	getJobProps()
int	getTaskId()

Methods inherited from class java.lang.Object

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

Field Details

MAPRED_TASK_ID_PROP_NAME

public static final String MAPRED_TASK_ID_PROP_NAME

See Also:

• Constant Field Values

MAPREDUCE_JOB_NAME_PROP_NAME

public static final String MAPREDUCE_JOB_NAME_PROP_NAME

See Also:

• Constant Field Values

Constructor Details

MapReduceEngineTaskConfigProvider

public MapReduceEngineTaskConfigProvider(org.apache.hadoop.mapred.JobConf jobConf)

Method Details

getJobName

public String getJobName()

Specified by:

getJobName in interface EngineTaskConfigProvider

Returns:

The name of the compute job. This must be the same for all tasks of the same job.

getTaskId

public int getTaskId()

Specified by:

getTaskId in interface EngineTaskConfigProvider

Returns:

The ID of the current task. This ID number is 0-based.

getJobProps

public Properties getJobProps()

Specified by:

getJobProps in interface EngineTaskConfigProvider

Returns:

The properties of the compute job.