zoukankan      html  css  js  c++  java
  • mapReducer程序编写过程

    /*
        第一步    split    有系统自动切分
        第二步    map        撰写map类extemds Maper 复写Map方法;
        第三步    shuffle        
                    Partion        分区,将不同信息区分的分发到不同的Reducer中
                    Sort        排序,按照key的不同标准判断顺序
                    Group        分组,按照不同的key值判断相同的标准分组到一起
        第四步    Reducer        处理分组数据。输出信息。        

        自定义key值    implements writableComparable<>
        编写Map类
        重写Partion    extends    HashPartitioner<MyKey, DoubleWritable>
                        两个参数分别是自定义key的类型,和值得类型。
                        重写getPartion方法,(要求短小)
        重写sort方法    extends    writableCompare方法,
                    //使用父类构造方法加载并创建自定义key类。
                    public MySort(){
                        super(MyKey.class,true);
                    }
                    //重写compare方法,自定义比较标准。(需要将WritableComparable转化为指定类)
                    public int compare(WritableComparable a, WritableComparable b)
        重写分组方法    extends    writableCompare方法,
                    //使用父类构造方法加载并创建自定义key类。
                    public MySort(){
                        super(MyKey.class,true);
                    }
                    //重写compare方法,自定义比较标准。(需要将WritableComparable转化为指定类)
                    public int compare(WritableComparable a, WritableComparable b)
        编写Reduce类,extends Reducer<MyKey, DoubleWritable, Text, NullWritable>
                    重写 Reducer方法。输出。
        编写Job类        设置配置参数,创建Job类型,设置相关类。            
        
        
    */

  • 相关阅读:
    python网页抓取之英汉字典
    快速搭建建SSH服务
    dos文件批量转换成unix文件
    svn强制提交备注信息
    win7/8下VirtualBox虚拟共享文件夹设置
    CentOS SVN服务器安装配置小记
    CentOS中vsftp安装与配置
    sql执行顺序
    PHP最佳实践(译)
    python连接mysql数据库
  • 原文地址:https://www.cnblogs.com/Xmingzi/p/5774703.html
Copyright © 2011-2022 走看看