hadoop - Pig模式加载数据

Question

我具有以下输入数据格式来表示来自源URL的传出链接，即源URL 1具有2和3个传出URL

1 2 3
2 3 4
3 4
4 1

我想按以下方式加载到Pig中

N,  aN
(1,(2,3))
(2,(3,4))
(3,(4))
(4,(1))

我可以使用默认的AS模式执行此操作，还是必须编写自定义加载程序函数？

Answer 1

您将需要编写自定义加载程序，或稍稍修改数据结构。如果没有自定义加载程序，则可以采用以下格式:

N,  aN
(1,(2,3))
(2,(3,4))
(,(3,4))
(,(4,1))