PK}K3Osparkipy/__init__.pyPK$n3ON?9sparkipy/runner.pyUMo0+FHKġʩ9Q[!/xw!hj}7o捑uܼXJ {Q7M "a@Z(JŭNkaBj"B7"a|,- @KOOC:*aۼmo1`x[ٞ q$lߘtb_aNY4:n헰 !];q:.DF.T' -KiĶFj.RRxޥ{_%fY,VnȐ;gFݰVM)hiffey"W1`>9H' o: UtVkNěaΔBCYLL: ]$Jj]ӮD`?" F??f:8;J욺%V:K z !=y5.u $dy <^_:q@c64HGlwj;y2(˷OjUU &'WW؝dPmHEFTB瞘~OCKPaQ@r{\6gDz 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__.pyPKu3OJ7;v1 sparkipy-0.0.5.dist-info/LICENSE]QK0W8Jqz3Y8rR&1mQl nR3f2Exh/@wki~X]&Ieǣ ahwW8fMa?Z ~MgƃM!z0Nv h@Np2vH>^hqoA>h}s>!Hz{;b8z-8t}0GG nhsK^۽;}Iu{)]RhQ9>f+ Tt1 <(i'Lqe/DPD{ES۹~{+tag C]\'H!IOP˅0AP)"rÌz)pBRoA.[!<RADBp2+ֹ(aRj(Jh$HN%xMd+%>\Bod!tI AŔٺ` dQ>GR *|KX(H*aktd*԰Eα8 ~PY*3PYTBc7wYr*/B#VL1oЍy LPr&NDȉq%ЪEp뚿BY\5)_PKu3OW !sparkipy-0.0.5.dist-info/METADATAuQn@ WYRҠ=hQ!E`Nr%Zx_ݥu9 J"3;d,)&] +DK5qäjeYGk1N5F}Gө6Tf`^0nQ'4kxNm5E3{dQ;̑B䒨=,-WOKuoe*1i{j]?ʤPK~5?_saCB|s.hYY`=%& sQ o3HxA:X^x-6Sr%;tJ]% 9j B~ vPRs<lٍ3uIja) Hww;&tH2 =l)&. x9 H?PKu3Oʩr\\sparkipy-0.0.5.dist-info/WHEEL HM K-*ϳR03rOK-J,/RHJ,./Q0363 /, (-JLR()*M ILR(4KM̫PKu3O&sparkipy-0.0.5.dist-info/top_level.txt+.H,,*I-.)PKu3OJF sparkipy-0.0.5.dist-info/RECORDIwL}~ @ E/@800 /_$;깗[4UPj|융?F9 ~U(]3<`tMV:ܥ;Q@o`0@[K){) 0 )s8Ľ:"o`SFb 3UR~njC<^ZԴO*IM YӒ9oʄЩAh)r Ŝ!mĹQZ>.2ET~5RlQm/㨈]"o2m4̠I8]uU,k؝+]Xvq Y6aIJ5af1KA5/vhVuxgt%ecz%kPY8M"_2ۘ2APK}K3Osparkipy/__init__.pyPK$n3ON?94sparkipy/runner.pyPKP3Oʡ'8sparkipy/jobs/HelloWorldJob.pyPKh3O-i&sparkipy/jobs/PiJob.pyPKwL3Osparkipy/jobs/__init__.pyPK6i3O7Usparkipy/jobs/ajob.pyPKeL3O3sparkipy/readers/__init__.pyPK/f3OIq!nosparkipy/readers/areader.pyPKf3O sparkipy/readers/aws/__init__.pyPKf3O"Vsparkipy/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!'sparkipy/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ߧ<(jsparkipy/writers/gcp/big_query_writer.pyPKK3Omtests/__init__.pyPKu3OJ7;v1 sparkipy-0.0.5.dist-info/LICENSEPKu3OW !Rsparkipy-0.0.5.dist-info/METADATAPKu3Oʩr\\sparkipy-0.0.5.dist-info/WHEELPKu3O&sparkipy-0.0.5.dist-info/top_level.txtPKu3OJF  sparkipy-0.0.5.dist-info/RECORDPKL