Java 类org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorJob 实例源码

项目：hadoop 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hadoop 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：aliyun-oss-hadoop-fs 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：aliyun-oss-hadoop-fs 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：big-c 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：big-c 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hadoop-plus 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hadoop-plus 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：FlexMap 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：FlexMap 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hops 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hops 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：glusterfs-hadoop-examples 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：glusterfs-hadoop-examples 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：stats-hdfs 文件：AggregateWordCount.java

/**
    * 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, InterruptedException, ClassNotFoundException {
long random = new Random().nextLong();
log.info("random -> " + random);
args = new String[] { String.format(ConfigUtils.HDFS.WORDCOUNT_IN, "word.txt"), String.format(ConfigUtils.HDFS.WORDCOUNT_OUT, random) };
Job job = ValueAggregatorJob.createValueAggregatorJob(args, new Class[] { WordCountPlugInClass.class });
job.setJarByClass(AggregateWordCount.class);
job.setInputFormatClass(TextInputFormat.class);
int ret = job.waitForCompletion(true) ? 0 : 1;
System.exit(ret);
   }

项目：stats-hdfs 文件：AggregateWordHistogram.java

/**
    * 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, InterruptedException, ClassNotFoundException {
long random = new Random().nextLong();
log.info("random -> " + random);
args = new String[] { String.format(ConfigUtils.HDFS.WORDCOUNT_IN, "word.txt"), String.format(ConfigUtils.HDFS.WORDCOUNT_OUT, random) };
Job job = ValueAggregatorJob.createValueAggregatorJob(args, new Class[] { AggregateWordHistogramPlugin.class });
job.setJarByClass(AggregateWordCount.class);
job.setInputFormatClass(TextInputFormat.class);
int ret = job.waitForCompletion(true) ? 0 : 1;
System.exit(ret);
   }

项目：hadoop-TCP 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hadoop-TCP 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hardfs 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hardfs 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hadoop-on-lustre2 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：hadoop-on-lustre2 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：mapreduce-fork 文件：AggregateWordCount.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {WordCountPlugInClass.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}

项目：mapreduce-fork 文件：AggregateWordHistogram.java

/**
 * 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, InterruptedException, ClassNotFoundException  {
  Job job = ValueAggregatorJob.createValueAggregatorJob(args
      , new Class[] {AggregateWordHistogramPlugin.class});
  job.setJarByClass(AggregateWordCount.class);
  int ret = job.waitForCompletion(true) ? 0 : 1;
  System.exit(ret);
}