在pig中将字段强制转换为bag数据类型

ybzsozfc  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(437)

假设我在一个袋子里装入一个没有模式文件的pig。我知道包中的每个元组包含1个字段,这也是一个包,例如。

{
  ({1, 2, 3}),
  ({3,4,5}),
  ({1,2})
}

我想把每个元组的第一个参数都放到一个包里。我怎么能这么做?

data = LOAD '/path/to/data' AS (f:bytearray);
data2 = FOREACH data GENERATE (bag)f;  -- this doesn't work
jtoj6r0c

jtoj6r0c1#

data = LOAD '/path/to/data' AS (f:bag{(n:int)});

相关问题