W3Cschool
恭喜您成為首批注冊用戶
獲得88經(jīng)驗(yàn)值獎(jiǎng)勵(lì)
SPLIT 運(yùn)算符用于將關(guān)系拆分為兩個(gè)或多個(gè)關(guān)系。
下面給出了 SPLIT 運(yùn)算符的語法。
grunt> SPLIT Relation1_name INTO Relation2_name IF (condition1), Relation2_name (condition2),
假設(shè)在HDFS目錄 /pig_data/ 中有一個(gè)名為 student_details.txt 的文件,如下所示。
student_details.txt
001,Rajiv,Reddy,21,9848022337,Hyderabad 002,siddarth,Battacharya,22,9848022338,Kolkata 003,Rajesh,Khanna,22,9848022339,Delhi 004,Preethi,Agarwal,21,9848022330,Pune 005,Trupthi,Mohanthy,23,9848022336,Bhuwaneshwar 006,Archana,Mishra,23,9848022335,Chennai 007,Komal,Nayak,24,9848022334,trivendram 008,Bharathi,Nambiayar,24,9848022333,Chennai
通過關(guān)系 student_details 將此文件加載到Pig中,如下所示。
student_details = LOAD 'hdfs://localhost:9000/pig_data/student_details.txt' USING PigStorage(',') as (id:int, firstname:chararray, lastname:chararray, age:int, phone:chararray, city:chararray);
現(xiàn)在,讓我們將關(guān)系分為兩個(gè),一個(gè)列出年齡小于23歲的員工,另一個(gè)列出年齡在22到25歲之間的員工。
SPLIT student_details into student_details1 if age<23, student_details2 if (22<age and age>25);
使用 DUMP 操作符驗(yàn)證關(guān)系 student_details1 和 student_details2 ,如下所示。
grunt> Dump student_details1; grunt> Dump student_details2;
它將產(chǎn)生以下輸出,分別顯示關(guān)系 student_details1 和 student_details2 的內(nèi)容。
grunt> Dump student_details1; (1,Rajiv,Reddy,21,9848022337,Hyderabad) (2,siddarth,Battacharya,22,9848022338,Kolkata) (3,Rajesh,Khanna,22,9848022339,Delhi) (4,Preethi,Agarwal,21,9848022330,Pune) grunt> Dump student_details2; (5,Trupthi,Mohanthy,23,9848022336,Bhuwaneshwar) (6,Archana,Mishra,23,9848022335,Chennai) (7,Komal,Nayak,24,9848022334,trivendram) (8,Bharathi,Nambiayar,24,9848022333,Chennai)
Copyright©2021 w3cschool編程獅|閩ICP備15016281號-3|閩公網(wǎng)安備35020302033924號
違法和不良信息舉報(bào)電話:173-0602-2364|舉報(bào)郵箱:jubao@eeedong.com
掃描二維碼
下載編程獅App
編程獅公眾號
聯(lián)系方式:
更多建議: