pig拉丁过滤和生成

rks48beu  于 2021-06-21  发布在  Pig
关注(0)|答案(1)|浏览(262)

我有一个简单的元组(userid,country,amount,transactionid,date,crap1,crap2,crap3)
我使用filter过滤掉一些数据,同时我想从元组中删除一些元素。它们存在于元组中的原因是我需要它们在某个较早的点,而不是在过滤器之后。
目前我正在做

B = FILTER A by date == 'xxxx';
C = FOREACH B GENERATE name, country, tranactionid;

有没有可能在一个语句中完成(以加快查询速度),因为据我所知,foreach+filter+generate只处理嵌套的包。

j2cgzkjk

j2cgzkjk1#

不可能。。

FILTER alias  BY expression;

以及

FOREACH { gen_blk | nested_gen_blk } [AS schema];

相关问题