hadoop - Pig 将一个表中的数字乘以另一个表中的所有值

Question

我有两个表:

A: (feature:chararray, value:float)

B:(multiplier:charray, value:float)

其中 A 是一个有数千行的表，而 B 只有一行。

我想做的是获取 A 中的所有行并将 A.value 乘以 B.value。

例如

A:[('f1', 1.5) , ('f2', 2.3)]

B:[('mul', 2)]

我想制作一张 table C

C: [('f1', 3), ('f2', 4.6)]

有没有简单的方法来做到这一点？

Answer 1

您可以执行CROSS 和FOREACH ... GENERATE。

X = A CROSS B;
Y = FOREACH X GENERATE A::feature, A::value * B::value;

以上代码没有经过测试