Hadoop示例程序WordCount详解及实例(转)

1.图解MapReduce

2.简历过程:

Input:

Hello World Bye World

Hello Hadoop Bye Hadoop

Bye Hadoop Hello Hadoop

Map:

<Hello,1>

<World,1>

<Bye,1>

<World,1>

<Hello,1>

<Hadoop,1>

<Bye,1>

<Hadoop,1>

<Bye,1>

<Hadoop,1>

<Hello,1>

<Hadoop,1>

Sort:

<Bye,1>

<Bye,1>

<Bye,1>

<Hadoop,1>

<Hadoop,1>

<Hadoop,1>

<Hadoop,1>

<Hello,1>

<Hello,1>

<Hello,1>

<World,1>

<World,1>

Combine:

<Bye,1,1,1>

<Hadoop,1,1,1,1>

<Hello,1,1,1>

<World,1,1>

Reduce:

<Bye,3>

<Hadoop,4>

<Hello,3>

<World,2>

3.代码实例:

[c-sharp] view plaincopy

  1. package com.felix;
  2. import java.io.IOException;
  3. import java.util.Iterator;
  4. import java.util.StringTokenizer;
  5. import org.apache.hadoop.fs.Path;
  6. import org.apache.hadoop.io.IntWritable;
  7. import org.apache.hadoop.io.LongWritable;
  8. import org.apache.hadoop.io.Text;
  9. import org.apache.hadoop.mapred.FileInputFormat;
  10. import org.apache.hadoop.mapred.FileOutputFormat;
  11. import org.apache.hadoop.mapred.JobClient;
  12. import org.apache.hadoop.mapred.JobConf;
  13. import org.apache.hadoop.mapred.MapReduceBase;
  14. import org.apache.hadoop.mapred.Mapper;
  15. import org.apache.hadoop.mapred.OutputCollector;
  16. import org.apache.hadoop.mapred.Reducer;
  17. import org.apache.hadoop.mapred.Reporter;
  18. import org.apache.hadoop.mapred.TextInputFormat;
  19. import org.apache.hadoop.mapred.TextOutputFormat;
  20. /**
  21. *
  22. * 描述:WordCount explains by Felix
  23. * @author Hadoop Dev Group
  24. */
  25. public class WordCount
  26. {
  27. /**
  28. * MapReduceBase类:实现了Mapper和Reducer接口的基类(其中的方法只是实现接口,而未作任何事情)
  29. * Mapper接口:
  30. * WritableComparable接口:实现WritableComparable的类可以相互比较。所有被用作key的类应该实现此接口。
  31. * Reporter 则可用于报告整个应用的运行进度,本例中未使用。
  32. *
  33. */
  34. public static class Map extends MapReduceBase implements
  35. Mapper<LongWritable, Text, Text, IntWritable>
  36. {
  37. /**
  38. * LongWritable, IntWritable, Text 均是 Hadoop 中实现的用于封装 Java 数据类型的类,这些类实现了WritableComparable接口,
  39. * 都能够被串行化从而便于在分布式环境中进行数据交换,你可以将它们分别视为long,int,String 的替代品。
  40. */
  41. private final static IntWritable one = new IntWritable(1);
  42. private Text word = new Text();
  43. /**
  44. * Mapper接口中的map方法:
  45. * void map(K1 key, V1 value, OutputCollector<K2,V2> output, Reporter reporter)
  46. * 映射一个单个的输入k/v对到一个中间的k/v对
  47. * 输出对不需要和输入对是相同的类型,输入对可以映射到0个或多个输出对。
  48. * OutputCollector接口:收集Mapper和Reducer输出的<k,v>对。
  49. * OutputCollector接口的collect(k, v)方法:增加一个(k,v)对到output
  50. */
  51. public void map(LongWritable key, Text value,
  52. OutputCollector<Text, IntWritable> output, Reporter reporter)
  53. throws IOException
  54. {
  55. String line = value.toString();
  56. StringTokenizer tokenizer = new StringTokenizer(line);
  57. while (tokenizer.hasMoreTokens())
  58. {
  59. word.set(tokenizer.nextToken());
  60. output.collect(word, one);
  61. }
  62. }
  63. }
  64. public static class Reduce extends MapReduceBase implements
  65. Reducer<Text, IntWritable, Text, IntWritable>
  66. {
  67. public void reduce(Text key, Iterator<IntWritable> values,
  68. OutputCollector<Text, IntWritable> output, Reporter reporter)
  69. throws IOException
  70. {
  71. int sum = 0;
  72. while (values.hasNext())
  73. {
  74. sum += values.next().get();
  75. }
  76. output.collect(key, new IntWritable(sum));
  77. }
  78. }
  79. public static void main(String[] args) throws Exception
  80. {
  81. /**
  82. * JobConf:map/reduce的job配置类,向hadoop框架描述map-reduce执行的工作
  83. * 构造方法:JobConf()、JobConf(Class exampleClass)、JobConf(Configuration conf)等
  84. */
  85. JobConf conf = new JobConf(WordCount.class);
  86. conf.setJobName("wordcount");           //设置一个用户定义的job名称
  87. conf.setOutputKeyClass(Text.class);    //为job的输出数据设置Key类
  88. conf.setOutputValueClass(IntWritable.class);   //为job输出设置value类
  89. conf.setMapperClass(Map.class);         //为job设置Mapper类
  90. conf.setCombinerClass(Reduce.class);      //为job设置Combiner类
  91. conf.setReducerClass(Reduce.class);        //为job设置Reduce类
  92. conf.setInputFormat(TextInputFormat.class);    //为map-reduce任务设置InputFormat实现类
  93. conf.setOutputFormat(TextOutputFormat.class);  //为map-reduce任务设置OutputFormat实现类
  94. /**
  95. * InputFormat描述map-reduce中对job的输入定义
  96. * setInputPaths():为map-reduce job设置路径数组作为输入列表
  97. * setInputPath():为map-reduce job设置路径数组作为输出列表
  98. */
  99. FileInputFormat.setInputPaths(conf, new Path(args[0]));
  100. FileOutputFormat.setOutputPath(conf, new Path(args[1]));
  101. JobClient.runJob(conf);         //运行一个job
  102. }
  103. }
