0

忽略上面的查询。它不正确。

我有以下猪脚本 A = LOAD 'textinput' 使用 PigStorage() 作为 (a0:chararray, a1:chararray, a2:chararray, a3:chararray, a4:chararray, a5:chararray, a6:chararray, a7:chararray, a8 :chararray,a9:chararray); 描述 A;使用 PigStorage() 将 A 存储到“output2”中;

这工作正常。

但是,当我使用 PigStorage() 修改 store 语句以将 A 存储到“output3”中时(a0:chararray,a1:chararray,a2:chararray,a3:chararray,a4:chararray,a5:chararray,a6:chararray,a7:字符数组,a8:字符数组,a9:字符数组);

它失败并出现以下错误 2013-05-04 11:49:56,296 [main] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1200: mismatched input 'as' Expecting SEMI_COLON

4

1 回答 1

1

使用 pig 存储输出时,您无需指定模式。您存储的别名的架构是您创建它时的任何内容。如果你想改变它的存储方式,你可以做类似的事情

B = FOREACH A GENERATE (insert transformation here);
STORE B INTO 'output3';

如果您希望更改 PigStorage 将别名写入磁盘的方式,您可以创建自己的StoreFunc

于 2013-05-04T19:18:00.770 回答