开发手册 欢迎您!
软件开发者资料库

Apache Pig - Union Operator

Apache Pig Union操作员 - 从概述,架构,安装,执行,Grunt Shell,猪拉丁语基础知识,读取数据,存储数据,诊断操作员,描述操作员,解释操作员,说明操作员,组操作员,Cogroup操作员,加入,学习Apache Pig操作员,跨操作员,联合操作员,拆分操作员,过滤操作员,不同操作员,Foreach操作员,订单依据,限制操作员,评估函数,加载和存储函数,包和元组函数,字符串函数,日期时间函数,数学函数,用户定义的函数,运行脚本。

Pig Latin的 UNION 运算符用于合并两个关系的内容.要对两个关系执行UNION操作,它们的列和域必须相同.

语法

以下是 UNION的语法运营商.

grunt> Relation_name3 = UNION Relation_name1, Relation_name2;

示例

假设我们有两个文件,即 student_data1.txt /pig_data/目录中的> student_data2.txt ,如下所示.

Student_data1.txt

001,Rajiv,Reddy,9848022337,Hyderabad002,siddarth,Battacharya,9848022338,Kolkata003,Rajesh,Khanna,9848022339,Delhi004,Preethi,Agarwal,9848022330,Pune005,Trupthi,Mohanthy,9848022336,Bhuwaneshwar006,Archana,Mishra,9848022335,Chennai.

Student_data2.txt

7,Komal,Nayak,9848022334,trivendram.8,Bharathi,Nambiayar,9848022333,Chennai.

我们已将这两个文件加载到Pig中,其关系为 student1 student2 ,如下所示.

grunt> student1 = LOAD 'hdfs://localhost:9000/pig_data/student_data1.txt' USING PigStorage(',')    as (id:int, firstname:chararray, lastname:chararray, phone:chararray, city:chararray);  grunt> student2 = LOAD 'hdfs://localhost:9000/pig_data/student_data2.txt' USING PigStorage(',')    as (id:int, firstname:chararray, lastname:chararray, phone:chararray, city:chararray);

现在让我们使用 UNION 运算符合并这两个关系的内容,如下所示.

grunt> student = UNION student1, student2;

验证

使用 DUMP验证关系学生 运算符如下所示.

grunt> Dump student;

输出

它将显示以下输出,显示关系 student .

(1,Rajiv,Reddy,9848022337,Hyderabad) (2,siddarth,Battacharya,9848022338,Kolkata)(3,Rajesh,Khanna,9848022339,Delhi)(4,Preethi,Agarwal,9848022330,Pune) (5,Trupthi,Mohanthy,9848022336,Bhuwaneshwar)(6,Archana,Mishra,9848022335,Chennai) (7,Komal,Nayak,9848022334,trivendram) (8,Bharathi,Nambiayar,9848022333,Chennai)