register $zebraJar; --fs -rmr $outputDir a1 = LOAD '$inputDir/25Munsorted3' USING org.apache.hadoop.zebra.pig.TableLoader('count,seed,int1,str2'); a2 = LOAD '$inputDir/25Munsorted4' USING org.apache.hadoop.zebra.pig.TableLoader('count,seed,int1,str2'); sort1 = order a1 by str2; sort2 = order a2 by str2; --store sort1 into '$outputDir/strsorted1' using org.apache.hadoop.zebra.pig.TableStorer('[count,seed,int1,str2]'); --store sort2 into '$outputDir/strsorted2' using org.apache.hadoop.zebra.pig.TableStorer('[count,seed,int1,str2]'); rec1 = load '$outputDir/strsorted1' using org.apache.hadoop.zebra.pig.TableLoader(); rec2 = load '$outputDir/strsorted2' using org.apache.hadoop.zebra.pig.TableLoader(); joina = LOAD '$outputDir/strsorted1,$outputDir/strsorted2' USING org.apache.hadoop.zebra.pig.TableLoader('count,seed,int1,str2', 'sorted'); joinaa = order joina by str2; store joinaa into '$outputDir/union3' using org.apache.hadoop.zebra.pig.TableStorer('[count,seed,int1,str2]');