时间: 2024-11-14 18:22:02

Hadoop示例程序WordCount详解及实例(转)的相关文章

(转载)Hadoop示例程序WordCount详解

最近在学习云计算,研究Haddop框架,费了一整天时间将Hadoop在Linux下完全运行起来,看到官方的map-reduce的demo程序WordCount,仔细研究了一下,算做入门了. 其实WordCount并不难,只是一下子接触到了很多的API,有一些陌生,还有就是很传统的开发相比,map-reduce确实是一种新的编程理念,为了让各位新手少走弯路,我将WordCount中的很多API都做了注释,其实这些方法搞明白了以后程序就很简单了,无非就是将一句话分词,先用map处理再用reduce处

Hadoop集群WordCount详解

Hadoop集群WordCount详解 MapReduce理论介绍 MapReduce处理过程 MapReduce代码 1.MapReduce 理论介绍 1.1 MapReduce编程模型 MapReduce采用"分而治之"的思想,把对大规模数据集的操作,分发给一个主节点管理下的各个分节点共同完成,然后通过整合各个节点的中间结果,得到最终结果.简单地说,MapReduce就是"任务的分解与结果的汇总". 在Hadoop中,用于执行MapReduce任务的机器角色有两

JStorm第一个程序WordCount详解

一.Strom基本知识(回顾) 1,首先明确Storm各个组件的作用,包括Nimbus,Supervisor,Spout,Bolt,Task,Worker,Tuple nimbus是整个storm任务的管理者,并不实际进行工作.负责在集群中分发代码,对节点分配任务,并监视主机故障. supervisor是实际进行工作的节点,负责监听工作节点上已经分配的主机作业,启动和停止Nimbus已经分配的工作进程. Worker是具体处理Spout/Bolt逻辑的进程,worker数量由拓扑中的conf.s

Hadoop示例程序wordcount分析

wordcount作为Hadoop的示例程序,其思想很简洁,但也值得去理解 尤其是作为Hadoop菜鸟的我 wordcount程序如下: package com.lcy.hadoop.examples; import java.io.IOException; import java.util.StringTokenizer; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import

运行Hadoop示例程序WordCount

WordCount程序的目标是统计几个文件中每个单词出现的次数,是官方提供的示例程序,这里使用的hadoop的版本为hadoop-1.2.1. 1).首先编写代码,将WordCount.java文件放到wordcount_classes文件夹中,代码如下: import java.io.IOException; import java.util.*; import org.apache.hadoop.fs.Path; import org.apache.hadoop.conf.*; import

Hadoop WordCount详解(二)

Hadoop集群WordCount详解(二) 源代码程序 WordCount处理过程 具体代码讲解 1.源代码程序 package org.apache.hadoop.examples; import java.io.IOException; import java.util.StringTokenizer; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.examples.WordCount.Token

5.hadoop流原理、实例和新旧API下Wordcount详解

前四篇文章讲了Hadoop的配置和测试以及eclipse下的使用,有兴趣的可以先看下. 1.Hadoop流简介 用可执行文件作为Mapper和Reducer,接受的都是标准输入,输出的都是标准输出. 当一个可执行文件作为Mapper时,每一个Map任务会以一个独立的进程启动这个可执行文件,然后在Map任务运行时,会把输入切分成行提供给可 执行文件,并作为它的标准输入(stdin)内容.当可执行文件运行出结果时,Map从标准输出(stdout)中收集数据,并将其转化 为<key, value>对

hadoop应用开发技术详解

<大 数据技术丛书:Hadoop应用开发技术详解>共12章.第1-2章详细地介绍了Hadoop的生态系统.关键技术以及安装和配置:第3章是 MapReduce的使用入门,让读者了解整个开发过程:第4-5章详细讲解了分布式文件系统HDFS和Hadoop的文件I/O:第6章分析了 MapReduce的工作原理:第7章讲解了如何利用Eclipse来编译Hadoop的源代码,以及如何对Hadoop应用进行测试和调试:第8-9章 细致地讲解了MapReduce的开发方法和高级应用:第10-12章系统地讲

Hadoop Hive sql语法详解

Hive 是基于Hadoop 构建的一套数据仓库分析系统,它提供了丰富的SQL查询方式来分析存储在Hadoop 分布式文件系统中的数据,可以将结构化的数据文件映射为一张数据库表,并提供完整的SQL查询功能,可以将SQL语句转换为MapReduce任务进行运行,通过自己的SQL 去查询分析需要的内容,这套SQL 简称Hive SQL,使不熟悉mapreduce 的用户很方便的利用SQL 语言查询,汇总,分析数据.而mapreduce开发人员可以把己写的mapper 和reducer 作为插件来支持