如何使用apache pig递归加载文件

Question

我对Pig很新,我有一个非常基本的问题:我可以让make Pig加载目录中的所有文件,包括子文件夹中的文件吗？以下是我的进展方式:

records = LOAD '/worldwide/data/' USING PigStorage() AS (event:chararray, user:chararray);

在这里,repo/data可能有子文件夹如

repo/data/region/cluster1
repo/data/region/cluster2 

我是否可以从子目录和可能在将来添加的任何新目录中加载所有内容？

Answer 1

确认上述语句可以正常工作并将子目录中的所有数据加载到记录变量中。