hadoop - 如何生成元组？ pig 的运算符(operator)

Question

我的代码如下

temp = foreach requiredData generate (recordType == 3 ? controllingCalledNum : callingPtyNum)as ServiceNumber, (recordType == 3 ? callingPtyNum : controllingCalledNum)as DestinationNumber;

这里我的代码是多余的..

我可以在 '?' 中生成元组吗？运算符并做这样的事情，我可以进一步扁平化

  temp = foreach requiredData generate (recordType == 3 ? (controllingCalledNum,callingPtyNum) : (callingPtyNum,controllingCalledNum))as (ServiceNumber,DestinationNumber);

如果我尝试这样做，我会收到错误消息请帮助我。

Answer 1

使用内置的 TOTUPLE UDF:

temp = foreach requiredData generate FLATTEN(recordType == 3 ? TOTUPLE(controllingCalledNum,callingPtyNum) : TOTUPLE(callingPtyNum,controllingCalledNum))as (ServiceNumber,DestinationNumber);