Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Pig >> mail # user >> Pig Map-reduce process


Copy link to this message
-
Pig Map-reduce process
Hi All,

Can someone explain map-reduce process flow for the below script?

b =  FOREACH a{ P_EVAR =  REPLACE(PEVAR35,'-','');
               P_LEN = LENGTH(P_EVAR);
               P_EVAR_10 = (LENGTH(P_EVAR) == 11 ?
CONCAT(SUBSTRING(P_EVAR,8,11),SUBSTRING(P_EVAR,4,8)) : (LENGTH(P_EVAR) =12 ?CONCAT(SUBSTRING(P_EVAR,8,12),SUBSTRING(P_EVAR,4,8)) : (LENGTH(P_EVAR)
== 13 ? CONCAT(SUBSTRING(P_EVAR,9,13),SUBSTRING(P_EVAR,4,9)) : P_EVAR )));
GENERATE P_EVAR,P_LEN,P_EVAR_10;
};

Thanks
Krishnan