pig-不加载数据

lvmkulzt  于 2021-06-02  发布在  Hadoop
关注(0)|答案(1)|浏览(330)

输入数据:

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

pig查询:
x=load'/data.txt'为(d1:int,d2:int,b:bag{t:tuple(t1:int,t2:int)});
但我得到的结果是:

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

我不知道我在哪里犯了错。

yjghlzjz

yjghlzjz1#

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

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

相关问题