MapReduce-드라이버 드라이브

드라이버는 주로 Mapper와 Reducer를 연결하고 프로그램 전체를 제출하는 데 사용됩니다.
구체적인 코드는 다음과 같습니다.

//   
public class FlowSumDriver {
 public static void main(String[] args){
  
  Configuration conf = new Configuration() ;
  // 1.   job  
  Job job = Job.getInstance(conf);
  // 2.   Jar   
  job.setJarByClass(FlowSumDriver);  
  // 3.    mapper   reducer 
  job.setMapperClass（FlowCountMapper.class）;
  job.setReducerClass（FlowCountReducer.class）;
  // 4.    mapper    key   value   
  job.setMapOutputKeyClass(Text.class);
  job.setMapOutputValueClass(FlowBean.class);
  // 5.        key   value
  job.setOutputKeyClass(Text.class);
  job.setOutputValueClass(FlowBean.class);
  // 6.         
  FileInputFormat.setInputPaths(job,new Path("e:\Input"));
  FileOutputFormat.setOutputPath(job,new Path("e:\output"))
  // 7.   job
  boolean  result = job.waitForCompletion(true);
  System.exit(result?0:1);
  //  result  true   0，   1；
  //0       ， 0      ；
  }
 }

구동 클래스는 총 7단계로 구성됩니다.

job 대상 획득

Jar의 경로 설정(현재 드라이브 클래스)

MapReduce-드라이버 드라이브

좋은 웹페이지 즐겨찾기