Class MapReduceEngineTaskConfigProvider
- java.lang.Object
-
- com.linkedin.venice.hadoop.mapreduce.engine.MapReduceEngineTaskConfigProvider
-
- All Implemented Interfaces:
EngineTaskConfigProvider
public class MapReduceEngineTaskConfigProvider extends java.lang.Object implements EngineTaskConfigProvider
An implementation ofEngineTaskConfigProvider
to get information about a running job on the MapReduce engine.
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
MAPRED_TASK_ID_PROP_NAME
static java.lang.String
MAPREDUCE_JOB_NAME_PROP_NAME
-
Constructor Summary
Constructors Constructor Description MapReduceEngineTaskConfigProvider(org.apache.hadoop.mapred.JobConf jobConf)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
getJobName()
java.util.Properties
getJobProps()
int
getTaskId()
-
-
-
Field Detail
-
MAPRED_TASK_ID_PROP_NAME
public static final java.lang.String MAPRED_TASK_ID_PROP_NAME
- See Also:
- Constant Field Values
-
MAPREDUCE_JOB_NAME_PROP_NAME
public static final java.lang.String MAPREDUCE_JOB_NAME_PROP_NAME
- See Also:
- Constant Field Values
-
-
Method Detail
-
getJobName
public java.lang.String getJobName()
- Specified by:
getJobName
in interfaceEngineTaskConfigProvider
- 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 interfaceEngineTaskConfigProvider
- Returns:
- The ID of the current task. This ID number is 0-based.
-
getJobProps
public java.util.Properties getJobProps()
- Specified by:
getJobProps
in interfaceEngineTaskConfigProvider
- Returns:
- The properties of the compute job.
-
-