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

     

  • 相关阅读:
    美剧天堂前100最新
    自动登录github
    分布式爬虫
    爬虫框架:scrapy
    First day ~
    docker 使用的一些笔记
    POI 写出word文档实例
    POI 生成word各类问题(设置中文字体,重复图片插入等怪问题......)
    HTML 与 文本 的相互转义
    TDengine + Telegraf + Grafana 运维监测系统搭建
  • 原文地址:https://www.cnblogs.com/chenyaling/p/5539493.html
Copyright © 2011-2022 走看看