猪 - 不加载数据

Pig - Not loading the data

输入数据:

(10,1,{(2,3),(4,6)})
(10,3,{(2,3),(4,6)})
(10,6,{(2,3),(4,6),(5,7)})

猪查询:

x= load '/data.txt' as (d1:int, d2:int, B:bag{T:tuple(t1:int, t2:int)});

但我得到的输出如下:

(,,)
(,,)
(,,)
(,,)

我不确定我哪里弄错了。

您的数据用大括号括起来,这意味着它是一个元组。您必须定义一个外部结构以将数据视为元组,然后放置您的字段。

这是您需要的:

x= load '/data.txt' as (a:tuple(d1:int, d2:int, B:bag{T:tuple(t1:int, t2:int)}));