How do I join 2 tables in PIG using 2 fields

Question

Hello, How do I join 2 tables in PIG using 2 fields.?

Syntax for 1 field :-> 

grunt> result = JOIN table1 BY col1, table2 BY col1;

How about if there are 2 fields(col1 & col2)  in table 1 which needs to join to 2 fields in table 2?

Answer 1

Here, we have two tables:

• Tab1 having columns id, name and age
• Tab2 having columns id, name and email

Using the below command to load data in pig,

tab1 = load ‘/mnt/home/edureka_425640/pig_join_1.txt’ using PigStorage(‘,’) as (id:int,name:chararray,age:int)

Dump tab1;

 

tab2 = load ‘/mnt/home/edureka_425640/pig_join_2.txt’ using PigStorage(‘,’) as (id:int,name:chararray,emal:chararrray)

Dump tab2;

Now, joining two tables on two columns

 

The below is the output:

Hope this helps you.