hadoop - hadoop pig:在条件上加入(例如tab1.COL1 LIKE(％tab2.col2％))

Question

如何在PIG中的条件下实现联接？
SQL等效示例:

       select * from tab1, tab2 where instr(t1.col1,t2.col1 ) > 1 ;
       select * from tab1, tab2 where f(t1.col1) =f(t2.col1)  ;

非常感谢你。
菲利波

Answer 1

截至目前，pig仅支持内部联接，外部联接和完全联接。第二个Join示例可以在Pig中实现，而不是另一个。下面是一个例子。

tab1 = LOAD 'file1' using PigStorage('|') using (col1:chararray,col2:chararray);
tab2 = LOAD 'file2' using PigStorage('|') using (col1:chararray,col2:chararray);
result = JOIN tab1 by col1, tab2 by col1;