Home
last modified time | relevance | path

Searched refs:TASK_PARTITION (Results 1 – 7 of 7) sorted by relevance

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/
H A DFileOutputFormat.java283 int partition = conf.getInt(JobContext.TASK_PARTITION, -1); in getUniqueName()
H A DTask.java551 conf.setInt(JobContext.TASK_PARTITION, partition); in localizeConfiguration()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/
H A DTestReduceFetchFromPartialMem.java117 id = nMaps - conf.getInt(JobContext.TASK_PARTITION, -1) - 1; in configure()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/
H A DMRJobConfig.java204 public static final String TASK_PARTITION = "mapreduce.task.partition"; field
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/
H A DLocalContainerLauncher.java345 conf.setInt(JobContext.TASK_PARTITION, task.getPartition()); in runSubtask()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/util/
H A DConfigUtil.java288 MRJobConfig.TASK_PARTITION), in addDeprecatedKeys()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-archives/src/main/java/org/apache/hadoop/tools/
H A DHadoopArchives.java588 partId = conf.getInt(MRJobConfig.TASK_PARTITION, -1); in configure()