import org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob; //导入依赖的package包/类
/**
 * The main driver for word count map/reduce program. Invoke this method to
 * submit the map/reduce job.
 * 
 * @throws IOException
 *           When there is communication problems with the job tracker.
 */
@SuppressWarnings("unchecked")
public static void main(String[] args) throws IOException {
  JobConf conf = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class}, AggregateWordCount.class);
 
  JobClient.runJob(conf);
}
 

import org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob; //导入依赖的package包/类
/**
 * The main driver for word count map/reduce program. Invoke this method to
 * submit the map/reduce job.
 * 
 * @throws IOException
 *           When there is communication problems with the job tracker.
 */
@SuppressWarnings("unchecked")
public static void main(String[] args) throws IOException {
  JobConf conf = ValueAggregatorJob.createValueAggregatorJob(args,
      new Class[] { AggregateWordHistogramPlugin.class },
      AggregateWordHistogram.class);
  
  JobClient.runJob(conf);
}
 

import org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob; //导入依赖的package包/类
/**
 * The main driver for word count map/reduce program. Invoke this method to
 * submit the map/reduce job.
 * 
 * @throws IOException
 *           When there is communication problems with the job tracker.
 */
@SuppressWarnings("unchecked")
public static void main(String[] args) throws IOException {
  JobConf conf = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
 
  JobClient.runJob(conf);
}
 

import org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob; //导入依赖的package包/类
/**
 * The main driver for word count map/reduce program. Invoke this method to
 * submit the map/reduce job.
 * 
 * @throws IOException
 *           When there is communication problems with the job tracker.
 */
@SuppressWarnings("unchecked")
public static void main(String[] args) throws IOException {
  JobConf conf = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  
  JobClient.runJob(conf);
}
 

import org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob; //导入依赖的package包/类
/**
 * The main driver for word count map/reduce program. Invoke this method to
 * submit the map/reduce job.
 *
 * @throws IOException When there is communication problems with the job
 * tracker.
 */
@SuppressWarnings("unchecked")
public static void main(String[] args) throws IOException {
    JobConf conf = ValueAggregatorJob.createValueAggregatorJob(args, new Class[]{WordCountPlugInClass.class});

    JobClient.runJob(conf);
}
 

import org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob; //导入依赖的package包/类
/**
 * The main driver for word count map/reduce program. Invoke this method to
 * submit the map/reduce job.
 *
 * @throws IOException When there is communication problems with the job
 * tracker.
 */
@SuppressWarnings("unchecked")
public static void main(String[] args) throws IOException {
    JobConf conf = ValueAggregatorJob.createValueAggregatorJob(args, new Class[]{AggregateWordHistogramPlugin.class});

    JobClient.runJob(conf);
}