pig连接将导致零行空结果

dsf9zpds  于 2021-06-21  发布在  Pig
关注(0)|答案(0)|浏览(194)

以下是表说明的转储:

  1. A = LOAD '/tmp/all.csv' as (cmd:chararray,q1:int,q2:int,q3:int);
  2. R = LOAD '/tmp/raw.csv' as (cmd:chararray,duration:int);
  3. A: {cmd: chararray,q1: int,q2: int,q3: int}
  4. R: {cmd: chararray,duration: int}
  5. J: {A::cmd: chararray,A::q1: int,A::q2: int,A::q3: int,R::cmd: chararray,R::duration: int}

以下是a和r表:

  1. === A ==-=
  2. A,5,10,20
  3. B,25,50,75
  4. === R ===
  5. A,6
  6. A,12
  7. A,22
  8. B,30
  9. B,55
  10. B,80

我通过以下命令加入:

  1. J = join A BY cmd, R BY cmd;

这看起来很直接,但是当我转储表j时,它总是返回空/null。

  1. DUMP J;
  2. Output(s):
  3. Successfully stored 0 records in

你知道我遗漏了什么吗?

暂无答案!

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

相关问题