PK}K3Osparkipy/__init__.pyPKe3OԜ,sparkipy/runner.pyUN0+"4X6RUWeA($0v^ۉc`Pľs_RiJt|ddätOk71IlFX۟LWSpi0hdSB^ FSȉ$*3Ôv˰DQNa-}grF̌JDnր!k4,?3{&^m(wERP(gɋȌж:*wg,m5*[Eg%ջ7~,v]w!a*ϜIWORʒFQnؚ_3b?xxRIE|Y!ޙzi^)(ڍk-!ϩ!1%6AYGǐTf !z[c0Cmfό$"W#VԮ{E]gV nǕ?zD3$Y8) k)XFmՐ&6YٵgmaKxgh<|?b~PKP3Oʡ'sparkipy/jobs/HelloWorldJob.py}0 Dwթ|Bl QJHn{ ,pߝΎi@ PWDx:p?<(c{pFw6F:>Wԥ`VojRF.-)|[szW&P cyR̫xPKh3O-i&sparkipy/jobs/PiJob.pyR=O0+N:m0 bB0 6PMΩ#@˯N]7.F;4iq:0La9_}荥,}|֛NHK<3/i$IRIf-EP(iB (omd ity b#Fe)peI,J90؃QK`NW=~"<'DF|:*pU XPLIybcI7paFAjHYUa5]^~"C~ѰgR?HsCK(8mYGxF ־BrV.P{ /F)vJg3J-Rsۚ|2Yxfu\=PKf3O sparkipy/readers/aws/__init__.pyPKf3O"sparkipy/readers/azure/__init__.pyPKf3O sparkipy/readers/gcp/__init__.pyPKf3O(sparkipy/readers/gcp/big_query_reader.pyUMO0W pH*Uν` R$NbH`; WC͌|$W8[*F*4Ѳj ~[b4cJ_.Z^nna\/-RU)*H+FTda 2, d2Zr/\pǡfUP{L0-pѴ&θbc%|X}dTdP r&vr≋ET ^L\#ᴒmw'-$msP+id#Vlf.霵K{sk<5;|R'u73uA3)@."r^`9ed<#[$~G=.E$3akRh;w!Lj|@1Sς/SzEo^jC1^>vޜݹ~:$cGlT?PKf3O.qsZb3sparkipy/readers/gcp/google_cloud_storage_reader.pyN0 yABx.K/s]7$Jb7kۿ]i\ ~Ԇ6|FQTuZT?6'J&gqPK0պ*NxTL,vMvei5EiS69;+BSLl`C( k dp'KL w '2ۤ$q*7IK۩,mћLRx7T=:p^aA9պג1Pٳ 7,pwJH8A3td,=js[c썻sM*66c.YXh6D9!ԩvK L 0jP5b :p,T Ӓ{> _uazOCB-6jz[e fĠT$.}tF=>"5`N9KŅ nb\/4Τ* =:DN*ۅvBmΚ2^7\^^f—˻[ӫ-PKjL3Osparkipy/writers/__init__.pyPK/f3Oꍹpsparkipy/writers/awriter.pyMA 0 zS yA&n$A%@V#9# 'CY~R-REX> )Xj1>42@7ϳLJNWtS :`b?rwPKf3O sparkipy/writers/aws/__init__.pyPKf3O"sparkipy/writers/azure/__init__.pyPKf3O sparkipy/writers/gcp/__init__.pyPK;h3Oߧ<(sparkipy/writers/gcp/big_query_writer.pyTmo0ίI6p#akԱMT&ULr i8K7=;&!@{;ߓ ^8δUÅ"l-yzP $e`]Ru#xRFdRE[Y9A<~d5˔$,IRIjmgn')d ǁ201nYVVqZH[Z CJPЫݧfթRkFgغR̈ǟAث{MhJ̾J Y{5י|$ `Dq~"W7 3k@d\TݫqvrE; Dju?Q9۸n? LxmƇڎIL3jvp$J )BYQ˜3#D&|mF $i!ZsZrDr-[Xd9Y,fcq;~.?Lvhs _BKΞlvdg/֧E]wlXbWMY`W=qXqD3R<6$ OMoAM3~2:Tw=%¾u^O15Lm\Q.rOQE6Y:/y ]߰,+[<J|g[g_PKK3Otests/__init__.pyPKfk3O]{l], sparkipy-0.0.2.dist-info/LICENSEZ[s~rSi4i牱䆭CiDn&% . =dwVM5Iٳ[)^s3OCYM'.d7J{_~͓vпyj%m37vܫXۛ~yZw7ww׷w7W=u\-ߐJպ(/63p;4UtPuBv(MW*Q+F aUoM5uE᳕v՛҉ TZ,+o͸݉჆L92DA}`BXo9bA[+aa2V6D(1vx@^ Yb <`Ҫ! < ~;v,+MۚKv,7wƒh{|4Rft'.%/5{e p/b0t|KV[}XbOJ[f1@ʅM=n{T+[o_3`6|4nMV DnTF(5r"=3g3eumeYLJA[PлQSq[NBm ^qVZXNdOEk* GU+LI(:3Fw?:S{ /GS*~=EZoGK[_ ߁;Ɔ򣶦˝@ 'e(k!zGDŽ5&!1 pzrpR >?Gc?$ 0R .#&Ƀԍ4!3\*M1KCIF\f#aMfÀ,".Q= !y!>{;?B25fp~+>(q=Kb7ҡ:J a­] .wV=hr%F1P`ac'ݜgUN9LCIVw˩O8T=IB[aU+uOKKvcʪy}"m Z0N:٪t @dkYR(zZG:y-Bg=~1e}…Z@aP WImC/ lvÃG]9S6"?T9QAT17 Y)&/_V,ieq T h q^Ȇhoq]GcfAnt v\J+-E=࿤ npqe%+R!wpj]PsG%`ccVn"IdF-GGUvl /=HJz F5# y[i?!ĎRNo;~El$"XV`o)\NS_c , m*vFA<eTtOJB~!~ܶ4`o.Hxc z. }X\\}mf4QYABL,xC8%0^ `~}M5:ӽ$;81~| nq2 UI{0%I5n-X9c ]~Z"jH ̥7X}[N#Y>L9'la1sЭD?,S -((!=5uX^PhS؁qe f죰MӁʈ]^f+ܺ7;^Ք ҡ. 6IdxA8wڂL-PbYc/0SeVrqH+rkk{IcfDğR4rF=Q" 'NpVV;)sX-1UTl2fgJh4RXWLQ^a|Ѻ ĊSdhN[u6E}Q=7SA%ՇN{*aM'n> wX !htqݣ˶G!2uߒ1˙\f;[5@7g-ǐ1z\eBc99 TOV]"hE]=[/^ 7)wO]ɔ˒2QCYQN5+9o&ƃ!P|]31-|֮l Qa;O@`7AMtLND{Vs0Yu,TOYM|opJQmyp> 3 % qujDC>!R e-Bd6ˆ*~'LJP[K2`;pD~&pQU6I`/af8L4y ԽYh+  2W\eid{ޙ+#6EJH>Dpl8TȺqLTh2Q'0qȷU ts*i6*5$1 1̆YUb &>7Yf0,kny (P}n0ma!JEA cK3:2 xAJJǽ @a a1ѕ!rg7Bhx%\cfKa~8m8DJjSm `I'B7-^O6`e%л"68=φl ~L `Ky. /mk' 9pK7X ȋԼ)Xs%U/PW88ZZ,3b\~\x^|\-V뵸˯oމg GtMRecҔA4'䒩! Ƽ_޿.꫗ջ?] A)-Wk~}`e.a/퇻ۛ5W[-lfaSMt3]4\sV#=]_Bl^Fq\kGLc̠Yi_6{`R\^ˍn|W҃eW ;AG贳QKɂAU"vQn|6/(L"t"l9n|P&Ѵke+>\n=}bW H`xr^h@h8|gUntɚcĘѝwf;1[cn'(ʦ%N x-u3ZF.*g[ r8HЏq^FA%i_߀ F/7xŢĚVȋ;/RΒ4]/ n ,SPtN.i V'uJŇy @q_-I16ktf)W;|΃+46?=vBJF=3|FKd!skHt-JB4)τg53&<;٦T f\Kry6ݖ1`2tج8olɦhhcԅzuukpY BF]¿F1&Zm k,Cjj*'@@3oRAd~u&B0/t d9RPNmz?ểlgw+x/Bg'`asҀ, D2VnfՍJ i(Gk֊ͧՄ>[.ܻLrH[ƚ!]&r_/7yt+=zi \^~"B?@ˏםoC cDE#Ro64-]d9p+/AeZ% )9C1H '4x;o2Z !ȉ@ѺBwf$N5PKfk3OI!sparkipy-0.0.2.dist-info/METADATAEn@ ~ @qOTH iE[8İ?Eyx̚ rF :0z gTx"-m1.0 n" ?TZͻ: b-[_<1TZE.gq77)UMֺ8Aj\Ҥ;cu8xKKI,uy_ڵ֘ &g4׾Rˮ$Ubd觭^W{hWmbbzq'oZ(XAU KЩ7qP}'{`=z4&~AR F3 v9KfƐⲌ3YمnӖÏ䶉}*Wf i1J2k rZykT:${)|\5hDa39r,,QZ! KE%bCɧa}?D isRKi\ecn)ـzNkf# >lo a{gϰ}q8'^D [䗞 3UbVhg[ ]stäigI͊S $(bwCv6%j>Q ܁]AK]ru3a(Dnj@\.^4R45l{ՂrI<]'Q6ɾ)SKpt60@k-+77ۡb(~˥zx﹤uSv$ȯq[5PK}K3Osparkipy/__init__.pyPKe3OԜ,4sparkipy/runner.pyPKP3Oʡ'Isparkipy/jobs/HelloWorldJob.pyPKh3O-i&sparkipy/jobs/PiJob.pyPKwL3Osparkipy/jobs/__init__.pyPK6i3O7Usparkipy/jobs/ajob.pyPKeL3ODsparkipy/readers/__init__.pyPK/f3OIq!nsparkipy/readers/areader.pyPKf3O 'sparkipy/readers/aws/__init__.pyPKf3O"gsparkipy/readers/azure/__init__.pyPKf3O sparkipy/readers/gcp/__init__.pyPKf3O(sparkipy/readers/gcp/big_query_reader.pyPKf3O.qsZb3 sparkipy/readers/gcp/google_cloud_storage_reader.pyPKpL3O! sparkipy/transformers/__init__.pyPKL3O sparkipy/utils/__init__.pyPKN3OY-'g!8sparkipy/utils/utils.pyPKjL3Osparkipy/writers/__init__.pyPK/f3Oꍹpsparkipy/writers/awriter.pyPKf3O sparkipy/writers/aws/__init__.pyPKf3O"sparkipy/writers/azure/__init__.pyPKf3O ;sparkipy/writers/gcp/__init__.pyPK;h3Oߧ<({sparkipy/writers/gcp/big_query_writer.pyPKK3O~tests/__init__.pyPKfk3O]{l], sparkipy-0.0.2.dist-info/LICENSEPKfk3OI!Y$sparkipy-0.0.2.dist-info/METADATAPKfk3Oʩr\\`%sparkipy-0.0.2.dist-info/WHEELPKfk3O&%sparkipy-0.0.2.dist-info/top_level.txtPKfk3OG M&sparkipy-0.0.2.dist-info/RECORDPKL)