Home
last modified time | relevance | path

Searched refs:MAP_INPUT_FILE (Results 1 – 11 of 11) sorted by relevance

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-datajoin/src/main/java/org/apache/hadoop/contrib/utils/join/
H A DDataJoinMapperBase.java59 this.inputFile = job.get(MRJobConfig.MAP_INPUT_FILE); 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/lib/input/
H A DCombineFileRecordReaderWrapper.java82 String path = conf.get(MRJobConfig.MAP_INPUT_FILE); in fileSplitIsValid()
H A DCombineFileRecordReader.java148 conf.set(MRJobConfig.MAP_INPUT_FILE, split.getPath(idx).toString()); in initNextRecordReader()
/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/lib/
H A DCombineFileRecordReader.java146 jc.set(JobContext.MAP_INPUT_FILE, split.getPath(idx).toString()); in initNextRecordReader()
H A DMultipleOutputFormat.java193 String infilepath = job.get(MRJobConfig.MAP_INPUT_FILE); in getInputFileBasedOutputFileName()
/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/lib/aggregate/
H A DValueAggregatorBaseDescriptor.java164 this.inputFile = conf.get(MRJobConfig.MAP_INPUT_FILE); in configure()
/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 DTestMultipleTextOutputFormat.java78 job.set(JobContext.MAP_INPUT_FILE, "1/2/3"); in test2()
H A DSortValidator.java71 Path inputFile = new Path(job.get(JobContext.MAP_INPUT_FILE)); in deduceInputFile()
215 URI inputURI = new URI(job.get(JobContext.MAP_INPUT_FILE)); 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.java234 public static final String MAP_INPUT_FILE = "mapreduce.map.input.file"; field
/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.java310 MRJobConfig.MAP_INPUT_FILE), in addDeprecatedKeys()
/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 DMapTask.java481 job.set(JobContext.MAP_INPUT_FILE, fileSplit.getPath().toString()); in updateJobWithSplit()