hadoop - pig 如何为列分配名称？

Question

我有一个包含数百列的 csv 文件，当我将文件加载到 Pig 中时，我不想像这样分配每一列

A = load 'path/to/file' as (a,b,c,d,e......)

因为我会在第二步过滤掉很多:

B = foreach A generate $0,$2,....;

但是在这里，我可以为 B 的每一列分配一个名称和类型吗？像

B = foreach A generate $0,$2,... AS (a:int,b:int,c:float)

我试过上面的代码，但它不起作用。

谢谢。

Answer 1

您必须在每个逗号之间指定它们。

B = foreach A 生成 $0 作为 a，$2 作为 b，...

请注意，它只是假定它已经是的类型。