Hive-UDTF-函数解析Json字符串

前言:

本章主要讲解Hive的一对多"UDTF"函数解析Json字符串,根据业务需求返回对应的值;

正文:

开发工具:IDEA+JDK1.8+MAVEN

1.创建maven项目并导入UDTF函数的依赖jar包

<dependency>

<groupId>org.apache.hive</groupId>

<artifactId>hive-exec</artifactId>

<version>1.1.1</version>

</dependency>

2.编写UDTF(User-Defined Table-Generating Functions)需要继承GenericUDTF类,类中部分代码如下:

/**

  * A Generic User-defined Table Generating Function (UDTF)

  *

  * Generates a variable number of output rows for a single input row. Useful for

  * explode(array)...

  */

  public abstract class GenericUDTF {

  ​

   public StructObjectInspector initialize(StructObjectInspector argOIs)

         throws UDFArgumentException {

       List<? extends StructField> inputFields = argOIs.getAllStructFieldRefs();

       ObjectInspector[] udtfInputOIs = new ObjectInspector[inputFields.size()];

       for (int i = 0; i < inputFields.size(); i++) {

         udtfInputOIs[i] = inputFields.get(i).getFieldObjectInspector();

       }

       return initialize(udtfInputOIs);

    }


   /**

      * Give a set of arguments for the UDTF to process.

      *

      * @param args

      *          object array of arguments

      */

   public abstract void process(Object[] args) throws HiveException;

  ​

   /**

      * Called to notify the UDTF that there are no more rows to process.

      * Clean up code or additional forward() calls can be made here.

      */

   public abstract void close() throws HiveException;

  }

继承GenericUDTF需要实现以上方法,其中initialize方法和UDF中类似,主要是判断输入类型并确定返回的字段类型。process方法对udft函数输入的每一样进行操作,通过调用forward方法返回一行或多行数据。close方法在process调用结束后调用,用于进行其它一些额外操作,只执行一次。

import com.google.common.collect.Lists;

import org.apache.hadoop.hive.ql.exec.UDFArgumentException;

import org.apache.hadoop.hive.ql.metadata.HiveException;

import org.apache.hadoop.hive.ql.udf.generic.GenericUDTF;

import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector;

import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspectorFactory;

import org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector;

import org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory;

import org.json.JSONArray;

import org.json.JSONException;

import org.json.JSONObject;

import java.util.Iterator;

import java.util.List;

/**

* @author yangxuan

* @date 2019/08/19

*/

public class JsonUDTFextends GenericUDTF {

private String[]obj =new String[3];

/**

* process()方法

* 主要业务逻辑方法:

    *  @param objects

    *  objects接收的参数

*/

    public void process(Object[] objects)throws HiveException {

//判断objects[0]是否为null,是直接return;

        if(objects[0] ==null){

return;

}

//获取参数并转为String并用JSONObject解析字符串

        String json = objects[0].toString();

try {

JSONObject jsonObject =new JSONObject(json);

Iterator keys = jsonObject.keys();

while (keys.hasNext()){

JSONArray o = (JSONArray)jsonObject.get(String.valueOf(keys.next()));

for(int i =0; i

JSONObject j2 = (JSONObject)o.get(i);

Iterator keys1 = j2.keys();

while (keys1.hasNext()){

JSONArray o2 = (JSONArray)j2.get(String.valueOf(keys1.next()));

for(int j =0;j

JSONObject j3 = (JSONObject)o2.get(j);

obj[0]= toStr(j3.get("equipParamNameId"));

obj[1]= toStr(j3.get("deviceParamNameId"));

obj[2]= toStr(j3.get("finalValue"));

//通过调用forward方法返回一行或多行数据

                            forward(obj);

}

}

}

}

}catch (JSONException e) {

e.printStackTrace();

}

}

private String toStr(Object o){

if(o==null){

return "";

}

return String.valueOf(o);

}

//close方法在process调用结束后调用,用于进行其它一些额外操作,只执行一次。

    public void close()throws HiveException {

}

/**

*返回类型String,String,String

*init方法,主要定义输出的字段名及字段类型

*/

    @Override

    public StructObjectInspector initialize(StructObjectInspector argOIs)throws UDFArgumentException {

//设置列名

        List colName = Lists.newLinkedList();

colName.add("equipParamNameId");

colName.add("deviceValue");

colName.add("finalValue");

//设置对应每列的类型

        List resType = Lists.newLinkedList();

resType.add(PrimitiveObjectInspectorFactory.javaStringObjectInspector);

resType.add(PrimitiveObjectInspectorFactory.javaStringObjectInspector);

resType.add(PrimitiveObjectInspectorFactory.javaStringObjectInspector);

//返回分别为列名 和列类型

        return ObjectInspectorFactory.getStandardStructObjectInspector(colName,resType);

}

}

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,657评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,662评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,143评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,732评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,837评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,036评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,126评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,868评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,315评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,641评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,773评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,470评论 4 333
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,126评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,859评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,095评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,584评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,676评论 2 351

推荐阅读更多精彩内容