我使用以下代码行:
student = load 'test/Pig/student' using PigStorage(' ') as (name:chararray,roll:int);
result = load 'test/Pig/results' using PigStorage('\t') as (id:int,status:chararray);
passroll = FILTER result by status == 'pass';
store passroll into 'test/Pig/passroll';
pass = load 'test/Pig/passroll/part-m-00000' using PigStorage(',') as (id:int,status:chararray);
stupass = JOIN pass by id, student by roll;
studentname = FOREACH stupass GENERATE student::name;
举例说明 studentname
是给成绩优秀的学生命名的有及格的。
但是倒垃圾 studentname
正在发出警告 ACCESSING_NON_EXISTENT_FI ELD 19 time(s)
.
暂无答案!
目前还没有任何答案,快来回答吧!