- Configuration conf = new Configuration();
- String[] otherArgs = new GenericOptionsParser(conf, args)
- .getRemainingArgs();
- if (otherArgs.length < 2) {
- System.err.println("Usage: wordcount <in> [<in>...] <out>");
- System.exit(2);
- }
- Job job = new Job(conf, "My Test");
- job.setJarByClass(MapReduce2.class);
- job.setMapperClass(TokenizerMapper.class);
- job.setCombinerClass(IntSumReducer.class);
- job.setReducerClass(IntSumReducer.class);
- job.setOutputKeyClass(Text.class);
- job.setOutputValueClass(Text.class);
复制代码
咨询一下,2.5.2的这个WordCount例子,启动job的时候有使用YARN吗?新手一个,表示不太懂怎么算是使用了YARN框架。。
|