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

     

  • 相关阅读:
    获得目标服务器中所有数据库名、表名、列名
    SQL Server 2008 安装SQLDMO.dll
    三层交换原理
    NAT地址转换原理全攻略
    C#中显/隐式实现接口及其访问方法
    As,is含义?using 语句
    c#泛型约束
    C#几个经常犯错误汇总
    C#--深入分析委托与事件
    markdown基础
  • 原文地址:https://www.cnblogs.com/chenyaling/p/5539493.html
Copyright © 2011-2022 走看看