join - 左连接中缺失字段的默认值？

Question

在 Pig 中，当我进行左连接并且某行没有行时，值为 NULL:

c = join a by ($0) left, b by ($0);

如果

a=((1,10),(2,20))
b=((1,30))

然后

c=((1,10,30),(2,20,NULL))

我想使用默认值(例如，-1)而不是 NULL，这样

c=((1,10,30),(2,20,-1))

我该怎么做？

如果这不可能，我如何将 c 的第 3 列更改为默认值而不是 NULL？

Answer 1

我不知道这是否可以在 join 语句中完成，但是您添加了另一个语句:

d = FOREACH c GENERATE $0, $1, (($2 IS NULL) ? -1 : $2);

我猜它不会触发额外的 MR 作业。