此函數(shù)接受兩個字符串參數(shù)。它驗證第一個字符串是否以第二個開頭。
下面給出了 STARTSWITH() 函數(shù)的語法。
grunt> STARTSWITH(string, substring)
假設(shè)在 HDFS 目錄 /pig_data/ 中有一個名為 emp.txt 的文件,如下所示。此文件包含員工詳細(xì)信息,如id,姓名,年齡和城市。
emp.txt
001,Robin,22,newyork 002,BOB,23,Kolkata 003,Maya,23,Tokyo 004,Sara,25,London 005,David,23,Bhuwaneshwar 006,Maggy,22,Chennai 007,Robert,22,newyork 008,Syam,23,Kolkata 009,Mary,25,Tokyo 010,Saran,25,London 011,Stacy,25,Bhuwaneshwar 012,Kelly,22,Chennai
通過使用 emp_data 關(guān)系將此文件加載到Pig中,如下所示。
grunt > emp_data = LOAD 'hdfs://localhost:9000/pig_data/emp.txt' USING PigStorage(',') as (id:int, name:chararray, age:int, city:chararray);
以下是 STARTSWITH() 函數(shù)的示例。在此示例中,我們驗證所有員工的姓名是否以子字符串“Ro"開頭。
grunt> startswith_data = FOREACH emp_data GENERATE (id,name), STARTSWITH (name,’Ro’);
如果任何這些名稱以字符串'Ro'開頭,上述語句將解析所有員工的名稱。因為員工姓名'Robin'和'Robert'這兩個元組以子串'Ro'開頭,所以 STARTSWITH() 函數(shù)返回布爾值'true',剩余的元組的值將為'false'。
語句的結(jié)果將存儲在名為 startswith_data 的關(guān)系中。使用Dump運(yùn)算符驗證關(guān)系 startswith_data 的內(nèi)容,如下所示。
grunt> Dump startswith_data; ((1,Robin),true) ((2,BOB),false) ((3,Maya),false) ((4,Sara),false) ((5,David),false) ((6,maggy),false) ((7,Robert),true) ((8,Syam),false) ((9,Mary),false) ((10,Saran),false) ((11,Stacy),false) ((12,Kelly),false)
更多建議: