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

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

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

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

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

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

jtoj6r0c1#

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

相关问题