如何在猪中将字符串转换为元组

Question

我有一个从parameter-file.json获取的字符串，可以使用$ param访问该参数

$param='abc|cde|ghi'

我需要遍历此param变量

我尝试过的代码

以下代码的错误是“ \ u0027输入不匹配。\ u0027期望RIGHT_PAREN”

A= STRSPLIT($param,'\\x7c');
B=FOREACH A GENERATE 1
STORE A into '$output' using PigStorage(',');

以下代码的错误是“ \ u0027输入不匹配。\ u0027期望RIGHT_PAREN”

A= STRSPLIT($param,'|');
B=FOREACH A GENERATE 1
STORE B into '$output' using PigStorage(',');

以下代码在分析期间出现错误“”错误。 \ u003cfile，第7行\ u003e无法扩展宏\ u0027STRSPLIT \ u0027。原因：必须在扩展之前定义宏。“

A= STRSPLIT('$param','|');
B=FOREACH A GENERATE 1
STORE B into '$output' using PigStorage(',');

以下代码在分析期间出现错误“”错误。 \ u003cfile，第7行\ u003e无法扩展宏\ u0027STRSPLIT \ u0027。原因：必须在扩展之前定义宏。“

A= STRSPLIT('$param','\\x7c');
B=FOREACH A GENERATE 1
STORE B into '$output' using PigStorage(',');

以下代码的错误为“”：“在解析过程中出错。\ u003cline 7，列120 \ u003e语法错误，\ u0027bytearrayy \ u0027或附近的意外符号”“

A = LOAD '$userQuery' USING PigStorage('|') AS (name:bytearrayy);
B=FOREACH A GENERATE 1
STORE B into '$output' using PigStorage(',');

以下代码在分析期间出现错误“”错误。 \ u003cline 7，第9列\ u003e输入不匹配\ u0027。\ u0027期望QUOTEDSTRING“”“

A = LOAD $userQuery USING PigStorage('|') AS (name:bytearrayy);
B=FOREACH A GENERATE 1
STORE B into '$output' using PigStorage(',');

关于如何完成所需任务的任何建议。

谢谢

Answer 1

[pig udf's应该在像FOREACH这样的关系运算符中使用。