zoukankan      html  css  js  c++  java
  • java程序,用于mapreduce处理数据

    1、通过传统的key-value类分析数据

    创建key类时,所有key都要继承writablecomparable接口

    public class sendorkey implements writablecomparable

    {

      default constructor+parameterized constructor

      implementation of readfields method

      implementation of write method

      overriding the compare to method

    }

    Sensorkey.java

      SensorValue.java

    【注明:默认构造函数对变量进行初始化设置

    带参数的构造函数通过其参数值对类变量进行初始化设置

    默认的readfields方法的参数为datainput,不管内容是什么,我们都是使用readfield方法来接受和传递输入到这个类中的数据,同理不论dataoutput的内容是什么,write方法都会输出这些数据

    在compreto方法逻辑中,我们将对于不同的传感器进行比较

    每个属性都含有一个get和set方法】

    2、creating a customized recordreader class(如何创建自定义的recordreader类)

     

    【注明:自定义recordreader会继承默认的recordreader,他的参数时自定义的key,value类型,在nextkeyvalue,我们从含有完整记录的reader获取当前值。记录中,根据TDB键拆分这些列,并把前三列赋给key类,同时也给value类赋值】

     3.creating a customized inputformat class

     

  • 相关阅读:
    全宁对医药行业销售代表的介绍
    effective c#读书笔记之二 静态成员的初始化
    自学笔记
    effective c#读书笔记之一
    如何判断表中是否有值
    领域驱动
    VIM 打造自己的VIM界面!
    Jqueryui的用法!
    php中io操作!
    php中Http请求!
  • 原文地址:https://www.cnblogs.com/chenyaling/p/5539493.html
Copyright © 2011-2022 走看看