/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/ |
H A D | TestDuplicateArchiveFileCachedURLMinicluster.java | 46 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt")); in testDuplicationsMinicluster() 69 FileInputFormat.setInputPaths(conf, getInputDir()); in testDuplicationsMinicluster() 73 Path inputRoot = getInputDir().makeQualified(getFileSystem()); in testDuplicationsMinicluster() 74 Path unqualifiedInputRoot = getInputDir(); in testDuplicationsMinicluster() 102 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text2.txt")); in testApparentDuplicationsMinicluster() 127 FileInputFormat.setInputPaths(conf, getInputDir()); in testApparentDuplicationsMinicluster() 131 Path localInputRoot = getInputDir().makeQualified(lfs); in testApparentDuplicationsMinicluster() 132 Path dfsInputRoot = getInputDir().makeQualified(getFileSystem()); in testApparentDuplicationsMinicluster() 133 Path unqualifiedInputRoot = getInputDir(); in testApparentDuplicationsMinicluster()
|
H A D | TestJobName.java | 40 OutputStream os = getFileSystem().create(new Path(getInputDir(), in testComplexName() 56 FileInputFormat.setInputPaths(conf, getInputDir()); in testComplexName() 75 OutputStream os = getFileSystem().create(new Path(getInputDir(), in testComplexNameWithRegex() 91 FileInputFormat.setInputPaths(conf, getInputDir()); in testComplexNameWithRegex()
|
H A D | TestJavaSerialization.java | 69 OutputStream os = getFileSystem().create(new Path(getInputDir(), in testMapReduceJob() 91 FileInputFormat.setInputPaths(conf, getInputDir()); in testMapReduceJob() 116 OutputStream os = getFileSystem().create(new Path(getInputDir(), in testWriteToSequencefile() 139 FileInputFormat.setInputPaths(conf, getInputDir()); in testWriteToSequencefile()
|
H A D | TestClusterMapReduceTestCase.java | 30 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt")); in _testMapReduce() 58 FileInputFormat.setInputPaths(conf, getInputDir()); in _testMapReduce() 93 Path file = new Path(getInputDir(), "text.txt"); in testDFSRestart()
|
H A D | TestJobClient.java | 45 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt")); in runJob() 68 FileInputFormat.setInputPaths(conf, getInputDir()); in runJob()
|
H A D | TestUserDefinedCounters.java | 81 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt")); in testMapReduceJob() 104 FileInputFormat.setInputPaths(conf, getInputDir()); in testMapReduceJob()
|
H A D | TestJobStatusPersistency.java | 43 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt")); in runJob() 66 FileInputFormat.setInputPaths(conf, getInputDir()); in runJob()
|
H A D | TestNonLocalJobJarSubmission.java | 48 OutputStream os = hdfs.create(new Path(getInputDir(), "dummy.txt")); in testNonLocalJobJarSubmission() 70 FileInputFormat.setInputPaths(conf, getInputDir()); in testNonLocalJobJarSubmission()
|
H A D | ClusterMapReduceTestCase.java | 198 protected Path getInputDir() { in getInputDir() method in ClusterMapReduceTestCase
|
H A D | TestBadRecords.java | 86 FileInputFormat.setInputPaths(conf, getInputDir()); in runMapReduce() 100 OutputStream os = getFileSystem().create(new Path(getInputDir(), in createInput()
|
/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 D | TestJobName.java | 35 OutputStream os = getFileSystem().create(new Path(getInputDir(), in testComplexName() 51 FileInputFormat.setInputPaths(conf, getInputDir()); in testComplexName() 69 OutputStream os = getFileSystem().create(new Path(getInputDir(), in testComplexNameWithRegex() 85 FileInputFormat.setInputPaths(conf, getInputDir()); in testComplexNameWithRegex()
|
H A D | TestClusterMapReduceTestCase.java | 34 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt")); in _testMapReduce() 62 FileInputFormat.setInputPaths(conf, getInputDir()); in _testMapReduce() 97 Path file = new Path(getInputDir(), "text.txt"); in testDFSRestart()
|
H A D | TestMRCJCJobClient.java | 37 OutputStream os = getFileSystem().create(new Path(getInputDir(), in runJob() 61 FileInputFormat.setInputPaths(conf, getInputDir()); in runJob()
|
H A D | ClusterMapReduceTestCase.java | 178 protected Path getInputDir() { in getInputDir() method in ClusterMapReduceTestCase
|
H A D | TestBadRecords.java | 88 FileInputFormat.setInputPaths(conf, getInputDir()); in runMapReduce() 102 OutputStream os = getFileSystem().create(new Path(getInputDir(), in createInput()
|
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/streaming/src/test/org/apache/hadoop/streaming/ |
H A D | TestStreamingBadRecords.java | 70 OutputStream os = getFileSystem().create(new Path(getInputDir(), in createInput() 159 "-input", (new Path(getInputDir(), "text.txt")).toString(), in testSkip() 192 "-input", (new Path(getInputDir(), "text.txt")).toString(), in testNarrowDown()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/ |
H A D | TestMRJobClient.java | 57 Job job = MapReduceTestUtil.createJob(conf, getInputDir(), getOutputDir(), in runJob() 68 Job job = MapReduceTestUtil.createJob(conf, getInputDir(), getOutputDir(), in runJobInBackGround() 102 Job job = MapReduceTestUtil.createJob(conf, getInputDir(), getOutputDir(), in testJobSubmissionSpecsAndFiles() 224 Job job = MapReduceTestUtil.createJob(conf, getInputDir(), getOutputDir(), in testSubmit()
|
/dports/biology/mothur/mothur-1.46.1/source/commands/ |
H A D | command.hpp | 29 inputdir = current->getInputDir(); in Command()
|
H A D | getcurrentcommand.cpp | 185 string inputDir = current->getInputDir(); in execute()
|
/dports/biology/mothur/mothur-1.46.1/source/datastructures/ |
H A D | filefile.cpp | 19 inputDir = current->getInputDir(); in FileFile()
|
/dports/biology/mothur/mothur-1.46.1/source/ |
H A D | commandfactory.cpp | 592 if (current->getInputDir() != "") { in getCommand() 593 if (optionString != "") { optionString += ", inputdir=" + current->getInputDir(); } in getCommand() 594 else { optionString += "inputdir=" + current->getInputDir(); } in getCommand()
|
H A D | optionparser.cpp | 193 string inputDir = current->getInputDir(); in getParameters()
|
H A D | currentfile.h | 109 string getInputDir() { lock_guard<std::mutex> guard(currentProtector); return inputDir; } in getInputDir() function
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-streaming/src/test/java/org/apache/hadoop/streaming/ |
H A D | TestStreamingBadRecords.java | 79 OutputStream os = getFileSystem().create(new Path(getInputDir(), in createInput()
|