Home
last modified time | relevance | path

Searched refs:getInputDir (Results 1 – 24 of 24) sorted by relevance

/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/
H A DTestDuplicateArchiveFileCachedURLMinicluster.java46 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 DTestJobName.java40 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 DTestJavaSerialization.java69 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 DTestClusterMapReduceTestCase.java30 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 DTestJobClient.java45 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt")); in runJob()
68 FileInputFormat.setInputPaths(conf, getInputDir()); in runJob()
H A DTestUserDefinedCounters.java81 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt")); in testMapReduceJob()
104 FileInputFormat.setInputPaths(conf, getInputDir()); in testMapReduceJob()
H A DTestJobStatusPersistency.java43 OutputStream os = getFileSystem().create(new Path(getInputDir(), "text.txt")); in runJob()
66 FileInputFormat.setInputPaths(conf, getInputDir()); in runJob()
H A DTestNonLocalJobJarSubmission.java48 OutputStream os = hdfs.create(new Path(getInputDir(), "dummy.txt")); in testNonLocalJobJarSubmission()
70 FileInputFormat.setInputPaths(conf, getInputDir()); in testNonLocalJobJarSubmission()
H A DClusterMapReduceTestCase.java198 protected Path getInputDir() { in getInputDir() method in ClusterMapReduceTestCase
H A DTestBadRecords.java86 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 DTestJobName.java35 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 DTestClusterMapReduceTestCase.java34 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 DTestMRCJCJobClient.java37 OutputStream os = getFileSystem().create(new Path(getInputDir(), in runJob()
61 FileInputFormat.setInputPaths(conf, getInputDir()); in runJob()
H A DClusterMapReduceTestCase.java178 protected Path getInputDir() { in getInputDir() method in ClusterMapReduceTestCase
H A DTestBadRecords.java88 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 DTestStreamingBadRecords.java70 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 DTestMRJobClient.java57 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 Dcommand.hpp29 inputdir = current->getInputDir(); in Command()
H A Dgetcurrentcommand.cpp185 string inputDir = current->getInputDir(); in execute()
/dports/biology/mothur/mothur-1.46.1/source/datastructures/
H A Dfilefile.cpp19 inputDir = current->getInputDir(); in FileFile()
/dports/biology/mothur/mothur-1.46.1/source/
H A Dcommandfactory.cpp592 if (current->getInputDir() != "") { in getCommand()
593 if (optionString != "") { optionString += ", inputdir=" + current->getInputDir(); } in getCommand()
594 else { optionString += "inputdir=" + current->getInputDir(); } in getCommand()
H A Doptionparser.cpp193 string inputDir = current->getInputDir(); in getParameters()
H A Dcurrentfile.h109 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 DTestStreamingBadRecords.java79 OutputStream os = getFileSystem().create(new Path(getInputDir(), in createInput()