2016-11-11 25 views
-1

我有一堆根據我的標準過濾的行。現在我需要減去兩列的值,我需要對它們進行排序。這些是我迄今使用的命令。減去兩列中的值並使用豬獲得一個新列

data = LOAD '/user/imohit01017881/jk/a2dbe50d-c6e5-42e2-8fd0-5386720ce07b_Data.csv' using PigStorage(',') AS (Country:chararray, CountryCode:chararray, Series:chararray, SeriesCode:chararray, yr2000: float, yr2001:float, yr2002 :float, yr2003 :float, yr2004 :float, yr2005:float, yr2006:float, yr2007:float, yr2008 :float, yr2009 :float, yr2010:float, yr2011: float, yr2012 :float, yr2013 : float, yr2014 : float, yr2015:float); 

過濾行包含REQ數據:

ggdif = FILTER data by Series == 'Improved sanitation facilities (% of population with access)' 
dump data 

下面一行是給我的錯誤:

sub_data = FOREACH ggdif GENERATE SUBTRACT(yr2015, yr2000); 

回答

0

Source:減去有兩個袋子作爲參數,並返回組成一個新書包第一個包的元組不在第二個包裏。 如果爲空,袋子參數被空袋取代

sub_data = FOREACH ggdif GENERATE (yr2015 - yr2000);