GitHub Viewer
PK
.nkH DataflowJavaSDK-1.5.0/UTh=ãVPK
.nkH€Ã{�v¶$ DataflowJavaSDK-1.5.0/.gitattributesUTh=ãVeRËnÜ0¼û+ä°@�úrJ·E� ‡6?À•èSZ2$Ê»î×—²×Ƚ�ø˜!‡z€÷@àiÀ*
'
8sÊOp 줙rfO.eê±jrY†ÃpMPÁwÖCéàTYôGT3e·–xRÊ#G2NÒ@&Ì–®‚ZÉèª�2œ8b^zã{o‘–.€™ i�hm(²@LyDá?䛆ѶQò¡À$¨ƒ%Kß=®¤Ï±3¾ãuv¬ÖíÉIãÔO
¨PBªâå‚K17îe0zp)š#JÞèL6Ú83�´å(zŽgSíϬ¨šùT•¶½ÖŸ�l“ì^¼ß~·Çc�sq;:ÊŽ?pÆ�~GSN“
Á;ùi&ÜËŽJØÑõ“sÙ¡ðõfÃ�Ù÷·¿@ðòóõÛ?BŠà¹ß©j;“éHÜœ¤$Ïí{üçvLj4æ;¥Õÿ\-¿�|5øv«oî�ÉóÀä7™�é|+íþPK
.nkH©ü¢¡ê DataflowJavaSDK-1.5.0/.gitignoreUTh=ãVeŽ1
1Dûœâƒ… n¼ÉÂSð÷°ÙZx8ñ-d·��yÛâÀyðQ~7+¯Ûð›ú³Sï~ñ²Ûçù‡` ß,�ó¥ê
¾à&ù PK
.nkH¾êæv§% DataflowJavaSDK-1.5.0/CONTRIBUTING.mdUTh=ãV}U]‹ÛV}ׯ˜²»ŽM_%l¼dûh!�BFÒHº]éŽz?,Ü_ß3Wr¼%6ÖÕÜ™3çœfŸ()5êSpuNò–ž‚pú�Þ»ÓŽðÐR\¤™{¡;ç›1·Î÷8Š�#ÍÁ!
§ÊŽÄ·÷ûªº¹¹¡wÒi:k~Q ÚN¡†=åX"ZÙ•Ø)ÇDÑõÞJT_ŸTûQèWߺ“k3�t¼$Ó@\#9ú 2‰OÝ
)Íñ§Ã¡•“Œ:Kˆû¾äØ7:pàßDTläÐŒ|pßò¾mâòó�÷ÕÝñÃÃýŽ–Á5Ã
8[%õ£ó²§Oè!N¼4#‡3Mìüx¦ZÞZ"]Ö�ÏÁõCazíu`ßKÜzâ.I¸�°uæÔ[.�Ĉ‰´#TÆRÍLE5
½H»^EŸ“‹Ñ.¢Œa`ßRëâÆû•å=}ÆË1jUn#º†’š ȉƒÓI�F çÖ�3
"©‡Ê³áùj¶ÈÞ¥ó›ëªliÒ6�¯;G’\—E¶îÅ㨹ýª€•éðȉ»Q—ßøÄ€qHXЇ‰#4;ly/ËùÓëõ]_4ÍB¨FAñ*}$†@
f(Þ1¶K×áÉ–ÿeýš×¹UPÁ5Âw…ž�Ú¥Å2f+‘kåF/2™DAfm´pÜrtTåiÇ–ðÒÓÈ�„x©4©Ç`„éYCC¨#S�ªÌ ž€7Ī´|¯tÜ{ø»€?â3]BÎ�)wv#„†÷jL_Â5†lqn
N½”}À™¾ÿ:ùæ‡CÐ�C¤¤6ÕªßFío�° ;ð –tr)~Óâõ4jVÞQ½+bÓ�“Ú“ùlȦà7_
Δ¶ÔŸçâJ;j�ðÒ¶�‚]1 ¢ª›7°Ôyc‹•`€¼HÍKš‚Éa>÷]RõuÅ¡Áq‹š?�ãˉs/q®�?[¬År=?,ÖËu0îÇåý�7îÅÇÅÝÝbu¿¼^‹›»üZþæ�X¬~_®®€îh¾~Äé¨K'Ñ„+U6&MDsRpêM.™Š"{
±`Ìûåýû묾z¹\½»[®þzýÓõê¾?]ß½ý´\ü°|¿¼ÿ™BèÝò~u½æ×^ÆíâöáýâNÜ~¸»½Y_sµåÛÂo@ÿ6Õtë@73ÜNÃÞ%Áßý.(ükÓiB Õ²ÆB>„©F‘:ùZ«¦r
$;ƒþo)Dæì—_gøh2á«Ý!¡ªïú²Nz..®L÷‡ø¾@–£Aøï.uëÔ¦: @ñ£¾;ÈÊvv7‹¹â€ç�ñ"”šzVp6/¨øi?'
(NÏrÜ@”!cå¶‹hfŠq¸ZݨôÊ
Ý�M.œ�r4¸Fža˜Þ|ú—_PMHª¬gš†O‘¿*.ð�øÎåå÷("ô#\¾üøì(ˆpø sÙ±GzÔ^î BJn´Ó? ñè‘|TÀÂê§Õ+¬ô=j
ß¿({ñ_úmõ÷Ü©¶ØüQR7û?¨Í„xE: �(ýÑ.B“TÀŠ*b—Mr 5C%ë"… ügΔ`r`wš�™Žó*`$>õª|`‹l
€.û"Àí‘–lºn‰·Þ q‰nôžèºCØá%±¾Ì�qw"W×—gfÍ4¯¿Ö˲¼¶yÍœ!ž2ï
|š–¡+#*1#ä�8Gg·ªîr9–xÏÉc�ö
J
ÛäQDá�Ul�A^Ém�è+ `úvø€
¼ù/lÅÊ^Á#›SXr+GýÛ�ðXÖÚ¦“«Tã¿—›‘ž§Ï¥â=®¾fèK‹ê›¢‡Ct±ºæ[ñ¿A¶HøPÚñO¬÷�vƒÌ¿`q"óš>ÿ·Ì|ë!2“�§h6•›jº7±[¥2˜ºUò�ãœKFjÃSW8vdô¨žk»Ô¢o¹3�걯õÑ(B"Wù›îÉÓËO¾�ªÎ¡±_Dz’o#רá|)ÜZï¤�Û$QYÓ`)‘L‘�lÓhžˆP÷óqÐ{^°®à†ÌRšˆ¼C1€¨œâÏÇ6•bbKÎa3/ð#È(r)Ÿî,aXHtl‡P5ÒzOQ3Ø åÙZmÿ'UŠÇ¯RÌ>kNë«ÖáQ·ç-Ô'YJ´„U=6ÖÓP¶Æ�sìÊY73q:ë�JfŒ;µí»â¯¤¢Œ˜|aÓ7%
ÚN×ò¦·o ô±ùúü›]Ä•9z5™Ýx�ÛmZy"U¶‰ƒŠÈ½/½ãG1O"‘�F¥©4Í‚Š0æþÀ‚G–Ï÷tLߓЗÔ!–HB=�ú¹Î‘R� 'XJ(÷Œ€ÍizÔ¡�KÅB®’WµU†�äQ1%’�å²±Ž[w[�ˆ–QÈ5rW‡0S$õV&묡Cðš„«ÚùÌ=2×1½žíŸ}Å
€Ü©)½1•ß�R—¶ðÿ€H8CÅ(ßJi'O…‚cÊz¥x93
cøðþ×ßà)ËŠA*2‚6è3ϘÐ,‡FäL�™1Ô4Ãa%�¿˜Ò\
ø@ÞCdza©ŸÀJ60§+ÒX¸F3Äà
Žç°§ŒÕ¸€LÎëŠS‘1Xr3sç_†|4c)F×øTXÀN PHÏŒ©ï÷—Ë%¡Ž,‘ªìW>L÷?§ÃëÑäúîEÅ´Åþi¸ÂdW@k$”ÑG¤YÑ%H´T׌´„—Š.Ê´,Ì’*far®�â��ÙÑ«¥‡YwP1* 7˜@:éÁå`’NxH§Žï§ìapw7MÓë Œï`8]¥Ótç†÷ì’z!»uJÿeþjq°�¤t."Y%›œäÔТ’K¢ó¯D5B [6?ž!]©Ì7öe2·Û†ößÉÛ¶E…Æ|çš\Éñý»n§í÷ÿ±—ª+ùýÛ–\ä?Jòà¾ý8›o¯ÂÜ=AHÃÊÕ7/hÕ0Ìz(«ŠeÖ*XØþ±kÔÊ:ˆ/t*¢¿ ÿÂLx£§…C9z\l£ü\"3ʵ‘«ð?4OŠ=À‹¿�â
ʃ7i~{ðªd¢å#³dðÀl…�ûê¸þ+ê0f¢^î øÔ¾¼Í˜rQ�ŸSÿÜìùÿî>xYÇ
/àw.ú£>âx¥W»Ì‹¥n÷ÙûéͼÑh8ºñÇûƒ¡0ß+¸ÝépßúPK
.nkHºO[Zj DataflowJavaSDK-1.5.0/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/ReadTranslator.javaUTh=ãVµWKsÚH¾ó+z}Y‘""›ª½Ä^'”DQHNÊ{q
Ò“�vfd¦üß·{$!�ñk³Ë=º¿îþú5ê¿èÀÊ|£ÄbiÀváõ«ß~‡R.R~»(ABç"æ™æ Y˜%‡AÎbü«Þôà3WZÈ^»¯À!�£êÕQ÷6²€Û@&
Áš#†Ð0h‡�yn@dËUž
–ÅÖÂ,�
Å…«
CÎCY†Ò9ÞÍ °%ÌTN/�ÉßôûëõÚeÖYWªE?-ÅtÿÜzãÐ{‰W
—YʵÅÿ*„Â`g`9:³º™²5Hl¡8¾3’^+aD¶è�–s³fŠL"´QbV˜¾j÷0ê¶2Æ28„à‡Gp6ý°_üècpØ—Át:G¾B0…a0ù‘Œñî=ÆWðÉ�zÀ‘-´Ã¿çŠ"@71ÉBN\óVa.K—tÎc11†–-
¶à°�7\eä\„¦Œjt0�T¬„aÆÞÛ öh§Jéw:Èó7ÂLº[FnœÊ"qfØ2[›²àóe.ƒsú²—šíÍ!åÙå±Gâ3¬aZÄœv‘/±|Ãp*ÓÜ,Fa¬¦ptìŠ=%xP8Û"³áó>Ðï¨l
Hº_H¿(�œ”Ü?¶hÈ=–ò{¦z¤W¬1öx\bS(Œ¹–°æ¦½Ë hm¤×Ø@‡½+Ôz¼ðRa8Ë̓0â»-n»„)î7°ø�ÊÀSŽgS¨WxSu²MÍ¡m,Œð°Ï\¡ôè'D¥½
¨el:ù¯¸£ŒOä4¶Ò_HÉ
>^reÁÒÎÎî‘´—mž¥N
ïãYAg‰ø‹ZQa¥²+wå”ÓÑ‚®[n6*&ÊÃÀ¢¦¯3¶Â+ õ{‘$Ød'‡ÊO"^³ª–
”ퟅܩÂÅ
+Ø‘%¤ñ±’Ø1«š!Û´ä±R¯óÜ8ªì̱:ÍϤÕÿë,
€‚nQ”c~ü)04º½ºDÓGQ1°Ñ—ì7"Ú`ÝÃPUê.;ׯ°»íÙ°€_˜àÿ\iñ‡ÏMw|&Þ�GÁc–÷Ze0ĸès/&NÉátþ¤ŽzMŸ«¥ninG¯¦«ñ2ÃeäDÿDw¯mÜÆ`j�£~�×Zê3d³ÏÈð Æ1Ýrkž³·çâˆó¦¸¯~UôXŽQèx—Á«¤ÎÂÜIÛôC@�]ù˜4i‡ T«×uÜ*Á#²#^¼ØYÊÙ‹Œ—Dma )í]H-Á2Ž9y‚{!ÑRŽ’
啯?ÕÖЯ—A�Ý�¿»öÈÅ&hi'ѲˆÌì&² W�V”ÐAçGhoTAÕkÙþ£
åN‰ŠW.—óAãåB•íEó„ôzN_¬j÷Á¡¢y‚3Òl�óÎ#™fv~qÄQ%ÂÓa1}ƒ^v_¥|þWîû¢œÕN;ôÚ1pŽZÜ™/^K—›Xû¤—3¸$l¦qciF-‹äw¶Fvª ‚àgoߌ#^èd×q„iþˆÞÄØK`|˜K.©8B —_²-‡MA}x¼KùEÃö‘ôˆÚI*Ã9’©âÂ{òÅ—4§O 3!J1@¿ÜºíìZŸ[ù¸äc*ø}Y´G¾³aY^|P‘ª@‹Ü:�aIL.¯]´AÅq¦qú%*³N¤–åe’Æ&hqLØ:µÛ ×óÖ}EJ¶9èðó‹ ‘w3ËÒª¦Ìd‡A|S" éê‘EÆñ¨——¥+Ì:Û©J_MIwåÿ C¤(ÛB1Øë‹²bv’[¬`´Š¡ò‘?jÏ'EL“Ä»kÆQ11è¼Nyóbèá6¶qŸªb8>šë^ø¿Ù\iµ\Z>%Aƒ#7_avÐ)î½�¼.¸·_sWwªûÏ�ìWבX¼^Y袀óGs1U�ØûôPÁg…´Öá
((5^÷úbð˜
nî}sÔ®|åíå~v�ÿPK
.nkH_‘¾G¶q DataflowJavaSDK-1.5.0/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/ForwardingPTransform.javaUTh=ãV•UMSÛ0½çW줗„IÊ¡‡†aH´ž2 ƒGÙÚ8*ŽäJrL†ÉïJ¶“À@€\ü¡}OoŸÞ:ýƒÀHå+-Ò¹…ΨG‡ß¾Ã/¥Ò!”I@®èR$(
r($G
vŽ0ÌYB—z¥·¨�PŽ‚C踂v½Ôî`¥
X°He]a�8„�™ }ð1ÁÜ‚��¨Ež &„Rعߧf à¾æP±eT˨:§§™#Ü)fkÑskóý~Y–ób¥Ó~V•™þe8:Gç_Ip
¸‘ÿBS³ñ
XN‚“ÌŒ• 4°T#Yå—ZX!Ó5³%Óèh¸0V‹¸°ÏüjäQ×»ä“ÐFFmø9ŒÂ¨wáô÷äfêÈî†××Ãñ4�hÅ”î€Á°äXFÂâ•}
42‚›ÇaïÄ `¹²CËè´$º÷“¸
f—¾}ÙÛJp¹67_’à�~ jA!KL,‰Ýk@´`.¶Z® ˜hE“©Â¦TîØkÅ÷öo{ÆpFŒaÕê º�åß©ÃÐê¹ZWÌmµ÷ÓÛÚÍ€ªlÝ»A½0•9ðyöÚ’ðÚH=�äiƒl Ql½RË|…âÄÓÆêT/ÍwŠý÷ÄœÇÄzËi½a‡:ó©×‘Qóð&("£ÚObwñHÿè…°çÔõûñ1™Ý|¼ù@n}¤8gPˆòRÆGõ.‚‚½ÿCâK AÅþH竉ÕÁä
Ø®àFUDúôP «©¶Þ’@ܚ̄x,$žºý �´Ö¡®aC¿t¡ÎÍøõA•ŸÆÈÕ8aNͤvDE®»³IÂâPç=º?pøT40MKà]$‰ë¡Š
Um�Ú;q|û;ƒF“ áÔ+çµç«|´þâ‰0!ŽWëî~²÷ TL�h¯©/â³EÙ´ÝqÕ50 b©¾�³(‚»^CýHåï'|Õ§!VI)—�òN \ó¿ïíÑ'¸[„ÿwø ¦BܤÐìzÎNiŒ}⟈Á'ë$/ëÙ»’´º—>ÆJK¯âçê¾C£ð„BJ%XãHb†ÿ÷ÔÔ•±ºw¬‡ñÄñÓ@äÂ�ëÐ&‡›9�åHS�7Ïøƒ+žsIwê|øZ™x޽)…38¹Oi¤÷Ë&„1ßsû 8Þå¹hÿè5º!—YL8ß…c§H/'z¸}äÿæ¹ÖŒþ>§^Ë,ÿ«pëÀkŸ2Þ8Å+�zÔ‡VÏ5l u¿P9$L%µDæ½O©hTa�’cEÍ@|ò¯÷‘R™{h�Þ•C¸�Ž:�öÕÎ[!ÿ¤Ë4:È¥ù,Œi1
…¢ñžBŸæþ‡ü>qco›5ØEè„Ý3ç~4ÃÝ?v†»1Ìâ@ýÜDÈÅP)�Ãû]/½ãiǹÛúÌPôªIG�Óã乌§5جx†S’¢OBÈ÷•ÌSÚNèŽom̹‚An�º-Ìv·¯ûʼö:Í{lŒ©Áجof
…Œy6KΈ§ñ ‡ùâd°)B^ÖÏÎÑn»Ð@ضq~‰%¥Ð“p¼ÑXŽP#Ÿ“8äeÃD“U¹È?�‡§¯è“¹†dÍ3bò1©rH˜ç#ôÞÚ,þ«{G}1pß“AüÐ y__Ïç�0OcÀ¾|÷Žß†…?>3‡…j~¶ ,Æ�Â,lK³œ1YÚ³MË2£Ä^P£÷
{Øy"ä˜C1áå UR§”‚”ráøD2!‹vç”EÙ|E]õmË ådF93�@¤¶ùh+èR%&Ðu�ŽªXÉaµW¡SË
€¨U) èšRcã]—ÒwÀ°Œ©/Tòe=�]VP¡¦½X ʱΕng¾ÜêË.”ÎÛvTØÝ>òõ=�Vç˜RÖ8+~E¢ê-ƒßô,; P“«ºEÀÃ2Mƒ/Ò„å½;ƒ¿W§òzÑî1ßxwìâ)Ç:}ó§ã_£)Þ,#8C›¤ý9oíëªn:“½ÿ4òmðaøB«Ì[RiKv¢6Ó_È]`½1$7q…Ö÷œ¡…T/¢eÏ
”à*ˆƒˆÜüv¥/žÖú&,½*i±g!+šÆIu!Üå‚…gâMbñ4>[ýLÿ"a¢p¬‡³FÉë¡?�ÕÓZ½VÒFw/»úÂò’ýµÛ�Í?äâ—Á5u±¨ðXrLðÕ�,3güä5¯èkþX†+ÞÃÄL¼Ó¿F»õlY70.U'§—ó”E –Ô@uu5èþ’ºQ†j�¾òA[ /{H·e4†ð–êý÷½L)Wò«‹6Š–ðJÙÆÐ
®ËB_Æy£‡HCÐ/Dë{•tä0«5–™$1TðòäÄR•JõXΔU¢B\Óëâ‡æk£Qì¨úõ`³
‰ó6‹KšÅ‘O‚»¯Ë
&¼q«0Õ¬‰9•ñ,ôÓºÝyxNºÛ¥ÏZNZ]ÆÝñjÐð›/ö=™Äƒ3úÎèÐ-Á‰ßQÔŸŠðïÌпûïLØ‹‡õ×ÞwÁ¼ñ‹®·BŽcQ™ª)f�†ºožô=c²ûEóUû Ëåª0óàýp¥17P�]B��õÜô[‘·/¶�þPK
.nkHqv÷áçl DataflowJavaSDK-1.5.0/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/InProcessBundle.javaUTh=ãVµVmSã6þίئөäÊõfú¥7r´—�& ÇÜGÅÞ[re™�Þä¿w%ù5 Ü´|dí˳Ïî³vÿøŽa¨Ò�Ë;Á°oßüúü©Ô2FÉ�‘…5º!Ê#Èe„Ì å!ý)nzðu&”„·ì
Ö S\uº'°Q9$|R.Ï�bˆ‚òàcˆ©!!TI.C„µ0w.O…Á—"†šN¶œ¬S:-lÀ†!pS€¾3&ý½ß_¯×Œ;°Lée?öfYÿr4韹[8ò…Õ©ÿ>Ê÷9K
Jƒ�D –ÞÔ:Eµ"�À×¢XM-Çàÿ�\‡aŽ÷p§P²¬{ñfà(¿÷"´FѪ&IçV8QxÕ:ÎEªÐUË}$�ßRØÆ“ÑBÜ{qÊipÔ6#{¿¢U��Š¡Œ1UDúåuù¶Ø—€Ê“´‡¨(ìÀ®¨¥ö\©T t™�HiŸ¢HsT(š98,Ö
'ÈÞ£7!¤;“L{-b„ó!Ùs7Rc�l\5½”á„}zv=ÿ
&ÃSbCBïh@˜÷nB_J¼s!òvÆì‚Ô~œwRÆgÝôC^€ä)ËwaÔ{�‘™qýÀ¼×Û°!)c\ßCŠF
PÓ´9{§Ö™PÜgû¡¼bn°¼€NW,±ÿ
ôA¢MàþÂCÑÙ]œçT$Q¯�¾ž+¶¤Žƒ�;/\§PÓ¢×Ñä[ØSé–•l�eÞLÕÌ„žêmǰœUpŒ¤eâ*�MàA$¼K-h ŽäNFìöó�°À=fƒ9Ë•Z÷Áü£�üu1€/ØžÝkiQ+‰CzSÀAH(œgûIŒTšòEù*øö,&,�‰HàÒun98Õ]Æ“¯ L~>"ˆÏ
gé*é8x»µtÈ0Jûàô¼
ôÚУ¨»¤˜4°—L!�îÁi2M§}¸NgÇW3»N&“d4K‡SOàl¤§Ùj…÷½i¬·=øÖmu„°¯{{fkô}íã9eÝÊ·½õã¦ÏTûT#ýö0¾¤î9ïbÀ¾¥§§i>—59¡:;‡ÂoO¼ØW?†{Æ,Éæ=áh´m!¦
ÂG“mäRû¹ÙYfTf®˜ :Ñoôa4)Uí2õGÊÕõõ¼\z¿‰_Òµ±ù§’By£2eâŸÉ‘óüsZé{Ôl¥ Ų́Rt€o›(¤Ç2I0´µö>Åy¦œ³¸:Íÿ²'–cªlÚÃ>8pývNíãû Õà#ì©Ê—r“²M9]°�~¯_Ênf
Â.=PKÕ(mûÚ8¬Šà%o]a¨s:¥€`‚mO®¥â…I÷Ã�uQÍ#Â*»§Góá%»J£|ÈXvkê›Û|ÑÀ6_±F“†²¯FÝÏ3l=ŠÌ(�UWg…VLÏl·úElÓ‰vÞï:ËŠ>¢åO- Û»]H{r‘Ë·Mèšj;#’'ÝÛQl‚uq·4ÆãÒ—ÍcÊ\Ùo§¼q¾zl¹_O¬01§àŸË„‡f˜2“aês§bß_;ùá‚m
ø¾µµ¾¥-¬Î̺Q¨µv2w'WÞÜ™Üü˜8ÿüøæ\ß]
ö…ßÃ1g9-³/͘[�—6_Yˆ£_ËKÒf7ȯ$Bƒ ß+¹ö†–o•QuvI4íº`ú.fyre™·£ŸY-íE†ƒì©Øûš‡¥(«ö¼—›—ÎZe½g^IY5ó©»V�±-j£EŠÓ)̧9K˜Oûbkºhßje3Ü’X
uwÕ=�fo˜õšŠ¤ÁbË(sÐùv›ÚQqͬÞ?$u>¯Ôl�©dÛíRâ†[M!õQ¯bÜÈ-s�Û–e¹¼aÞí\õŸ°—ggæNv'e~_�þPK
.nkH?s.yo DataflowJavaSDK-1.5.0/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/TransformEvaluator.javaUTh=ãV•TßOÛ0~ï_qb/€:—!íeL¥”-jQ[@Ü¡±B+8e'pèâÒÁѬu
%_ƒÒÎÃÕ CXÈõÁç+BAªËJ
®R„F¸UèQ˜ªž*’ïx^¤†ùÜ5uPÇâR^Ç‘×üú´�
Ïö,Z´ª0UµÜ·Âi!ð¨2â oªÖµûp÷%ÒõÜ3¿»ÎÎÿЪw¶ƒ3§‹|nŠŸ_L]Ê0V;}ž”½‰ÎeœÃ‰Þ·*GzÞÙèy.w+õç _š¥êyèÁe6·¹¥7ÒP%Øä©V=»µãI¤ /
–ó¿¯ãˆ�ݱhÍ£ ™D7,ËYt‘sxWfˆðM—qz1`Ev^ÞD9G0‹¸(óx¶.
~)ô€j½p,JYïxÊÆÓ{q2~éUzŸí×ßó³à�ŽÅ*²"昪ÃjìÄ?O¶÷nd»™—°~{È'5ï�·¥êÇkÇ*åxÀOP.B!³½®à»¢6v'Ùæ‚mÞaü*£æ½O
t%hÞÓ¶µ±äíÍø9'z�óYˆjÜêN~4Ü}Ø�»§ÜFîŽFaMíôfÛP'o?ýPK
.nkHZƒä8oBoa DataflowJavaSDK-1.5.0/sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/DataflowAssert.javaUTh=ãVí\ÿsÛ¸±ÿÝžîµ¥îôè»kûËÙñÅç8©›œ�‰”Üt:oÞ@$1¡H•¤¬¨©þ÷îâ¤DÉNîÞTÓ^,X,v»Ÿ]FlY’8%Q¶X&1M#FÖq9çãH*!ù›¤‘�K
m)´^·)4ZJ¦çe¹üáôt½^‡”3fùì4ÍŠÓW7W×·Ãëÿ†e‡·iŠ‚äì«8‡ÉŽ7„.�¡ˆŽ�Í„®I–:ËÑ6üîâÂö?¯’2^Ð¥¥å—ï1WÙ{W9É̇{ëA¿óë.µ‹=¹¶ÄG¡…ž]kR¥[Ìå°ÓK¶‘¬VÒôµ{‡êVvøù,QZ�áæô7ŠÈ"ƒ/Yªh-AØæ7c¹h†ÜRÿßéÃÛg£9VÖxÄDzf«FÇ٪ܫ†Ø
lˆ 4Gµd¦É`DÅ p?Pf±f�Q†J›Eæ^žôö•§‘Þ.8…âA+v¹ ‘¡o› ªÌž+È{ÁT.M
–v Ta�ÙÓªÌé(^õùš¹E\„fkX
õ‰Èvª;´±%§èȵ¤æÒq�©“
ã¥ù
¨K˜ßFÎøÎ9ú?«$±Yê|wP‡°¾:$lƒ±å¨°å*_f$n’º¶ë^/�—Pƶ@²8Ëc„c~I�r>[[kVgåx[*½ÿO.Ѽ•bÞ]Þ«
¹×áþ*ÿE—š,ôˆ5+±Áè†5¬t‚ö™-ž iá*k8jý ’_²uð‹É±#ï7gpåo&§ªÈÍ/g«–�P¨s*ÁåÒ¬�…ň�¼!AÝÛ˜ È&”’%²8©‹Ë¡ÊÐ(¼c�žê†%=…€ä«"¬xœˆ>Ï¢¯fï’Ä0ºË’2‘LJ#¬‡ŠöˆGÙ€IP@âKì„1Lð¹À"F#_ìMb“r…ÔÍoUàiÞò´´SZyLJ.`Ïÿ:Ÿ4åTq…¥‹”‚å¢�r’:Mh,B` (ÉèäEêXóÜNRµÀh«?‘ƒtùa;Ì\÷õkœ4WÃé|úlft,Nf„{;h>†c•ܵvÎHi˜�#4U늲Ús£¶¾’L¬M•gËÃ%Ûi™+mþ+(§žÍr\å›!pH¢$~ýÅg*õØÿÄa–@Ý…ÅÁû,NÃËG6Ž_ãûÜr¯Ê#W`sIï¸) Ußyµ§zɸãÔ¶x.—*G(Çz3åZ!`¨5búŒlÓY[ÍŠ©b’¢ªXdc–â§ÝPXŽUò͇Ö6S¬�[Îï�à–Þ_Lƒ×6qË}
xáS[‚/@—:˜|s’zÁÀBslW`Sö»(ôZjÈLõ¸zÇL=ÙÒÉ£E±Ï¯|Àé8.æa¡±"¶�Á€n•Zyøù(ÜòGu×€Äégz]ŒÕ7ï�þPK
.nkHzO‚Ïbjb DataflowJavaSDK-1.5.0/sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SourceTestUtils.javaUTh=ãVí=k“Û6’ßý+`¥¼¡lšc§*_æµ�g]ì™”%;»•ºrQ4bL‘Z‚Y·;ÿýº €qÆNnëîô!c‰@£_èÌÁÓGì);Ï6»¨EÜıÿ™ï�ÅîÏòU³ãýÊv4�+’QgÚ«ÝòúîÑPK
.nkH;•Ç#öun DataflowJavaSDK-1.5.0/sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestDataflowPipelineOptions.javaUTh=ãV…RÁnÛ0½û+ˆœÚ “»»¬—¹I¶+œ!NWô¨È´CÄ‘4Ižý÷RŽd†ž���ï=2�&0…¹±GGÍ.ÀÅü®¯>~‚oÆ4-B®•`DÝ‘Bí±‚NWè ì2+?ce¿Ðy2®Å\DÀd,M.oàh:8È#h"]ç‘9ÈCM_åòîu‹ÞƒÃß96»=‚´,HÉ-ËleÆ�lr-˜(¸wH73ð¦½ti*òÁѶåõ&�]Ÿ81©a’•�—¸ÍʼœÁC¾ù¾ºßD²‡l½ÎŠM¾,aµ†ùªXä›|Uðï+dÅ#üÈ‹Å�Óâ9ød]tÀ2)&‰•€cÖx¶E¨ÍI’·¨¨&ÅÖtÓÉ¡1ÐivÝ�|ܨg�´t ÃðLý{¼”4I8ç}$âMŠf8#¡ZÓU¢’AÖé…¯ö" �±Ý$ Ë4.¼7v˜+n[£öÜ·‹?ÉbKW§:Ó¥Óa‘x|0vƃV¦Œ®©éÜ ÇˆùÏXN= ®¾ø‚z�~ЕC³S¬SØ ¤÷Ù¯;;ÒOÄ®« @¾QFÝŠÂÔ¥*ŒçÊ}õèãyaqºDðä~ã É•¾÷¦ÜèAÓ—4™d•#Š€ÛmÆ_Lðœ¢%QhÌ~;Fpüâ°8ø_uÖ]h5Éáu�»ÕâÈ�`0V®D=‘Ññô¸V¿YjµvÇÁ”Ó)ö9½fXÃÝFcr‰—hÔ´ñÖ(zHf!é
8Ñä=ˆÜˆ%\¿–8ŠÿºúìIR ^«ü�.{ÍÂýԃDŽΚ%7ÉþãsÝà˜ò€ô"Ù“H¹26¶í¸Ué6!u{ˆÐöþE’cŒdÎÛmêŠå*Ì8ÉÁFU×ûÀN‚çuµàЂث*ß'ׯ]‹áVOù“CòıC½0IG!^¾a2´š½ãy%ÉÑõ]™é‡d*~wÛ§)ü�f¯?
2œc†ZóM‚Ã"¶U–VZ£°¿óµk.ò‰Íá¥ÔÔX¤;œˆÎáÎmé¿49T ðÔP‘?è)It‹-¹¹Äá¿�Ï.ö” 6*N£‰¥ö÷—dtÞcމÏÏMBZ8¶À6èow'Tßlé”\Ç;wáÇyøÜº?�øA¡ìNRþŸ¡ÿåψ=@=b�©¹S9Þ—Ž®,Ÿy†ñ»ãþè¿PK
.nkH#8·Ð¾ì,d DataflowJavaSDK-1.5.0/sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/WindowFnTestUtils.javaUTh=ãVÍZ[sÛ¶~÷¯Ø83=T¢ÐifÎK|IÇN=MìŽÄÓG˜„$4Á¤e·ãÿ~vq!’²•¸=“:1›Á´Î.GÕïæ¸§‡Rð™ÓFÄ žŠ ICÛC)†¬ð��$½¿&êhYT·Q³LpwŲ&ÒlÓõŠ‹FÕs�‰\ýÊo�!á§ŸàI ƒ[Ô€OÃ�Ì1ɲhÈ1=ó9€…ØÊgãS%Ÿp^LûG;ÏY6)ç5mkàL´=-…‡iañ’Ëü¿AT�ë¬^ŠXyÑp·‘Š£¡ø)ùBѪ§ù`„òƒa´a‘kÈ~å·èìN‰ÛÙ�ã¶‚Ä2¤J?»Ô{É6P½4"1%h.®9bÉ·‰L½ƒÝùÁ�új¥Ñ^;çC7Ù
®gÜ�i¶g¨c©¦5¶öÙÓ1¶Üδ�õX®tœ%‡ë…Òó[}Ê䆶ÛmÊ6S¾byÉø¬p¯Î‘áU™ÔI6X•Oë/’‰“ª.“ɲvä¥ÙƒYÛ
@bÚû”²Ø/ß``o®´ÞUñg¢F÷Ãt“Ä‚C愪7s»{\QÕ5‰
û²¢ÞEQæ·É‚×Bw¾¸ÛŽEÅF"œ…ì§%/é{€t �@~�ß™¨£pl²Õ,Í'("FuËö`~8À‚ßZ4 �$S�s!+!kÊÔ‘O¦i\üñ5VÄ¥(ØU®%À ÊÎÓ¶Æ@} ýy¾LcÄÂÎL|æjWEÄ$Ï€]Ø“tû7›L¨QÉë¡ÕIüÑm½ûáHX�z \‰ÖHG*‡_Á2é—GDQå6�Ý¢Ä3BrHn™äƒq¤&.é¸ßè³sö„}ÙÌæ�òÓÖ [¦°›’·Áõdº~!pï!Ép7#�µ_ä™s§kû¾îß;nmâÔ^±êg c»óŽ'ªÙӎج}�jº8OñÝ=ú_PK
.nkHºl:®7;g DataflowJavaSDK-1.5.0/sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ApproximateUnique.javaUTh=ãVí[msÛ6þî_�óMg¨V¦l÷Ò¹©OT×i4Ní\ä¸×뤈‚$ÖÁ¤eµUûí.@ )YÊ$½ëÜy&‘D,û†g/ì}ºÇ>eç2Y¦át–1ï¼ÃŽ�ž°o¤œF‚
âÀ
$z"VbÌòx,R–Íë'±¸�&*”Êç…`ê¬èj£79TOXn€¡*ª`²A‰ší°*âÄ÷¯Ï¢0¾c-£x,� úk.ˆÊÕë—ÅóTœ™ÁôE ³€Jg, ØSæûþI“„€Æxî*Ÿ]âSMŠIàcºôš£Á™��ŽgÅN{(Ÿ¥Ç3H¨-µL*¹ð´™N•�ëpŠ’›ÂÒtxTiºÿ‰v5Lš©ÕšQ—žÏ%ú=òÔĖáD^3)O˜šÉSõÓiŽj—™ž…ÚÍrF…XÔqâfR25Iþ79�´ÈÜßá÷Ò]!ô·r²Ö�Ãb±¨z�ÙÀŒþ]9iñex'š‘ìÄa†•¾†±P´¾™s§|¾Tc• >.D@óÚÿ˜!e„º(Ź i(tSCÔ.[ÌÂ`æFVftÀÉié×ýã.;ôŸ¼Ý-0Ü(0ÜÚE^9A‚Øv!)v�
Ik†Ù6kú4ChëÊÊÉ¢6–]Þž^vÙíNN�õH‚À33†©¸¨¦’TÆQ¤¹Ì
1MP©Y¦mSsnŒ1ÌQE °EµV¤œZ‰‹BjیْsÚ')Õ?XF>$°×‘-xÛTúA½Ó‡ÔŠ¿3C‚‚�Ó¹½ÈŽ´:h˜ÍX€Tx,E&"½2AB`Y>E¤7©lc¶´éuØ4Sç+rÛZÞ¨¸m½l‚µx8t,;àÑ/Êå~ÛänÂòÿ9úƒçh‚.¦£Çü0Áðh–6�vÉÑë?.Cÿ)‚õ8û¯�À]ó�›³?Fç‡üs½¥ŠØuŠmØ¡ú(%(:ÅxCoGÙÕ,pEN2à 7E~�NÅ1>{F¼Xí„ÿlÐå.Ÿ{+.qÞov]•U¾Øß§b..“JlÐõ¤²ü]_\oÐé´KŠé]Ï“â$«6阧ƒ¾gxfsq‘fâyös|t“šLª_æùE2×ï¶ö�(^ˆÛ�Ý2–ÛÂî=ȯãY²‰=I"Àbv°ƒ–W ¦—dFÃ{Š/÷ð½ùžÄ@ìNóÉ
¿FSöd/9DȈãU~ƒ¦–4E„ÓÈFX_dBNæIY²õ±ºcM>‰XTG>Š¢e‘^ƒðSÏF»ô4Šöö¢iŽF)@+A RhoÖ�à?D½ðx+ªU�fÐižf¢_9^¬¬´–0ª«¤ÂQ”4ŒËôZdª-ÞŸ¯2&?š©dDèiÁñ0j#¹£‚L¯SäÙà|¦€L$ &,Z’�@ZâèP×8ŠÎ Aò£t¾#�iŒ�9,HúùL˜èBN` ›_Lýdgàž“NÌK$˜Ë4
gXY�%À$šŠY²šWîè]Öu>GÄá´6´lÄbYÝ"UrãÉ uåßs²Èµ¾Ã象î1Òß±`ñT¢^®Ñ‚÷Û$å)M[%7f,E\X÷s0÷]ÒâÂìæY\g‹¼À‘#ÇJ±I0öpíÈEUâÚœDOÎ5¨'çãþTÂaDK*
òó%î¡?ubÞ.ÔJ,h�XÆe…+Îg#ÝiwÿS/RÕYãó—Z¡“$‹¦él&Їµù¯MRXÎÆ‘TNά•Z{ã/ZÏ/ðäǨ\Á^©Ž?Z}g™·j3qc>u8šeã¨*Vb}×g¡JËJ�]þZ¤´>%�YZi/‹|µ„uFk‰Ca9ðãç ø\ÜF ¼ÐR� $”cä¯à\ç0c†žZZμ¾¤VÍA3ƒæ¹¶,òéj"È9MÙÊvcµô2¦™
[ ÅCy‘,—¨¥Ñ×ÑwœF8
rBãòu¾EÈ™/Fδ†}A§îûôÅOÝ’Dw²î\ˆyÿ%‘L5@I(d³ùc޵µE
Lº”A£Ó�°Òžž‰õ ¬¾:aåY6AaµMÛÍEM8%®P^móÇ€G5uDVM&«…Eƒµ
Xæá¸-&X¡ÐW³\9¼|qu£¤Ä}C�¹òqkÝ"ò»1*xàzREÓœDpÕušD9àÁ¼«Ìx��1Å¥qtT”à VsŒói@M{íñ¨{H’u -ÝåÖkªÕ?yhMŽÕ9í¸M#0›°Eÿð�¹÷H oÔ´Mk¢8ÊË ñÖïVž9G˜æöƒ¹ªr2Pveî(€
ŒBÒæÊäNgMí2ÔóT¯Ñ·>Ãêr’¤ò�E#ë½é-ld™n®Ó�xt—• 6àÆ”*G…¡� úÉ+~™L,išÉwߪ)Eµš0ð~S0Üfi.Zä|Ñ*ìçü˜bp$‘ƒÙ©YŽvš0}q5%j(ö¨ÿÓ=;-¶ÆÝ+ˆ j mcö›Õ¼Ý”ë ÷ÎV�ó�/ÀÀ£JòÍ9½Üåd!ßaö�Ü]WHUdkpã÷¶·8øû±7&Áëq‹TfAnÎÒ]v凴‰mÙo`fæƒ�ùEÙ™¡]ç³™œÛÝ
ÂketïÍíðÌÒ¦m£ÙB
‘k€‘Ú.¤´»�flŠŸÑ’Ýî>ÖgûÚdl�&î66¬ûÔ ÜÚ¾¡Ý"ÞÂ@Œâ6ò?ØÇÛÇŸÖ6¶ÎÊß•2††« LÝÈøÝ”¦ÓdydLÁøt¼3ÉçÓŠa³‘“Õ傯-#Tå&/’$ò|[�K‹ülµœ‹³ä’ô³
{HÜDB7?ôB@V_ij¥³sD¯y´\ß ž|ÜIÀ}4�¾Â!í´æÖvÒñ¢Œ_0Õ¶‰²Ã ïI¾ÂcèúvÙ/#wY%Eõó*›ÎŨ#ç6 Fv…^æ“dþ¦;_Ä“UQP iœÉƒñ&M€ç/þíèÿü~~ôòݳàF¿á`:£cCÃr(}¸¦â:0¶Ž]Ddç;ÑoIu/’�£ïÝÌ®ÍucÊqöä ú¾3Õø‡ëp‚ñfýM",£GÔ,~ûmô¿x!p'Qç݆¬‰|,ÿk
k,Aÿòa-硃f·Vç¤GÑÀ;j¶!.×±^©J�ìì’ iΨPQbj²k17Õ»(ÙÀ
Ö|†2¨JªÞõÍ%†SK–þäÇqôã!ff³J½Ð!œbÝŽ+©wÆN¿Ág�
`ÔÅz_q„=â£ããw¿½{ytvòê—ߟŸ¼}öô÷7G¯ž�ÚLÄ6€RšÐpæ£OON��Þ>õQí'ÊXUÒ·
’À´
˜Ôq]üÚr²i¥©Q9+~¥]�äµÍP@lâûY¨ÄŒõksÌÞyR€¼
M¤é3±Û+9ÑoOÐÒVJ»ÔmBKC#7@+àÑ)É¢‘WÔ>6qwñ¤ŽT;ü2Ä’-ã^ë±dþ©WÑ&Gƒ…XúÊæt‰‘Ê”(ŒÂkèáº+(Ç~fSÍïK]!†ïy,O„ý’X~¿aÃZeœ�WZDâ±æ¨Ú^¦Š$¨}¬¹²Š»aÉê*>³¶ÕWéÃ4^í•ÐVaÉõ�Âò27_0§|Æh
Vxåš‹É'|q¯+[åÅk±39Î8qõÔ=— dû¹bÝ„«œr¸Í«œW…4ù¼ŽðÜ5°=Pš5tÚRë{#”ñ\]^:áœÓ}¹ÒVä¾ûŽ=ÀÔ±¦CyÙêü¶_.4ÉÀeI?$¿€Ï£#÷ôVÑ“[_Õúb‡h�eï:r]¼q`u}î´ÞLŠiÇΟƔuï´5+í·¶wˆåÞh±.U{C5}kÜÕ/f§xVÝ‘ ákó¯jò>YÖýOÿYæÕ=Ëó°v"øçN‘Ü`4D ÒÉ:´LÅœœæÈß§ 5Ø$AbM;þo••ññëßÞ¼~õìÕÙïÏ^¿FËçÔuÛÑõjù¼TÍ[=ðbâ[ΛÓ�ô“ï`˪?ýÞ-h(YSl…@d“š¹×ç$Kšã§”ìÓrÉߘ—bPÈ]º(G¦ã»„íëuØ‘iŽÅ¤Àü[øXLãßi%€H®Ò`íþ:äÞÛ‹æBe#¥š*в™…Å!ÑÊ™¡z7Q ¥�Q•2%dúH°z•´‹|•Ñ1²Tz逃{* ?>ÏÙ.Ã%r/(ÜŽd¯M¤wµkP¶€—$^°xS¤á�ÿÜÌV iÞ‡k‹�ø½·²ïN”O!béÝܸ‘YAù*# aúqÕ @ÛBÖ[+ÒÕMü7‹ÛMš,#¥¼ƒÒp“Ú¾¬„ ¾¸Sˤ:ñ4§œãÈêO‹Ž-T±XB…ÃìÎnk× =÷tãeÜí6±�.4;æqß™'§�5S¦LÝ'š/S§mÇ�òm´ãàÓg67ZîѼÄKÏ[°å®C`wZêÀœS{ó˜ÑŠèN«b¿a†„‘�:·p„¤]ERrb9t´~}Ê;]´TàÏ\~ÄrsÖTHÓk‡û½Ê²‘ðAT!Üè\¾óŒI‰ž²$£’äKܵ�‡rØsy
œàgÕpk¦ìó�-Y‘ZxÃÀ;¤† ¿N·íaï¶»ÍÙ³:ëÙÕäösjw>ÿÉp㤜єÿÞk>¬.W˜5*of‰CX+�øQïKa}zÁP¤N~ì{ã'/O�ÓѾ¾éún4P¯²PÂÉ€œkqJYÉ\s› •Ãï‚â× Ýë”§ªx•¬ºªßvZíÏ5RÀ•ßr‰ðm§ÇI»ö_ìv˜™ŽÓRÙš¶µïç7XZøÖ¢/¨�ÛWèý¡ûWzêþY=U§LŸ©0r'RØ£^¤–n*Ÿ)Úfúàmß)‘‡Ýÿ´=OÁ#ÞÁ¥Qá5!ê©?Ž•´+Ä»
âȧ®{yG®Ä€õ¡Knô°Í§iE³ú)§²×Ûµ"lˆ%l*•šro*Žv6²ÙÞaSºÚ�[„Úî…5�j…!©a{zz…$±æh`„ƒ,+Rf•îî¦Þ_…€~¡‹%É„HÑõ§Î>ÌŸ§SSÞÁ?ʸ^5}6Ý 6úÿþ‰»¡Ölm¦tG(ögl\!,p“¢á3||á>„Ëï>y‰ l奌S¨Ylo¸@ÐXÄXš#XƒN5Ë5rj‚»ðãX
Á�œUÂAH³ÆŒ_Q|j@>ÇL†Bžf&ôiÀ�Ùd3Ø'F`ê+|ŸÂ#[îüº^ëÔÅ ¤æç¹ÕNƒþâqñH§Ñ´šžó×SÔ#@å/çûMœïðŠOÄ
ì>Ÿªõ¾x
iq§Â;]0\a¡£ñWt6°jóøìf‰Õäv*ÃBÝO§
wâžÚNšŠ®vmüª½Ó°µAWøüã9è_Žõ{ˆjgCvS9’ô�|
‹PýÖs,ô"gàÝ\AUŠ.S5-l¸ÈÖ6F@šÁi
±”ñßì…^! oWƒ¡YŒ!ý€GQÿìËHLEq&î¡eÕwÚ€)¡º¶�@e—w¥ÛìW=I¨]•$·òcד¡úU�„éôÓ°Ö¹$W5Õ”æ
i»æx«ï×#yšw´äY˰zaìÙ
æŸà~XÍì�~°�¬ÜNÕÔ0²8tÕ g˜ë@S�Ÿ5|>åÇÃ㣪¾º¶0¼4nOž¨Vô'¹œÁ+ôCØhÝÏ–úÜnUn¡›Çµg`÷=�”³ú¾>C6ÎÚŒ�ÆýPÒU¯,š,‰ïÌÕIð
ÛÌQ!S(USKÓE]}È(¹è™àámÕìÕ»„}Ã{n'“ºÛçŽ�yo‡}Õ’ôë¥_3íí¾ÐÎeat§�ˆºtNa?•ÕÞ‡FX4¶ºB'J °j•]úkLµ¶Îú¸Ò„–F
X›´`¹ô¬
‹ÜÕÜ@õå©a¼ßZƒÈz/æ"ÏãH¸ô|·aúþ&űèÛÍwUžŠ;¾xä®M..„Ž™—ªèÝ¨í¯ª×³ßÅÀØÀF¿«„G%hQtQ¤Xgý�§Ú™{ü;à‘TÑ-(!OåßÑ=ž5kkÎì}¨{žþÄõòWž÷