From cb779b6b7d611d4c25c38047c6615a972d74580e Mon Sep 17 00:00:00 2001 From: Nadya Privalova Date: Tue, 15 Oct 2013 10:46:09 -0700 Subject: [PATCH] Add example edp jobs folder and pig example Change-Id: I30643876e7724b62b8f13a0d65a0b78fde26efcd --- edp-examples/README.rst | 4 ++++ edp-examples/pig-job/README.rst | 4 ++++ edp-examples/pig-job/example.pig | 3 +++ edp-examples/pig-job/expected_output | 4 ++++ edp-examples/pig-job/input | 4 ++++ edp-examples/pig-job/udf.jar | Bin 0 -> 3745 bytes 6 files changed, 19 insertions(+) create mode 100644 edp-examples/README.rst create mode 100644 edp-examples/pig-job/README.rst create mode 100644 edp-examples/pig-job/example.pig create mode 100644 edp-examples/pig-job/expected_output create mode 100644 edp-examples/pig-job/input create mode 100644 edp-examples/pig-job/udf.jar diff --git a/edp-examples/README.rst b/edp-examples/README.rst new file mode 100644 index 0000000..549baf4 --- /dev/null +++ b/edp-examples/README.rst @@ -0,0 +1,4 @@ +EDP Examples +============ + +* Pig job example - trim spaces in input file diff --git a/edp-examples/pig-job/README.rst b/edp-examples/pig-job/README.rst new file mode 100644 index 0000000..0fc93af --- /dev/null +++ b/edp-examples/pig-job/README.rst @@ -0,0 +1,4 @@ +Example Pig job +=============== + +This script trims spaces in input text diff --git a/edp-examples/pig-job/example.pig b/edp-examples/pig-job/example.pig new file mode 100644 index 0000000..4141906 --- /dev/null +++ b/edp-examples/pig-job/example.pig @@ -0,0 +1,3 @@ +A = load '$INPUT' using PigStorage(':') as (fruit: chararray); +B = foreach A generate com.hadoopbook.pig.Trim(fruit); +store B into '$OUTPUT' USING PigStorage(); diff --git a/edp-examples/pig-job/expected_output b/edp-examples/pig-job/expected_output new file mode 100644 index 0000000..60a0142 --- /dev/null +++ b/edp-examples/pig-job/expected_output @@ -0,0 +1,4 @@ +pomegranate +banana +apple +lychee \ No newline at end of file diff --git a/edp-examples/pig-job/input b/edp-examples/pig-job/input new file mode 100644 index 0000000..d2079b5 --- /dev/null +++ b/edp-examples/pig-job/input @@ -0,0 +1,4 @@ + pomegranate + banana + apple + lychee \ No newline at end of file diff --git a/edp-examples/pig-job/udf.jar b/edp-examples/pig-job/udf.jar new file mode 100644 index 0000000000000000000000000000000000000000..2eba7023ec8e6cf6ec5a0df4f32a8c976f94e946 GIT binary patch literal 3745 zcmb7G2{@GN7awIAMGdnsL_#COFiVuR#u{TE+9O+K9WvIGB64#HN%o6DiEO!+C`(G& zYDz*v$k?}pO8mdMWw|x?KKFm-`M&R+=RN25p7XxvocCu!+Q_~M#FYKPdo=$V{CIH# zUqfwkB1X?hN8aRz8W^MosM#G_I_(5ZUjiQ3dNo6$k)Dn=*<8+0=c8d$qX7vcN9QGB z&@D~R@0np+3B4cA%Idc~l_g;`z+3|v2V)R2)sjBtNnvJCk{OwrjJ^xowweDr!3^#X zZ8ZA`%;*z5^sD=PIke;Le^dHw{~Lr3JCPsb90@<=$2pC9QhB`cIB3N=5J)8z^|u(< z0q1NfF01bUsQ&& z&@*6h6l()L4_yky&eYS|*@5aSXX|Y3;gL)}VGJe0)Lyw(j2G=^BSOOb7w9h=0>#h@ zl8)88r6Cg8^wME3XMxz{EN8xNQeOfo5BoNUqDHQx9)7;^yLW6Bm|sCLzTA5v=^P`e zqO|8iCZ&z2C!KD5H+haffq%%PX7FlZ^CV~zPGTWBoSoRTM=x>DAP>fUBKAFp z7-fd>bgCUe@Fa88LmR`xqi^TWM3bT>0*lL!4S4D%ClZ_Ul@obr9LHP_TUf>x9gIHv z?v4^%rpni@8)7=8O=&l7Y5SitZj*CAcf!Y>^x)l;$S`-lMnf)#vb^)# z^eh{5$-bOsWg!kC z1XP}FTODtg-H0g@N%D!O zeolYbJ~h@e8SzE)Rl#s2q~^tkYr~EgJUP#YRqz(h#H7i88kj8yA7ba#rl12HOKl?< z0v5a>ORe%3Upt;qC-*0k1aKMw9MBN~PIB_C2iJ`dM|2eN54X<6CPDa%b%RnP-;~Twq+KhV0^&_wNiAKu5u(j{N5Ra|H2op)FEY>HD(B zQ>C&eQzejZiK_9TRUvr~E+NEjs*BC-t+=)z<(DN)J1j14yNi7;vK!)ik*M4WrW-M~ zXi&v9OB=P0(o=RcFtFk3NtwAkuZQbFe3m*%eL*mZK10(6m1~l}35#1v2$Q;YqzNQw zFrK3QsjBz5Z0B1QKZ%GRh0_GpEu-2FL@IrOuGHE0Ca@+!UInkT9t=n`e z@2X%dd;p$%+hi&w&;rigb_bm6N{}|AMw-}+hAfPt%H8`@cPd?@?25(&yE+F`r036DH}&A&^4zn3 z%=G|10cL)u6oxN1-#$EeU&Sh&lRTawr~mqy-Al23Huc3I>yi*gE? z9dbAoS+6!9+SnC2(SY5HEbrSSQKcWe9J9j|m#8?eB8u!0WSdd_=n>N&H}!OaKNwkp zR(&5!t;8QCB6aTW6?qQPCZpma_t=<@IK+Dl4sU)J|BTfIzUMJq316pC438xzWq&7Mvn7_gI zKvTN2Xoxp5HFX94>OrI0AEEKGM&+`J{=G^(m|l`dj`DqM+cT>YDs*8JffCRM>xVhvz3K)kgbA9 z9nhB}5sbxM6)5>Xa%T$&j>N05NUhhRQv%>;CmavdrA9tOQTW;oykOPmkwe`FUM10@ z*;;F*^PUeArUO1c zM8V`T4H^R7i_W7r4K#~m92N=bv${rS1NJwHh}TX*pR`|)^9w!0F1$IQ;a%-ysK`m@ z02)_j$&1Ge6uT60?|gEcQ<-R!b$es+29!G+IRj_-o{)hH+5^tNj5i)SJ#=NvzClXk zCA;Ngr{ZYe%TojTes)x$!83hUSaiR-TX*j;W|AzRk1!IuPb`T( zqxL{YJ@$*8+$&kN#|#gyva$e2>Dt57{m1)ft7=Z>(H~AG`l!TF-ai5nPI&j-4XxX^ z(hxu(`IB=RtJfqjU|y@M+^V@8f0i<=O8vVbD-bXU z18@Y_Hn%N`Y(U=v`j^~)2XUjg$oaT92S*brwPK*)$!~DO$>0$$EGMo)_E`EWt~Z5u-ypf<)~Dh1=ccAXh83q0C(8;op6TI07EvC0aA;8qY;u%w*4)57q}a44 z>3&y5W-?5eF)LUbGFHZ}1-<`%f4q>KfX4zDT}6tWm(Y5W46i@@wj}jD_>#2+Z!g2Y zWJYCo2JEG>xb(j8W4ID)&#YbUY#%44KVx)HAAvRYZoFXG>n7+3>wkN#oqbCVIK|<} z>}#EGLx)0qZ`ztuBcw?EBi?40}|igDxXMw{@H`8r$s6G(&G zwcSRM{L=#4bCjb$hs}9+L$YFw7R;WUL1*I^qjB%IU9{c=Hnv_Oyn#@x9ZjvQ4U~dL zg?f;-96Dcbsn}Ky7{s)XTQ)&d{k;~sR+0q_QUy)`RxQnN26o;DcohD>6L33A0g{92 zVDCZpGHxbe^kwx7O%L2LpE8ssHTRo&$uyXQjW8xyEE$V0z+;Q?3KnkjymUouAs!3b zgcS0)k%@qx9%OU~jUb0OzbbLEpIf-%mMQSzCc-DHJ?kJW17SayHFyK&u@iB_E^8<1 zW-9kafMl|5fNlI|stm*c2m~}vWPVq3f6a_Fb!I9vCF9cHl6f7GUPJhmy)yajcVRAE z2MoWn-8EN#X2i_G{4Pw3L16e3p