使用不同键的pig内部连接

kzipqqlq  于 2021-05-29  发布在  Hadoop
关注(0)|答案(0)|浏览(165)
a = LOAD '601' using org.apache.hive.hcatalog.pig.HCatLoader();

b = LOAD '602' using org.apache.hive.hcatalog.pig.HCatLoader(); 

c = LOAD '603' using org.apache.hive.hcatalog.pig.HCatLoader(); 

d = LOAD 'SKL' using org.apache.hive.hcatalog.pig.HCatLoader(); 

e = join a by (d_key, c_cd ), b by (d_key, c_cd), c by (p1_key, c_cd), d by    (p2_key, c_cd); 

Dump e;

========================================================================
如果我在hive中执行相同的连接,我就会得到输出。但在pig中,在dumping e上,它运行mapreduce,读取行,但在成功后不写入输出。但是,如果我在配置单元中通过嵌套的内部连接执行相同的操作,我将得到正确的输出。
谁能给我解释一下Pig在连接关系中不同键的错误吗?
如果我想用hcatlogue(hcatstore)加载到带有动态分区(没有值)的分区空白表中,还有一件事。我得到分区表错误。我不知道hcatalogue出错的原因。如果你面对同样的问题,请向我解释,并提供任何解决方案。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题