빅데이터공부하기 31-1 WordCount 의사코드

 

Wordcount의사코드에 대해서 계속 공부해보겠습니다.

 

WordCount 의사코드

 

public static void main(String[] args) throws Exception

{

Configuration conf = new Configuration();             

     Job job=new Job(conf, "word count");

 

job.setJarByClass(WordCount.class);

    job.setMapperClass(Map.class);

job.setReducerClass(Reduce.class);

 

job.setOutputKeyClass(Test.class);

job.setOutputValueClass(LongWritable.class);

 

job.setInputFormatClass(TextInputFormat.class);

 job.setOutputFormatClass(TextOutputFormat.class);

 

FilelnputFormat.addlinputPath(job, new Path(args[0]));

 FileOutputFormat.setOutputPath(job, new Path(args[0]));

 

job.watiForCompletion(true);

}

 

 

 

다음글에서도 빅데이터공부하기는 계속됩니다.^^

 

 

+ Recent posts