hadoop job 启动

hadoop job 启动
“”"
// public static void main(String[] args) throws Exception {
// String input = “hdfs://centos:9000/access.log.10”;
// String output = “hdfs://centos:9000/out_kpibrowser”;
//
// JobConf conf = new JobConf(KPIBrowser.class);
// conf.setJobName(“KPIBrowser”);
conf.addResource(“classpath:/hadoop/core-site.xml”);
conf.addResource(“classpath:/hadoop/hdfs-site.xml”);
conf.addResource(“classpath:/hadoop/mapred-site.xml”);
//
// conf.setOutputKeyClass(Text.class);
// conf.setOutputValueClass(IntWritable.class);
//
// conf.setMapperClass(KPIBrowserMapper.class);
// conf.setCombinerClass(KPIBrowserReducer.class);
// conf.setReducerClass(KPIBrowserReducer.class);
//
// conf.setInputFormat(TextInputFormat.class);
// conf.setOutputFormat(TextOutputFormat.class);
//
// FileInputFormat.setInputPaths(conf, new Path(input));
// FileOutputFormat.setOutputPath(conf, new Path(output));
// //启动任务
// JobClient.runJob(conf);
// System.exit(0);
“”"

最后

以上就是难过御姐最近收集整理的关于hadoop job 启动的全部内容，更多相关hadoop内容请搜索靠谱客的其他文章。