这个脚本很好用
data1=load'/user/maria_dev/ml-100k/test/u3.data'as(usesrid:int,movieid:int,rating:int,ratingtime:int);
转储数据1;
< /代码>
输出是

当我使用过滤器时,就通过错误的清管器。
data1=load'/user/maria_dev/ml-100k/test/u3.data'as(usesrid:int,movieid:int,rating:int,ratingtime:int);
filterrowdata1=按(int)movieid=556筛选数据1;
转储filterrowdata1;
< /代码>
错误屏幕截图
错误详细信息:
< Buff行情>
2018-10-20 23:20:24653[main]错误org.apache.pig.tools.grunt.grunt
-错误1000:分析期间出错。在第2行第1列遇到“filterrowdata1=filter”。
< /块引用>
我也试过了
data1=load'/user/maria_dev/ml-100k/test/u3.data'as(usesrid:int,movieid:int,rating:int,ratingtime:int);
filterrowdata1=filter data1 by movieid==556;(我试过:“556”;但没有运气)
转储filterrowdata1;
< /代码> <
输出是

当我使用过滤器时,就通过错误的清管器。
data1 = LOAD '/user/maria_dev/ml-100k/test/u3.data' AS (usesrID:int, movieID:int, rating:int, ratingTime:int);
filterRowData1=filter data1 by (int)movieID == 556;
DUMP filterRowData1;
错误屏幕截图
错误细节:
2018-10-20 23:20:24653[main]错误org.apache.pig.tools.grunt.grunt
-错误1000:分析期间出错。在第2行第1列遇到“filterrowdata1=filter”。
我也试过了
data1 = LOAD '/user/maria_dev/ml-100k/test/u3.data' AS (usesrID:int, movieID:int, rating:int, ratingTime:int);
filterRowData1=filter data1 by movieID == 556; (i have tried: '556'; but no luck)
DUMP filterRowData1;