Home
last modified time | relevance | path

Searched refs:JobConf (Results 1 – 25 of 882) sorted by relevance

12345678910>>...36

/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/conf/
H A DTestJobConf.java28 JobConf configuration = new JobConf(); in testProfileParamsDefaults()
40 JobConf configuration = new JobConf(); in testProfileParamsSetter()
47 JobConf configuration = new JobConf(); in testProfileParamsGetter()
58 JobConf configuration = new JobConf(); in testMemoryConfigForMapOrReduceTask()
70 configuration = new JobConf(); in testMemoryConfigForMapOrReduceTask()
77 configuration = new JobConf(); in testMemoryConfigForMapOrReduceTask()
84 configuration = new JobConf(); in testMemoryConfigForMapOrReduceTask()
91 configuration = new JobConf(); in testMemoryConfigForMapOrReduceTask()
105 JobConf configuration = new JobConf(); in testNegativeValueForTaskVmem()
121 JobConf configuration = new JobConf(); in testNegativeValuesForMemoryParams()
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/conf/
H A DTestJobConf.java31 JobConf configuration = new JobConf(); in testProfileParamsDefaults()
40 JobConf configuration = new JobConf(); in testProfileParamsSetter()
48 JobConf configuration = new JobConf(); in testProfileParamsGetter()
60 JobConf configuration = new JobConf(); in testMemoryConfigForMapOrReduceTask()
72 configuration = new JobConf(); in testMemoryConfigForMapOrReduceTask()
79 configuration = new JobConf(); in testMemoryConfigForMapOrReduceTask()
86 configuration = new JobConf(); in testMemoryConfigForMapOrReduceTask()
108 JobConf configuration = new JobConf(); in testNegativeValueForTaskVmem()
128 JobConf configuration = new JobConf(); in testNegativeValuesForMemoryParams()
141 JobConf configuration = new JobConf(); in testMaxVirtualMemoryForTask()
[all …]
/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 DTestChild.java31 import org.apache.hadoop.mapred.JobConf;
58 String javaOpts = conf.get(JobConf.MAPRED_TASK_JAVA_OPTS); in setup()
59 assertNotNull(JobConf.MAPRED_TASK_JAVA_OPTS + " is null!", in setup()
66 assertNotNull(JobConf.MAPRED_MAP_TASK_JAVA_OPTS + " is null!", in setup()
74 Level.toLevel(conf.get(JobConf.MAPRED_MAP_TASK_LOG_LEVEL, in setup()
90 String javaOpts = conf.get(JobConf.MAPRED_TASK_JAVA_OPTS); in setup()
91 assertNotNull(JobConf.MAPRED_TASK_JAVA_OPTS + " is null!", in setup()
106 Level.toLevel(conf.get(JobConf.MAPRED_REDUCE_TASK_LOG_LEVEL, in setup()
118 conf.set(JobConf.MAPRED_TASK_JAVA_OPTS, TASK_OPTS_VAL); in submitAndValidateJob()
120 conf.set(JobConf.MAPRED_MAP_TASK_JAVA_OPTS, MAP_OPTS_VAL); in submitAndValidateJob()
[all …]
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapreduce/
H A DTestChild.java31 import org.apache.hadoop.mapred.JobConf;
57 String javaOpts = conf.get(JobConf.MAPRED_TASK_JAVA_OPTS); in setup()
58 assertNotNull(JobConf.MAPRED_TASK_JAVA_OPTS + " is null!", in setup()
60 assertEquals(JobConf.MAPRED_TASK_JAVA_OPTS + " has value of: " + in setup()
64 String mapJavaOpts = conf.get(JobConf.MAPRED_MAP_TASK_JAVA_OPTS); in setup()
65 assertNotNull(JobConf.MAPRED_MAP_TASK_JAVA_OPTS + " is null!", in setup()
83 String javaOpts = conf.get(JobConf.MAPRED_TASK_JAVA_OPTS); in setup()
84 assertNotNull(JobConf.MAPRED_TASK_JAVA_OPTS + " is null!", in setup()
105 conf.set(JobConf.MAPRED_TASK_JAVA_OPTS, TASK_OPTS_VAL); in submitAndValidateJob()
107 conf.set(JobConf.MAPRED_MAP_TASK_JAVA_OPTS, MAP_OPTS_VAL); in submitAndValidateJob()
[all …]
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/
H A DTestMiniMRChildTask.java82 public void configure(JobConf job) { in configure()
133 public void launchTest(JobConf conf, in launchTest()
182 public void configure(JobConf job) { in configure()
185 String javaOpts = job.get(JobConf.MAPRED_TASK_JAVA_OPTS); in configure()
232 public void configure(JobConf job) { in configure()
235 String javaOpts = job.get(JobConf.MAPRED_TASK_JAVA_OPTS); in configure()
323 JobConf conf = mr.createJobConf(); in testTaskTempDir()
347 JobConf conf = mr.createJobConf(); in testTaskEnv()
369 JobConf conf = mr.createJobConf(); in testTaskOldEnv()
394 String mapTaskEnvKey = JobConf.MAPRED_MAP_TASK_ENV; in runTestTaskEnv()
[all …]
H A DTestQueueManager.java60 JobConf conf = new JobConf(); in testDefaultQueueConfiguration()
70 JobConf conf = new JobConf(); in testMultipleQueues()
81 JobConf conf = new JobConf(); in testSchedulerInfo()
145 JobConf conf = new JobConf(); in testSubmissionToInvalidQueue()
167 JobConf conf in testUserEnabledACLForJobSubmission()
199 JobConf conf = new JobConf(); in testStateRefresh()
261 JobConf conf = new JobConf(); in setupConf()
262 conf.setBoolean(JobConf.MR_ACLS_ENABLED, true); in setupConf()
446 JobConf conf, final boolean shouldSucceed) in verifyJobPriorityChangeAsOtherUser()
546 JobConf clientConf = new JobConf(); in submitSleepJob()
[all …]
H A DTestTaskTrackerMemoryManager.java61 private void startCluster(JobConf conf) in startCluster()
151 startCluster(new JobConf()); in testTTLimitsDisabled()
153 JobConf conf = miniMRCluster.createJobConf(); in testTTLimitsDisabled()
176 JobConf fConf = new JobConf(); in testTasksWithinLimits()
182 startCluster(new JobConf()); in testTasksWithinLimits()
184 JobConf conf = new JobConf(miniMRCluster.createJobConf()); in testTasksWithinLimits()
204 JobConf fConf = new JobConf(); in testTasksBeyondLimits()
232 JobConf fConf = new JobConf(); in testTaskMemoryMonitoringWithDeprecatedConfiguration()
261 JobConf conf = new JobConf(miniMRCluster.createJobConf()); in runJobExceedingMemoryLimit()
327 JobConf fConf = new JobConf(); in testTasksCumulativelyExceedingTTLimits()
[all …]
H A DTestSubmitJob.java58 JobConf jConf = new JobConf(conf); in startCluster()
84 JobConf jtConf = new JobConf(); in testJobWithInvalidMemoryReqs()
96 JobConf clusterConf = mrCluster.createJobConf(); in testJobWithInvalidMemoryReqs()
99 JobConf jobConf = new JobConf(clusterConf); in testJobWithInvalidMemoryReqs()
105 jobConf = new JobConf(clusterConf); in testJobWithInvalidMemoryReqs()
111 jobConf = new JobConf(clusterConf); in testJobWithInvalidMemoryReqs()
118 jobConf = new JobConf(clusterConf); in testJobWithInvalidMemoryReqs()
130 JobConf jtConf = new JobConf(); in testJobWithInvalidDiskReqs()
139 JobConf jobConf = new JobConf(clusterConf); in testJobWithInvalidDiskReqs()
232 final JobConf job = mr.createJobConf(); in testSecureJobExecution()
[all …]
H A DTestJobKillAndFail.java40 JobConf jtConf = new JobConf(); in testJobFailAndKill()
48 JobConf conf = mr.createJobConf(); in testJobFailAndKill()
94 public JTInstrumentation(JobTracker jt, JobConf conf) { in JTInstrumentation()
98 public synchronized void addPrepJob(JobConf conf, JobID id) in addPrepJob()
103 public synchronized void decPrepJob(JobConf conf, JobID id) in decPrepJob()
108 public synchronized void addRunningJob(JobConf conf, JobID id) in addRunningJob()
113 public synchronized void decRunningJob(JobConf conf, JobID id) in decRunningJob()
118 public synchronized void failedJob(JobConf conf, JobID id) in failedJob()
123 public synchronized void killedJob(JobConf conf, JobID id) in killedJob()
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/
H A DJobTrackerInstrumentation.java31 public JobTrackerInstrumentation(JobTracker jt, JobConf conf) { in JobTrackerInstrumentation()
53 public void submitJob(JobConf conf, JobID id) in submitJob()
56 public void completeJob(JobConf conf, JobID id) in completeJob()
59 public void terminateJob(JobConf conf, JobID id) in terminateJob()
62 public void finalizeJob(JobConf conf, JobID id) in finalizeJob()
119 public void failedJob(JobConf conf, JobID id) in failedJob()
122 public void killedJob(JobConf conf, JobID id) in killedJob()
125 public void addPrepJob(JobConf conf, JobID id) in addPrepJob()
128 public void decPrepJob(JobConf conf, JobID id) in decPrepJob()
131 public void addRunningJob(JobConf conf, JobID id) in addRunningJob()
[all …]
H A DFileOutputFormat.java42 public static void setCompressOutput(JobConf conf, boolean compress) { in setCompressOutput()
52 public static boolean getCompressOutput(JobConf conf) { in getCompressOutput()
63 setOutputCompressorClass(JobConf conf, in setOutputCompressorClass()
79 getOutputCompressorClass(JobConf conf, in getOutputCompressorClass()
101 public void checkOutputSpecs(FileSystem ignored, JobConf job) in checkOutputSpecs()
134 public static void setOutputPath(JobConf conf, Path outputDir) { in setOutputPath()
150 static void setWorkOutputPath(JobConf conf, Path outputDir) { in setWorkOutputPath()
161 public static Path getOutputPath(JobConf conf) { in getOutputPath()
217 public static Path getWorkOutputPath(JobConf conf) { in getWorkOutputPath()
231 public static Path getTaskOutputPath(JobConf conf, String name) in getTaskOutputPath()
[all …]
H A DReduceTaskRunner.java28 JobConf conf, TaskTracker.RunningJob rjob in ReduceTaskRunner()
54 public String getChildJavaOpts(JobConf jobConf, String defaultValue) { in getChildJavaOpts()
56 jobConf.get(JobConf.MAPRED_REDUCE_TASK_JAVA_OPTS, in getChildJavaOpts()
58 JobConf.DEFAULT_MAPRED_TASK_JAVA_OPTS)); in getChildJavaOpts()
65 public int getChildUlimit(JobConf jobConf) { in getChildUlimit()
66 return jobConf.getInt(JobConf.MAPRED_REDUCE_TASK_ULIMIT, in getChildUlimit()
71 public String getChildEnv(JobConf jobConf) { in getChildEnv()
72 return jobConf.get(JobConf.MAPRED_REDUCE_TASK_ENV, in getChildEnv()
H A DMapTaskRunner.java27 public MapTaskRunner(TaskInProgress task, TaskTracker tracker, JobConf conf, in MapTaskRunner()
50 public String getChildJavaOpts(JobConf jobConf, String defaultValue) { in getChildJavaOpts()
52 jobConf.get(JobConf.MAPRED_MAP_TASK_JAVA_OPTS, in getChildJavaOpts()
54 JobConf.DEFAULT_MAPRED_TASK_JAVA_OPTS)); in getChildJavaOpts()
62 public int getChildUlimit(JobConf jobConf) { in getChildUlimit()
63 return jobConf.getInt(JobConf.MAPRED_MAP_TASK_ULIMIT, in getChildUlimit()
68 public String getChildEnv(JobConf jobConf) { in getChildEnv()
69 return jobConf.get(JobConf.MAPRED_MAP_TASK_ENV, super.getChildEnv(jobConf)); in getChildEnv()
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/lib/
H A DChain.java74 private JobConf chainJobConf;
122 private static JobConf getChainElementConf(JobConf jobConf, String confKey) { in getChainElementConf()
123 JobConf conf; in getChainElementConf()
126 new DefaultStringifier<JobConf>(jobConf, JobConf.class); in getChainElementConf()
134 jobConf = new JobConf(jobConf); in getChainElementConf()
187 JobConf reducerConf = in addMapper()
202 JobConf previousMapperConf = in addMapper()
237 new DefaultStringifier<JobConf>(jobConf, JobConf.class); in addMapper()
304 new DefaultStringifier<JobConf>(jobConf, JobConf.class); in setReducer()
328 JobConf mConf = in configure()
[all …]
H A DMultipleOutputs.java145 private static void checkNamedOutput(JobConf conf, String namedOutput, in checkNamedOutput()
204 public static List<String> getNamedOutputsList(JobConf conf) { in getNamedOutputsList()
236 JobConf conf, String namedOutput) { in getNamedOutputFormatClass()
283 public static void addNamedOutput(JobConf conf, String namedOutput, in addNamedOutput()
324 private static void addNamedOutput(JobConf conf, String namedOutput, in addNamedOutput()
353 public static void setCountersEnabled(JobConf conf, boolean enabled) { in setCountersEnabled()
373 public static boolean getCountersEnabled(JobConf conf) { in getCountersEnabled()
379 private JobConf conf;
391 public MultipleOutputs(JobConf job) { in MultipleOutputs()
422 JobConf jobConf = new JobConf(conf); in getRecordWriter()
[all …]
/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/lib/
H A DTestChain.java22 import org.apache.hadoop.mapred.JobConf;
30 JobConf jobConf = new JobConf(); in testSetReducerWithReducerByValueAsTrue()
31 JobConf reducerConf = new JobConf(); in testSetReducerWithReducerByValueAsTrue()
43 JobConf jobConf = new JobConf(); in testSetReducerWithReducerByValueAsFalse()
44 JobConf reducerConf = new JobConf(); in testSetReducerWithReducerByValueAsFalse()
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/test/org/apache/hadoop/mapred/gridmix/
H A DTestHighRamJob.java26 import org.apache.hadoop.mapred.JobConf;
88 sourceConf.setLong(JobConf.MAPRED_JOB_REDUCE_MEMORY_MB_PROPERTY, in testHighRamConfig()
102 JobConf.MAPRED_JOB_MAP_MEMORY_MB_PROPERTY, in testHighRamConfig()
103 JobConf.DISABLED_MEMORY_LIMIT)); in testHighRamConfig()
106 JobConf.DISABLED_MEMORY_LIMIT)); in testHighRamConfig()
121 JobConf.DISABLED_MEMORY_LIMIT, in testHighRamFeatureEmulation()
122 JobConf.DISABLED_MEMORY_LIMIT, in testHighRamFeatureEmulation()
123 JobConf.DISABLED_MEMORY_LIMIT, gridmixConf); in testHighRamFeatureEmulation()
128 gridmixConf.setLong(JobConf.UPPER_LIMIT_ON_TASK_VMEM_PROPERTY, in testHighRamFeatureEmulation()
144 gridmixConf.setLong(JobConf.UPPER_LIMIT_ON_TASK_VMEM_PROPERTY, in testHighRamFeatureEmulation()
[all …]
H A DTestGridmixMemoryEmulation.java27 import org.apache.hadoop.mapred.JobConf;
324 simulatedConf.set(JobConf.MAPRED_REDUCE_TASK_JAVA_OPTS, in testJavaHeapOptions()
348 originalConf.set(JobConf.MAPRED_TASK_JAVA_OPTS, taskOptions); in testJavaHeapOptions()
359 simulatedConf.get(JobConf.MAPRED_TASK_JAVA_OPTS)); in testJavaHeapOptions()
425 gridmixConf.set(JobConf.MAPRED_MAP_TASK_JAVA_OPTS, "-Xmx1m"); in testJavaHeapOptionsDisabled()
427 gridmixConf.set(JobConf.MAPRED_TASK_JAVA_OPTS, "-Xmx3m"); in testJavaHeapOptionsDisabled()
430 final JobConf originalConf = new JobConf(); in testJavaHeapOptionsDisabled()
431 originalConf.set(JobConf.MAPRED_MAP_TASK_JAVA_OPTS, "-Xmx10m"); in testJavaHeapOptionsDisabled()
433 originalConf.set(JobConf.MAPRED_TASK_JAVA_OPTS, "-Xmx30m"); in testJavaHeapOptionsDisabled()
437 public JobConf getJobConf() { in testJavaHeapOptionsDisabled()
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapred/
H A DTestJobConf.java40 JobConf conf = new JobConf(); in testJobConf()
150 JobConf.deprecatedString("key")); in testJobConf()
155 null, conf.get(JobConf.MAPRED_MAP_TASK_JAVA_OPTS)); in testJobConf()
157 null, conf.get(JobConf.MAPRED_REDUCE_TASK_JAVA_OPTS)); in testJobConf()
167 JobConf configuration = new JobConf(); in testDeprecatedPropertyNameForTaskVmem()
169 configuration.setLong(JobConf.MAPRED_JOB_MAP_MEMORY_MB_PROPERTY, 1024); in testDeprecatedPropertyNameForTaskVmem()
170 configuration.setLong(JobConf.MAPRED_JOB_REDUCE_MEMORY_MB_PROPERTY, 1024); in testDeprecatedPropertyNameForTaskVmem()
182 JobConf.MAPRED_JOB_MAP_MEMORY_MB_PROPERTY, -1)); in testDeprecatedPropertyNameForTaskVmem()
184 JobConf.MAPRED_JOB_REDUCE_MEMORY_MB_PROPERTY, -1)); in testDeprecatedPropertyNameForTaskVmem()
187 JobConf.MAPREDUCE_JOB_MAP_MEMORY_MB_PROPERTY, -1)); in testDeprecatedPropertyNameForTaskVmem()
[all …]
/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 DTestMiniMRChildTask.java104 public void configure(JobConf job) { in configure()
125 public void configure(JobConf job) { in configure()
178 public void launchTest(JobConf conf, in launchTest()
221 public void configure(JobConf job) { in configure()
224 String javaOpts = job.get(JobConf.MAPRED_TASK_JAVA_OPTS); in configure()
288 public void configure(JobConf job) { in configure()
437 JobConf conf = new JobConf(mr.getConfig()); in testMapRedExecutionEnv()
464 JobConf conf = new JobConf(mr.getConfig()); in testTaskEnv()
487 JobConf conf = new JobConf(mr.getConfig()); in testTaskOldEnv()
512 String mapTaskEnvKey = JobConf.MAPRED_MAP_TASK_ENV; in runTestTaskEnv()
[all …]
H A DMiniMRCluster.java96 public JobConf createJobConf() { in createJobConf()
97 JobConf jobConf = null; in createJobConf()
99 jobConf = new JobConf(mrClientCluster.getConfig()); in createJobConf()
106 public JobConf createJobConf(JobConf conf) { in createJobConf()
107 JobConf jobConf = null; in createJobConf()
109 jobConf = new JobConf(mrClientCluster.getConfig()); in createJobConf()
116 static JobConf configureJobConf(JobConf conf, String namenode, in configureJobConf()
183 if (conf == null) conf = new JobConf(); in MiniMRCluster()
222 public JobConf getJobTrackerConf() { in getJobTrackerConf()
223 JobConf jobConf = null; in getJobTrackerConf()
[all …]
/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 DJobConf.java422 public JobConf() { in JobConf() method in JobConf
431 public JobConf(Class exampleClass) { in JobConf() method in JobConf
441 public JobConf(Configuration conf) { in JobConf() method in JobConf
444 if (conf instanceof JobConf) { in JobConf()
445 JobConf that = (JobConf)conf; in JobConf()
468 public JobConf(String config) { in JobConf() method in JobConf
476 public JobConf(Path config) { in JobConf() method in JobConf
2008 LOG.warn(JobConf.deprecatedString(JobConf.MAPRED_TASK_MAXVMEM_PROPERTY) in checkAndWarnDeprecation()
2013 LOG.warn(JobConf.deprecatedString(JobConf.MAPRED_TASK_ULIMIT)); in checkAndWarnDeprecation()
2016 LOG.warn(JobConf.deprecatedString(JobConf.MAPRED_MAP_TASK_ULIMIT)); in checkAndWarnDeprecation()
[all …]
/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 DMultipleOutputs.java206 public static List<String> getNamedOutputsList(JobConf conf) { in getNamedOutputsList()
238 JobConf conf, String namedOutput) { in getNamedOutputFormatClass()
251 public static Class<?> getNamedOutputKeyClass(JobConf conf, in getNamedOutputKeyClass()
265 public static Class<?> getNamedOutputValueClass(JobConf conf, in getNamedOutputValueClass()
284 public static void addNamedOutput(JobConf conf, String namedOutput, in addNamedOutput()
323 private static void addNamedOutput(JobConf conf, String namedOutput, in addNamedOutput()
372 public static boolean getCountersEnabled(JobConf conf) { in getCountersEnabled()
378 private JobConf conf;
390 public MultipleOutputs(JobConf job) { in MultipleOutputs()
421 JobConf jobConf = new JobConf(conf); in getRecordWriter()
[all …]
/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 DMapReduceChildJVM.java46 return jobConf.get(JobConf.MAPRED_MAP_TASK_ENV, in getChildEnv()
47 jobConf.get(JobConf.MAPRED_TASK_ENV)); in getChildEnv()
49 return jobConf.get(JobConf.MAPRED_REDUCE_TASK_ENV, in getChildEnv()
50 jobConf.get(JobConf.MAPRED_TASK_ENV)); in getChildEnv()
56 JobConf conf = task.conf; in setVMEnv()
107 JobConf.MAPRED_MAP_TASK_JAVA_OPTS, in getChildJavaOpts()
109 JobConf.MAPRED_TASK_JAVA_OPTS, in getChildJavaOpts()
110 JobConf.DEFAULT_MAPRED_TASK_JAVA_OPTS) in getChildJavaOpts()
119 JobConf.MAPRED_REDUCE_TASK_JAVA_OPTS, in getChildJavaOpts()
121 JobConf.MAPRED_TASK_JAVA_OPTS, in getChildJavaOpts()
[all …]
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/pipes/
H A DSubmitter.java52 import org.apache.hadoop.mapred.JobConf;
84 public static String getExecutable(JobConf conf) { in getExecutable()
112 public static boolean getIsJavaRecordReader(JobConf conf) { in getIsJavaRecordReader()
121 public static void setIsJavaMapper(JobConf conf, boolean value) { in setIsJavaMapper()
130 public static boolean getIsJavaMapper(JobConf conf) { in getIsJavaMapper()
148 public static boolean getIsJavaReducer(JobConf conf) { in getIsJavaReducer()
166 public static boolean getIsJavaRecordWriter(JobConf conf) { in getIsJavaRecordWriter()
188 static void setJavaPartitioner(JobConf conf, Class cls) { in setJavaPartitioner()
215 public static boolean getKeepCommandFile(JobConf conf) { in getKeepCommandFile()
369 JobConf conf, in getClass()
[all …]

12345678910>>...36