建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
創(chuàng)新互聯(lián)ApachePig教程：ApachePigSplit運算符
SPLIT 運算符用于將關(guān)系拆分為兩個或多個關(guān)系。
語法
下面給出了 SPLIT 運算符的語法。
grunt> SPLIT Relation1_name INTO Relation2_name IF (condition1), Relation2_name (condition2),
例
假設(shè)在HDFS目錄 /pig_data/ 中有一個名為 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)系分為兩個，一個列出年齡小于23歲的員工，另一個列出年齡在22到25歲之間的員工。
SPLIT student_details into student_details1 if age<23, student_details2 if (2225);
驗證
使用 DUMP 操作符驗證關(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)
網(wǎng)站欄目：創(chuàng)新互聯(lián)ApachePig教程：ApachePigSplit運算符
標(biāo)題網(wǎng)址：http://www.5511xx.com/article/dpossgs.html
