输入数据:
(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)});但我得到的结果是:
(,,) (,,) (,,) (,,)
我不知道我在哪里犯了错。
yjghlzjz1#
数据用大括号括起来,这意味着它是一个元组。必须定义一个外部结构,将数据视为元组,然后放置字段。以下是您需要的:
x= load '/data.txt' as (a:tuple(d1:int, d2:int, B:bag{T:tuple(t1:int, t2:int)}));
1条答案
按热度按时间yjghlzjz1#
数据用大括号括起来,这意味着它是一个元组。必须定义一个外部结构,将数据视为元组,然后放置字段。
以下是您需要的: