hadoop - pig FILTER ERROR 1000 : Error during parsing. 遇到

标签 hadoop apache-pig hortonworks-sandbox

这个脚本运行良好

data1 = LOAD '/user/maria_dev/ml-100k/test/u3.data' AS (usesrID:int, movieID:int, rating:int, ratingTime:int);
DUMP data1;

输出是 enter image description here

当我通过错误使用 FILTER 然后 PIG

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;

错误截图 enter image description here 错误详情:

2018-10-20 23:20:24,653 [main] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1000: Error during parsing. Encountered " "filterRowData1=filter "" at line 2, column 1.

我也试过

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;

最佳答案

filterRowData1 = filter data1 by movieID == 556;

别名和查询之间应该有空格。

关于hadoop - pig FILTER ERROR 1000 : Error during parsing. 遇到,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52933281/

相关文章:

hadoop - 使元数据无效/从 spark 代码刷新 imapala

hadoop - 如何在HDFS系统中引入 Octave 输出图像

hadoop - 如何使用Pig从字符串中获取有效的日期格式

hadoop - 由于 HDP 2.5 中的 Solr 异常,Hbase java 代码在表创建时卡住 - SolrServers 可用于处理此请求

minify - 从 nifi 带参数执行 java 程序

apache - 在 Apache Flume 中获取 JMS header

hadoop - 即使我设置了 setMapOutputKey 类,但 map 中的键类型不匹配

hadoop - 如何使用 pig 或 hadoop fs 选项重命名具有特定扩展名的文件?

hadoop - pig - 试图避免交叉

hadoop - 带有配置单元插件的 apache ranger - 需要保留哪些对象