Класс Hadoop JobConf устарел, требуется обновить пример

Я пишу программы hadoop, и я действительно не хочу играть с устаревшими классами. Нигде в сети я не могу найти программы с обновленным классом

org.apache.hadoop.conf.Configuration

insted из класса

org.apache.hadoop.mapred.JobConf

.

   public static void main(String[] args) throws Exception {
     JobConf conf = new JobConf(Test.class);
     conf.setJobName("TESST");

     conf.setOutputKeyClass(Text.class);
     conf.setOutputValueClass(IntWritable.class);

     conf.setMapperClass(Map.class);
     conf.setCombinerClass(Reduce.class);
     conf.setReducerClass(Reduce.class);

     conf.setInputFormat(TextInputFormat.class);
     conf.setOutputFormat(TextOutputFormat.class);

     FileInputFormat.setInputPaths(conf, new Path(args[0]));
     FileOutputFormat.setOutputPath(conf, new Path(args[1]));

     JobClient.runJob(conf);
   }

Так выглядит мой main (). Может, кто угодно предоставит мне обновленную функцию.

12
задан CodeBanger 22 December 2011 в 12:21
поделиться