现在的位置: 首页 > 综合 > 正文

Pig自定义功能

2018年05月20日 ⁄ 综合 ⁄ 共 328字 ⁄ 字号 评论关闭

user.data:第1列是用户id,第2列是用户名;

role.data:第1列是角色id,第2列是角色名,第三列是用户id;

比如想在PIG中过滤id为3的记录:

使用自定义函数的方式来解决:

                                                        图:在exec函数中判断id的值是否等于3

            图:在exec函数中判断id的值是否和要比较的值(refInteger)相等,refInteger为传入的参数;

        图:定义一个文件isEqual.pig, 并使用命令pig  isEqual.pig来执行命令;



     图:通过使用$ref来使用命令行传参的方法


    图:调用方式-p ref=3



    图:-m -ref.file通过把参数信息放在ref.file中







【上篇】
【下篇】

抱歉!评论已关闭.