pig:字段投影无效架构中不存在投影字段[dept\u no]

a1o7rhls  于 2021-06-25  发布在  Pig
关注(0)|答案(1)|浏览(425)

我有两个.csv文件,
1) 按部门名称、员工id和雇用日期划分的经理列表。
2) 一个包含所有员工的文件,不分级别,并按雇用日期、名字、姓氏进行划分。
我想输出所有的名字和姓氏经理在一个特定的部门标记为'化学'。
我先加载两个文件。

managers = LOAD....
employees = LOAD...

然后我尝试一个cogroup。

grouped = COGROUP emplo BY first_name, manag by dept_no;

然后试着根据具体的部门筛选出结果

only_chem = FILTER grouped BY dept_no == 'chem';

但是,当我转储结果时,它会在最后一位显示,无效的场投影。架构中不存在投影字段[dept\u no]。
我把他们分组的方式肯定做错了什么。我想摆脱无关的信息,但能够过滤出所有的员工,只有从这些经理,但我需要大的员工档案,因为它有名字/姓氏字段。
思想?谢谢您。

mrwjdhj3

mrwjdhj31#

你能这样试试吗?

D = FOREACH grouped{
                      only_chem = FILTER  managers BY dept_no == 'chem';
                      GENERATE FLATTEN(only_chem);
                 }
DUMP D;

如果这不起作用,请粘贴员工和经理文件的示例输入数据,并加载2个stmt。

相关问题