如何在中生成元组?清管器操作工

o8x7eapl  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(297)

我的代码如下

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);

如果我试着这样做,我会出错的。请帮助我。

dohp0rv5

dohp0rv51#

使用内置 TOTUPLE 自定义项:

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

相关问题