+
    JV-jå³  ã                   ó&  € ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	t	 ^ RI
t^ RIt^ RIHtHt  ^ RIHt ^ RIt ! R R4      t ! R R]4      t ! R	 R
]4      t ! R R]4      t]P4                  R 4       t]P4                  R 4       t]P4                  R 4       t]P4                  ! ]P<                  ! RRR7      ]P<                  ! RRR7      .R7      R 4       tR t R t!R t"]PF                  PI                  RR R .4      R 4       t%R t&]PF                  P(                  R 4       t'R  t(R! t)]PF                  P(                  ]PF                  PT                  R" 4       4       t+]PF                  P(                  R# 4       t,R$ t-]PF                  PI                  R%]P\                  P_                  4       ]P\                  P_                  R&R'7      .4      R( 4       t0R) t1]PF                  PI                  R%]P\                  P_                  4       ]P\                  P_                  R&R'7      .4      R* 4       t2R+ t3]PF                  P(                  R, 4       t4]PF                  P(                  R- 4       t5R. t6]PF                  Pn                  R/ 4       t8R0 t9]PF                  PI                  R%]P\                  Pu                  4       ]P\                  Pu                  R1R27      ]P\                  Pu                  R1R37      ]P\                  Pu                  ]P\                  Pv                  Px                  R47      ]P\                  Pu                  R1]P\                  Pv                  Px                  R57      .4      R6 4       t=R7 t>R8 t?R9 t@R: tAR; tB]PF                  P(                  R< 4       tC]P4                  R= 4       tDR> tER? tFR@ tGRA tH]PF                  P’                  RB 4       tJRC tKRD tLRE tM ! RF RG]Pœ                  4      tO ! RH RI]4      tP]P4                  RJ 4       tQ]PF                  P¤                  RK 4       tS]PF                  P¤                  RL 4       tT]PF                  P(                  RM 4       tU]PF                  P(                  RN 4       tV]PF                  P(                  ]PF                  PI                  RORPRQ.4      RR 4       4       tWRS tX]PF                  P(                  RT 4       tY]PF                  P(                  RqRU l4       tZ]PF                  P(                  RV 4       t[]PF                  P(                  RW 4       t\]PF                  P(                  RX 4       t]]PF                  P(                  RY 4       t^]PF                  P(                  RZ 4       t_]PF                  P(                  R[ 4       t`]PF                  P(                  R\ 4       taR] tbR^ tcR_ tdR` teRa tfRb tgRc thRd tiRe tjRf tkRg tl]P4                  Rh 4       tm]PF                  Pn                  ]PF                  PI                  RiRjRk.R1Rl7      Rm 4       4       tn]P4                  Rn 4       to]PF                  PI                  RoRjRk.R1Rl7      Rp 4       tpR#   ] d    Rt ELUi ; i  ] d     ELLi ; i)ré    )ÚUserListN)Úchanged_environÚinvoke_script)Úassert_frame_equalc                   óH   a € ] tR t^,t o RtR 3R ltR tR tRR ltRt	V t
R# )	Ú
IpcFixtureNc                 ó,   € \         P                  ! 4       # ©N©ÚioÚBytesIO© ó    Úg/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/pyarrow/tests/test_ipc.pyÚ<lambda>ÚIpcFixture.<lambda>/   s
   € ¬B¯JªJ¬Lr   c                ó<   € Wn         V P                  4       V n        R # r
   )Ú_sink_factoryÚget_sinkÚsink)ÚselfÚsink_factorys   &&r   Ú__init__ÚIpcFixture.__init__/   s   € Ø)ÔØ—M‘M“OˆŽ	r   c                ó"   € V P                  4       # r
   )r   ©r   s   &r   r   ÚIpcFixture.get_sink3   s   € Ø×!Ñ!Ó#Ð#r   c                ó6   € V P                   P                  4       # r
   )r   Úgetvaluer   s   &r   Ú
get_sourceÚIpcFixture.get_source6   s   € Ø�y‰y×!Ñ!Ó#Ð#r   c                ó’  € ^p\         P                  ! R\         P                  ! 4       3R\         P                  ! 4       3.4      pV P	                  V P
                  V4      p. p\        V4       F\  p\         P                  ! \        V4       Uu. uF  p\        P                  ! 4       NK  	  up. RO.VR7      p	VP                  V	4       K^  	  V'       d2   \         P                  P                  V4      p
VP                  V
4       MV F  p	VP                  V	4       K  	  VP                  V n        VP!                  4        V# u upi )é   ÚoneÚtwo©Úschema)ÚfooNÚbarÚbazbazÚqux)Úpar'   Úfloat64Úutf8Ú_get_writerr   ÚrangeÚrecord_batchÚrandomÚappendÚTableÚfrom_batchesÚwrite_tableÚwrite_batchÚstatsÚwrite_statsÚclose)r   Únum_batchesÚas_tableÚnrowsr'   ÚwriterÚbatchesÚiÚ_ÚbatchÚtables   &&&        r   Úwrite_batchesÚIpcFixture.write_batches9   sý   € ØˆÜ—’˜U¤B§J¢J£LÐ1°E¼2¿7º7»9Ð3EÐFÓGˆà×!Ñ! $§)¡)¨VÓ4ˆàˆÜ�{Ö#ˆAÜ—O’OÜ+0°¬<Ó8©< a”&—-’-–/©<Ñ8Ú6ð8àôˆEð �N‰N˜5Ö!ñ $÷ Ü—H‘H×)Ñ)¨'Ó2ˆEØ×Ñ˜uÕ%ã �Ø×"Ñ" 5Ö)ñ !ð "Ÿ<™<ˆÔØ�‰ŒØˆùò 9s   ÂE
)r   r   r9   )r#   F)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r9   r   r   r    rD   Ú__static_attributes__Ú__classdictcell__©Ú__classdict__s   @r   r   r   ,   s&   ø‡ € Ø€Ká$8ô $ò$ò$÷ò r   r   c                   ó8   a € ] tR t^St o RtRtR tRR ltRtV t	R# )ÚFileFormatFixtureTNc                óX   € \         P                  P                  WV P                  R 7      # ©©Úoptions)r,   ÚipcÚnew_filerS   ©r   r   r'   s   &&&r   r/   ÚFileFormatFixture._get_writerX   s   € Ü�v‰v�‰˜t°T·\±\ˆÓBÐBr   c                ó  € V P                  VR 7      p\        P                  ! V P                  4       4      p\        P                  P                  V4      pVP                  \        V4      8X  g   Q h\        V4       Fi  w  rVVP                  V4      pW%,          P                  V4      '       g   Q hVP                  P                  V^ ,          P                  4      '       d   Ki  Q h	  \        VP                  \        P                  P                  4      '       g   Q h\        V P                  \        P                  P                   4      '       g   Q h\#        VP                  4      \#        V P                  4      8X  g   Q hR# )©r<   N)rD   r,   ÚBufferReaderr    rT   Ú	open_fileÚnum_record_batchesÚlenÚ	enumerateÚ	get_batchÚequalsr'   Ú
isinstancer8   Ú	ReadStatsr9   Ú
WriteStatsÚtuple)r   r<   r?   Úfile_contentsÚreaderr@   rB   s   &&     r   Ú_check_roundtripÚ"FileFormatFixture._check_roundtrip[   s  € Ø×$Ñ$¨hÐ$Ó7ˆÜŸš¨¯©Ó(9Ó:ˆä—‘×!Ñ! -Ó0ˆà×(Ñ(¬C°«LÔ8Ð8Ð8ä! 'Ö*‰HˆAà×$Ñ$ QÓ'ˆEØ•:×$Ñ$ U×+Ò+Ð+Ð+Ø—=‘=×'Ñ'¨°­
×(9Ñ(9×:Ô:Ð:Ð:ñ	 +ô ˜&Ÿ,™,¬¯©×(8Ñ(8×9Ò9Ð9Ð9Ü˜$×*Ñ*¬B¯F©F×,=Ñ,=×>Ò>Ð>Ð>Ü�V—\‘\Ó"¤e¨D×,<Ñ,<Ó&=Ô=Ð=Ò=r   r   ©F)
rF   rG   rH   rI   Úis_filerS   r/   rg   rJ   rK   rL   s   @r   rO   rO   S   s   ø‡ € à€GØ€GòC÷>ò >r   rO   c                   ó2   a € ] tR t^nt o RtRtRtR tRtV t	R# )ÚStreamFormatFixtureFNc                óZ   € \         P                  P                  VVV P                  R 7      # rQ   )r,   rT   Ú
new_streamrS   rV   s   &&&r   r/   ÚStreamFormatFixture._get_writerv   s+   € Ü�v‰v× Ñ ØØØ—L‘Lð !ó 
ð 	
r   r   )
rF   rG   rH   rI   Úuse_legacy_ipc_formatrS   rj   r/   rJ   rK   rL   s   @r   rl   rl   n   s!   ø‡ € ð "Ðà€GØ€G÷
ð 
r   rl   c                   ó&   a € ] tR t^~t o R tRtV tR# )ÚMessageFixturec                ó.   € \         P                  ! W4      # r
   ©r,   ÚRecordBatchStreamWriterrV   s   &&&r   r/   ÚMessageFixture._get_writer€   ó   € Ü×)Ò)¨$Ó7Ð7r   r   N)rF   rG   rH   rI   r/   rJ   rK   rL   s   @r   rr   rr   ~   s   ø‡ € ÷8ð 8r   rr   c                  ó   € \        4       # r
   )r   r   r   r   Úipc_fixturery   „   s
   € ä‹<Ðr   c                  ó   € \        4       # r
   )rO   r   r   r   Úfile_fixturer{   ‰   s   € äÓÐr   c                  ó   € \        4       # r
   )rl   r   r   r   Ústream_fixturer}   Ž   ó   € äÓ Ð r   r{   zFile Format)Úidr}   zStream Format)Úparamsc                 ó8   € V P                  V P                  4      # r
   )ÚgetfixturevalueÚparam©Úrequests   &r   Úformat_fixturer†   “   s   € ð ×"Ñ" 7§=¡=Ó1Ð1r   c                  ó  € R p \         P                  ! \        P                  4      ;_uu_ 4        \        P                  P                  \        P                  ! V 4      4       RRR4       R#   + '       g   i     R# ; i©r   N)ÚpytestÚraisesr,   ÚArrowInvalidrT   r[   rZ   ©Úbufs    r   Útest_empty_filerŽ   ¡   sD   € Ø
€CÜ	�Š”r—‘×	'Õ	'Ü
�‰×ÑœŸš¨Ó-Ô.÷ 
(×	'×	'Ò	'ús   ¯4A-Á-A>	c                 ó*   € V P                  R R7       R# )FrY   N©rg   ©r{   s   &r   Útest_file_simple_roundtripr’   §   s   € Ø×!Ñ!¨5Ð!Ö1r   c                 ó*   € V P                  R R7       R# )TrY   Nr�   r‘   s   &r   Útest_file_write_tabler”   «   s   € Ø×!Ñ!¨4Ð!Ö0r   r   c                  ó,   € \         P                  ! 4       # r
   r   r   r   r   r   r   °   s
   € ŒB�JŠJŒLr   c                  ó,   € \         P                  ! 4       # r
   )r,   ÚBufferOutputStreamr   r   r   r   r   ±   s   € ŒB×!Ò!Ô#r   c                 óR  € \        V 4      pVP                  4       p\        P                  ! VP	                  4       4      p\        P
                  P                  V4      pVP                  4       p\        P                  P                  V4      pVP                  V4      '       g   Q hR # r
   )rO   rD   r,   rZ   r    rT   r[   Úread_allr4   r5   r`   )r   Úfixturer?   re   rf   ÚresultÚexpecteds   &      r   Útest_file_read_allr�   ¯   s|   € ô
   Ó-€Gà×#Ñ#Ó%€GÜ—O’O G×$6Ñ$6Ó$8Ó9€Mä�V‰V×Ñ˜mÓ,€Fà�_‰_Ó€FÜ�x‰x×$Ñ$ WÓ-€HØ�=‰=˜×"Ò"Ð"Ò"r   c                 óŠ  € V P                  4        V P                  4       p\        P                  P	                  V4      p\        P                  P	                  \        P
                  ! V4      4      p\        P                  ! V4      pVP                  4       pVP                  4       pVP                  4       pVP                  V4      '       g   Q hVP                  V4      '       g   Q hVP                  pVP                  ^8X  g   Q hVP                  ^8X  g   Q hVP                  V8X  g   Q hVP                  V8X  g   Q hR# ©é   N)rD   r    r,   rT   r[   rZ   ÚRecordBatchFileReaderr™   r`   r8   Únum_messagesr\   )	r{   ÚsourceÚreader1Úreader2Úreader3Úresult1Úresult2Úresult3Úst1s	   &        r   Útest_open_file_from_bufferr«   À   s  € à×ÑÔ Ø×$Ñ$Ó&€Fä�f‰f×Ñ˜vÓ&€GÜ�f‰f×ÑœrŸš¨vÓ6Ó7€GÜ×&Ò& vÓ.€Gà×ÑÓ €GØ×ÑÓ €GØ×ÑÓ €Gà�>‰>˜'×"Ò"Ð"Ð"Ø�>‰>˜'×"Ò"Ð"Ð"à
�-‰-€CØ×Ñ˜qÔ Ð Ð Ø×!Ñ! QÔ&Ð&Ð&Ø�=‰=˜CÔÐÐØ�=‰=˜CÔÐÒr   c                 óp  € V P                  4        Uu. uF  qP                  4       NK  	  pp\        P                  ! V P	                  4       4      p\        P
                  P                  V4      pVP                  4       p\        P                  ! V4      P                  R R7      p\        WV4       R# u upi ©T)ÚdropN)rD   Ú	to_pandasr,   rZ   r    rT   r[   Úread_pandasÚpdÚconcatÚreset_indexr   )r{   rB   Úframesre   rf   r›   rœ   s   &      r   Útest_file_read_pandasrµ   ×   s‰   € à-9×-GÑ-GÔ-IÓJÑ-I E�o‰oÖÑ-I€FÐJä—O’O L×$;Ñ$;Ó$=Ó>€MÜ�V‰V×Ñ˜mÓ,€FØ×ÑÓ!€Fä�yŠy˜Ó ×,Ñ,°$Ð,Ó7€HÜ�vÖ(ùò Ks   “B3c                 ó4  € V P                  4        V P                  4       pVP                  R 4      P                  p\	        VR4      ;_uu_ 4       pVP                  V4       RRR4       \        P                  P                  \        P                  ! V4      4      P                  4       p\        P                  P                  \        P                  ! V4      4      P                  4       pVP                  V4      '       g   Q hR#   + '       g   i     L­; i)ú
file.arrowÚwbN)rD   r    ÚjoinÚstrpathÚopenÚwriter,   rT   r[   ÚpathlibÚPathr™   ÚOSFiler`   )r{   Útmpdirr£   ÚpathÚfÚt1Út2s   &&     r   Útest_file_pathlibrÅ   ã   s·   € Ø×ÑÔ Ø×$Ñ$Ó&€Fà�;‰;�|Ó$×,Ñ,€DÜ	ˆd�D×	Ô	˜QØ	�‰�Œ÷ 
ô 
�‰×	Ñ	œ'Ÿ,š, tÓ,Ó	-×	6Ñ	6Ó	8€BÜ	�‰×	Ñ	œ"Ÿ)š) D›/Ó	*×	3Ñ	3Ó	5€Bà�9‰9�R�=Š=ÐŠ=÷ 
×	ús   ÁDÄD	c                  ó  € \         P                  ! R 4      p \        P                  ! \        P
                  4      ;_uu_ 4        \        P                  P                  V 4       RRR4       R#   + '       g   i     R# ; irˆ   )r   r   r‰   rŠ   r,   r‹   rT   Úopen_streamrŒ   s    r   Útest_empty_streamrÈ   ñ   sC   € Ü
�*Š*�S‹/€CÜ	�Š”r—‘×	'Õ	'Ü
�‰×Ñ˜3Ô÷ 
(×	'×	'Ò	'ús   Á A-Á-A>	c           	     óV  € \         P                  ! 4       p\         P                  ! \         P                  ! RV4      .4      pV P	                  R4      P
                  p\         P                  ! VR4      ;_uu_ 4       p\         P                  P                  WB4      ;_uu_ 4       p\         P                  ! R.VR7      p\         P                  ! V.V4      pVP                  V4       RRR4       RRR4       \        RV4       R#   + '       g   i     L&; i  + '       g   i     L1; i)z¿ARROW-15783: Verify to_pandas works for interval types.

Interval types require static structures to be enabled. This test verifies
that they are when no other library functions are invoked.
Únumsr·   r¸   ©ÚtypeNzread_record_batch.py©é   é   é   )r,   Úmonth_day_nano_intervalr'   Úfieldr¹   rº   r¿   rT   rU   Úarrayr1   r¼   r   )rÀ   Úmdn_interval_typer'   rÁ   r   r>   Úinterval_arrayrB   s   &       r   Ú"test_read_year_month_nano_intervalrÖ   ÷   sÇ   € ô ×2Ò2Ó4ÐÜ�YŠYœŸš Ð):Ó;Ð<Ó=€Fà�;‰;�|Ó$×,Ñ,€DÜ	�Š�4˜×	Ô	 $Ü�V‰V�_‰_˜T×*Ô*¨fÜŸXšX y kÐ8IÔJˆNÜ—O’O ^Ð$4°fÓ=ˆEØ�L‰L˜Ô÷ +÷ 
ô
 Ð(¨$Ö/÷	 +×*ú÷ 
×	ús%   Á<(DÂ$AD	Ã'DÄDÄDÄD(	c                 ó’  € \         P                  ! R \        P                  P	                  ^4      R\         P
                  ! R\        P                  RRR.RR.RR7      /4      p\        P                  P                  V4      pV P                  V P                  VP                  4      ;_uu_ 4       pVP                  V4       RRR4       \        P                  P                  \        P                   ! V P#                  4       4      4      P%                  4       p\'        VP)                  4       V4       R#   + '       g   i     L{; i)r$   r%   r(   r)   T©Ú
categoriesÚorderedN)r±   Ú	DataFrameÚnpr2   ÚrandnÚCategoricalÚnanr,   ÚRecordBatchÚfrom_pandasr/   r   r'   r7   rT   rÇ   rZ   r    r™   r   r¯   )r}   ÚdfrB   ÚwrrC   s   &    r   Ú!test_stream_categorical_roundtriprä     sä   € ä	�ŠØŒr�y‰y�‰˜qÓ!ØŒr�~Š~˜u¤b§f¡f¨e°U¸EÐBØ*/°¨Ø&*ô,ðó 
€Bô �N‰N×&Ñ& rÓ*€EØ	×	#Ñ	# N×$7Ñ$7¸¿¹×	FÔ	FÈ"Ø
�‰�uÔ÷ 
Gô �V‰V×Ñ¤§¢°×0IÑ0IÓ0KÓ LÓMß‰h‹jð 
ä�u—‘Ó(¨"Ö-÷ 
G×	Fús   Â1D6Ä6E	c                 óÔ  € V P                  4        V P                  4       p\        P                  P	                  V4      p\        P                  P	                  \        P
                  ! V4      4      p\        P                  ! V4      pVP                  4       pVP                  4       pVP                  4       pVP                  V4      '       g   Q hVP                  V4      '       g   Q hVP                  pVP                  ^8X  g   Q hVP                  ^8X  g   Q hVP                  V8X  g   Q hVP                  V8X  g   Q h\        V4      \        V P                  4      8X  g   Q hR# rŸ   )rD   r    r,   rT   rÇ   rZ   ÚRecordBatchStreamReaderr™   r`   r8   r¢   r\   rd   r9   )	r}   r£   r¤   r¥   r¦   r§   r¨   r©   rª   s	   &        r   Útest_open_stream_from_bufferrç     s#  € à× Ñ Ô"Ø×&Ñ&Ó(€Fä�f‰f× Ñ  Ó(€GÜ�f‰f× Ñ ¤§¢°Ó!8Ó9€GÜ×(Ò(¨Ó0€Gà×ÑÓ €GØ×ÑÓ €GØ×ÑÓ €Gà�>‰>˜'×"Ò"Ð"Ð"Ø�>‰>˜'×"Ò"Ð"Ð"à
�-‰-€CØ×Ñ˜qÔ Ð Ð Ø×!Ñ! QÔ&Ð&Ð&Ø�=‰=˜CÔÐÐØ�=‰=˜CÔÐÐä�‹:œ˜~×9Ñ9Ó:Ô:Ð:Ò:r   rS   F©Úuse_threadsc                 óT  € V P                  4        V P                  4       p\        P                  P	                  W!R 7      pVP                  4        VP                  pVP                  ^8X  g   Q hVP                  ^8X  g   Q h\        V4      \        V P                  4      8X  g   Q hR# ©rR   N)rD   r    r,   rT   rÇ   r™   r8   r¢   r\   rd   r9   )r}   rS   r£   rf   Ústs   &&   r   Útest_open_stream_optionsrí   5  s‹   € ð
 × Ñ Ô"Ø×&Ñ&Ó(€Fä�V‰V×Ñ ÐÓ8€Fà
‡O�OÔØ	�‰€BØ�?‰?˜aÔÐÐØ× Ñ  AÔ%Ð%Ð%ä�‹9œ˜n×8Ñ8Ó9Ô9Ð9Ò9r   c                 ó  € V P                  4        V P                  4       p\        P                  ! \        4      ;_uu_ 4        \
        P                  P                  VR R7       RRR4       R#   + '       g   i     R# ; i©TrR   N)rD   r    r‰   rŠ   Ú	TypeErrorr,   rT   rÇ   )r}   r£   s   & r   Ú#test_open_stream_with_wrong_optionsrñ   G  sQ   € Ø× Ñ Ô"Ø×&Ñ&Ó(€Fä	�Š”y×	!Õ	!Ü
�‰×Ñ˜6¨4ÐÔ0÷ 
"×	!×	!Ò	!úó   Á"A/Á/B 	c                 ó
  € V P                  4        V P                  4       p\        P                  P	                  W!R 7      pVP                  4        VP                  pVP                  ^8X  g   Q hVP                  ^8X  g   Q hR# rë   )	rD   r    r,   rT   r[   r™   r8   r¢   r\   )r{   rS   r£   rf   rì   s   &&   r   Útest_open_file_optionsrô   O  sn   € ð
 ×ÑÔ Ø×$Ñ$Ó&€Fä�V‰V×Ñ˜fÐÓ6€Fà
‡O�OÔà	�‰€BØ�?‰?˜aÔÐÐØ× Ñ  AÔ%Ð%Ò%r   c                 ó  € V P                  4        V P                  4       p\        P                  ! \        4      ;_uu_ 4        \
        P                  P                  VR R7       RRR4       R#   + '       g   i     R# ; irï   )rD   r    r‰   rŠ   rð   r,   rT   r[   )r{   r£   s   & r   Ú!test_open_file_with_wrong_optionsrö   `  sQ   € Ø×ÑÔ Ø×$Ñ$Ó&€Fä	�Š”y×	!Õ	!Ü
�‰×Ñ˜¨ÐÔ.÷ 
"×	!×	!Ò	!úrò   c                 ó(  € \         P                  ! R \        P                  P	                  ^4      R\         P
                  ! R\        P                  RRR.RR.RR7      /4      p\        P                  P                  VRR7      p\        P                  P                  VRR7      pV P                  V P                  VP                  4      ;_uu_ 4       pVP                  V4       VP                  V4       RRR4       \        P                  P!                  \        P"                  ! V P%                  4       4      4      P'                  4       p\)        VP+                  4       \         P,                  ! W.RR	7      4       R#   + '       g   i     L’; i)
r$   r%   r(   r)   TrØ   F©Úpreserve_indexN©Úignore_index)r±   rÛ   rÜ   r2   rÝ   rÞ   rß   r,   r4   rá   rà   r/   r   r'   r¼   rT   rÇ   rZ   r    r™   r   r¯   r²   )r}   râ   rC   rB   rã   s   &    r   Útest_stream_write_dispatchrü   h  s  € ô 
�ŠØŒr�y‰y�‰˜qÓ!ØŒr�~Š~˜u¤b§f¡f¨e°U¸EÐBØ*/°¨Ø&*ô,ðó 
€Bô �H‰H× Ñ  °EÐ Ó:€EÜ�N‰N×&Ñ& r¸%Ð&Ó@€EØ	×	#Ñ	# N×$7Ñ$7¸¿¹×	FÔ	FÈ"Ø
�‰�ŒØ
�‰�Œ÷ 
Gô �V‰V×Ñ¤§¢°×0IÑ0IÓ0KÓ LÓMß‰h‹jð 
ä�u—‘Ó(Ü—y’y " ¸Ô=ö?÷ 
G×	Fús   Ã#FÆF	c           	      ól  € \         P                  ! R \        P                  P	                  ^4      /4      p\
        P                  P                  VR,          RR7      p\
        P                  P                  VRR7      p\
        P                  P                  W#V.4      pV P                  V P                  VP                  4      ;_uu_ 4       pVP                  V^R7       RRR4       \        \
        P                  P!                  V P#                  4       4      4      p\        \%        \&        V4      4      . RO8X  g   Q h\
        P                  P                  V4      p\)        VP+                  4       \         P,                  ! VR,          WR,          .RR7      4       R#   + '       g   i     LÉ; i)	r$   :Né
   NFrø   )Úmax_chunksizeNTrú   )rþ   é   r#   rþ   )r±   rÛ   rÜ   r2   rÝ   r,   rà   rá   r4   r5   r/   r   r'   r6   ÚlistrT   rÇ   r    Úmapr]   r   r¯   r²   )r}   râ   Úb1Úb2rC   rã   r?   Úresult_tables   &       r   Útest_stream_write_table_batchesr  }  s;  € ô 
�ŠØŒr�y‰y�‰˜rÓ"ðó 
€Bô 
�‰×	#Ñ	# B s¥G¸EÐ	#Ó	B€BÜ	�‰×	#Ñ	# B°uÐ	#Ó	=€Bä�H‰H×!Ñ! 2¨2 ,Ó/€Eà	×	#Ñ	# N×$7Ñ$7¸¿¹×	FÔ	FÈ"Ø
�‰�u¨BˆÔ/÷ 
Gô ”2—6‘6×%Ñ% n×&?Ñ&?Ó&AÓBÓC€Gä””C˜Ó!Ó"¢oÔ5Ð5Ð5Ü—8‘8×(Ñ(¨Ó1€LÜ�|×-Ñ-Ó/Ü—y’y " S¥'¨2°#­wÐ!7Ø.2ô4ö5÷ 
G×	Fús   ÃF#Æ#F3	c                 óR  € V P                  4       p\        P                  ! V P                  4       4      p\        P                  P                  V4      pVP                  P                  V^ ,          P                  4      '       g   Q h^ p\        V4       F-  w  rVVP                  W,          4      '       g   Q hV^,          pK/  	  V\        V4      8X  g   Q h\        P                  ! \        4      ;_uu_ 4        VP                  4        RRR4       R#   + '       g   i     R# ; i©r   N)rD   r,   rZ   r    rT   rÇ   r'   r`   r^   r]   r‰   rŠ   ÚStopIterationÚread_next_batch)r}   r?   re   rf   Útotalr@   Ú
next_batchs   &      r   Útest_stream_simple_roundtripr  •  sÖ   € Ø×*Ñ*Ó,€GÜ—O’O N×$=Ñ$=Ó$?Ó@€MÜ�V‰V×Ñ Ó.€Fà�=‰=×Ñ ¨¥
× 1Ñ 1×2Ò2Ð2Ð2à€EÜ" 6Ö*‰ˆØ× Ñ  ¥×,Ò,Ð,Ð,Ø��
Šñ +ð ”C˜“LÔ Ð Ð ä	�Š”}×	%Õ	%Ø×ÑÔ ÷ 
&×	%×	%Ò	%ús   Ã:DÄD&	c                  ór  € \         P                  ! 4       p \        R 4       Uu. uF  p\        P                  ! ^ ^4      NK  	  pp\
        P                  P                  V.R.R7      p\
        P                  P                  RR7      p\
        P                  P                  WP                  VR7      ;_uu_ 4       pVP                  V4       RRR4       \        V P                  4       4      p\         P                  ! 4       p\
        P                  ! R^R7      p\
        P                  P                  VR7      p\
        P                  P                  WsP                  VR7      ;_uu_ 4       pVP                  V4       RRR4       \        VP                  4       4      p	W–8w  g   Q h\
        P                  P!                  V 4      P#                  4       p
\
        P                  P!                  V4      P#                  4       pW«8X  g   Q hR# u upi   + '       g   i     ELN; i  + '       g   i     L®; i)i'  Úvalues©ÚnamesÚzstd©ÚcompressionrR   N)Úcompression_level)r   r   r0   r2   Úrandintr,   r4   Úfrom_arraysrT   ÚIpcWriteOptionsÚRecordBatchFileWriterr'   r6   r]   r   ÚCodecr[   r™   )r   rA   r  rC   rS   r>   Úlen1Úsink2ÚcodecÚlen2rÃ   rÄ   s               r   Útest_compression_roundtripr  §  s   € ä�:Š:‹<€DÜ,1°%¬LÓ9©L qŒf�nŠn˜Q Ö"©L€FÐ9Ü�H‰H× Ñ  & °(°Ð Ó<€Eä�f‰f×$Ñ$°Ð$Ó8€GÜ	�‰×	%Ñ	%Ø—,‘,¨ð 
&÷ 
1ô 
1Ø4:Ø×Ñ˜5Ô!÷
1ô ˆt�}‰}‹Ó€Dä�JŠJ‹L€EÜ�HŠH�V¨qÔ1€EÜ�f‰f×$Ñ$°Ð$Ó7€GÜ	�‰×	%Ñ	%Ø—<‘<¨ð 
&÷ 
2ô 
2Ø5;Ø×Ñ˜5Ô!÷
2ô ˆu�~‰~ÓÓ €Dð
 Œ<Ðˆ<ä	�‰×	Ñ	˜$Ó	×	(Ñ	(Ó	*€BÜ	�‰×	Ñ	˜%Ó	 ×	)Ñ	)Ó	+€BàŒ8€OŠ8ùò3 :÷
1÷ 
1ð 
1ú÷
2÷ 
2ús   £ HÂ;HÅ.H&ÈH#	È&H6	c                  ó¦  € \         P                  P                  4       p V P                  R J g   Q hV P                  R J g   Q hV P
                  \         P                  P                  P                  8X  g   Q hRV n        V P                  RJ g   Q hRV n        V P                  RJ g   Q h\         P                  P                  P                  V n        V P
                  \         P                  P                  P                  8X  g   Q hR F:  p\        P                  ! \        \        34      ;_uu_ 4        Wn        RRR4       K<  	  V P                  e   Q hR Fk  p\         P                  P                  V4      '       g   K*  Wn        V P                  V8X  g   Q hVP!                  4       V n        V P                  V8X  d   Kk  Q h	  RV n        V P                  e   Q h\        P                  ! \        4      ;_uu_ 4        ^ V n        RRR4       V P"                  RJ g   Q hR V n        V P"                  R J g   Q h\         P                  P                  R4      '       dÇ   \         P                  P                  \         P                  P                  P                  RRRR R7      p V P
                  \         P                  P                  P                  8X  g   Q hV P                  RJ g   Q hV P                  RJ g   Q hV P                  R8X  g   Q hV P"                  R J g   Q hR# R#   + '       g   i     EK2  ; i  + '       g   i     EL>; i)FTNÚlz4)Úmetadata_versionÚallow_64bitÚuse_legacy_formatr  ré   )ÚV5é*   )r!  r  )r,   rT   r  r#  r$  r"  ÚMetadataVersionr%  ÚV4r‰   rŠ   rð   Ú
ValueErrorr  r  Úis_availableÚupperré   )rS   Úvalues     r   Útest_write_optionsr-  Æ  s¹  € Ü�f‰f×$Ñ$Ó&€GØ×Ñ %Ó'Ð'Ð'Ø×$Ñ$¨Ó-Ð-Ð-Ø×#Ñ#¤r§v¡v×'=Ñ'=×'@Ñ'@Ô@Ð@Ð@à€GÔØ×Ñ $Ó&Ð&Ð&à $€GÔØ×$Ñ$¨Ó,Ð,Ð,ä!Ÿv™v×5Ñ5×8Ñ8€GÔØ×#Ñ#¤r§v¡v×'=Ñ'=×'@Ñ'@Ô@Ð@Ð@ÛˆÜ�]Š]œI¤zÐ2×3Õ3Ø',Ô$÷ 4Ñ3ñ ð ×ÑÒ&Ð&Ð&Û ˆÜ�8‰8× Ñ  ×'Ô'Ø"'ÔØ×&Ñ&¨%Ô/Ð/Ð/Ø"'§+¡+£-ˆGÔØ×&Ñ&¨%Ö/Ð/Ð/ñ !ð €GÔØ×ÑÒ&Ð&Ð&ä	�Š”y×	!Õ	!ØˆÔ÷ 
"ð ×Ñ $Ó&Ð&Ð&Ø€GÔØ×Ñ %Ó'Ð'Ð'ä	‡x�x×Ñ˜U×#Ò#Ü—&‘&×(Ñ(ÜŸV™V×3Ñ3×6Ñ6ØØ"ØØð )ó ˆð ×'Ñ'¬2¯6©6×+AÑ+A×+DÑ+DÔDÐDÐDØ×"Ñ" dÓ*Ð*Ð*Ø×(Ñ(¨DÓ0Ð0Ð0Ø×"Ñ" eÔ+Ð+Ð+Ø×"Ñ" eÓ+Ð+Ò+ñ $÷) 4×3Ñ3ú÷ 
"×	!Ð	!ús   Ä5L*ÈL?Ì*L<Ì?M	T)r#  )r$  )r"  )r$  r"  c                 óò  € Wn         V P                  4       p\        P                  ! V P	                  4       4      p\        P
                  P                  V P	                  4       4      pVP                  VP                  8X  g   Q h\        P
                  P                  V4      pVP                  P                  V^ ,          P                  4      '       g   Q h^ p\        V4       F-  w  rxVP                  W',          4      '       g   Q hV^,          pK/  	  V\        V4      8X  g   Q h\        P                  ! \        4      ;_uu_ 4        VP!                  4        RRR4       R#   + '       g   i     R# ; ir  )rS   rD   r,   rZ   r    rT   Úread_messager"  rÇ   r'   r`   r^   r]   r‰   rŠ   r	  r
  )	r}   rS   r?   re   Úmessagerf   r  r@   r  s	   &&       r   Útest_stream_options_roundtripr1  ÷  s  € ð %ÔØ×*Ñ*Ó,€GÜ—O’O N×$=Ñ$=Ó$?Ó@€Mä�f‰f×!Ñ! .×";Ñ";Ó"=Ó>€GØ×#Ñ# w×'?Ñ'?Ô?Ð?Ð?ä�V‰V×Ñ Ó.€Fà�=‰=×Ñ ¨¥
× 1Ñ 1×2Ò2Ð2Ð2à€EÜ" 6Ö*‰ˆØ× Ñ  ¥×,Ò,Ð,Ð,Ø��
Šñ +ð ”C˜“LÔ Ð Ð ä	�Š”}×	%Õ	%Ø×ÑÔ ÷ 
&×	%×	%Ò	%ús   Å
E%Å%E6	c                  ó"  € \         P                  P                  4       p V P                  R J g   Q hV P                  R J g   Q hV P
                  \         P                  P                  P                  8X  g   Q hV P                  . 8X  g   Q hRV n        V P                  RJ g   Q h\         P                  P                  P                  V n        V P
                  \         P                  P                  P                  8X  g   Q h\         P                  P                  P                  V n        V P
                  \         P                  P                  P                  8X  g   Q hRV n        V P                  RJ g   Q h^ ^.V n        V P                  ^ ^.8X  g   Q h\        P                  ! \        4      ;_uu_ 4        RV n        RRR4       \         P                  P                  RR\         P                  P                  P                  ^.R7      p V P                  RJ g   Q hV P                  RJ g   Q hV P
                  \         P                  P                  P                  8X  g   Q hV P                  ^.8X  g   Q hR#   + '       g   i     LÅ; i)TFN)ré   Úensure_native_endianÚensure_alignmentÚincluded_fields)r,   rT   ÚIpcReadOptionsré   r3  r4  Ú	AlignmentÚAnyr5  ÚDataTypeSpecificÚAt64Byter‰   rŠ   rð   rR   s    r   Útest_read_optionsr;    s  € Ü�f‰f×#Ñ#Ó%€GØ×Ñ $Ó&Ð&Ð&Ø×'Ñ'¨4Ó/Ð/Ð/Ø×#Ñ#¤r§v¡v×'7Ñ'7×';Ñ';Ô;Ð;Ð;Ø×"Ñ" bÔ(Ð(Ð(à#(€GÔ Ø×'Ñ'¨5Ó0Ð0Ð0ä!Ÿv™v×/Ñ/×@Ñ@€GÔØ×#Ñ#¤r§v¡v×'7Ñ'7×'HÑ'HÔHÐHÐHÜ!Ÿv™v×/Ñ/×8Ñ8€GÔØ×#Ñ#¤r§v¡v×'7Ñ'7×'@Ñ'@Ô@Ð@Ð@à€GÔØ×Ñ %Ó'Ð'Ð'à  !˜f€GÔØ×"Ñ" q¨! fÔ,Ð,Ð,ä	�Š”y×	!Õ	!Ø"&ˆÔ÷ 
"ô �f‰f×#Ñ#Ø°ÜŸ™×)Ñ)×:Ñ:ÈQÈCð $ó €Gð ×Ñ %Ó'Ð'Ð'Ø×'Ñ'¨5Ó0Ð0Ð0Ø×#Ñ#¤r§v¡v×'7Ñ'7×'HÑ'HÔHÐHÐHØ×"Ñ" q cÔ)Ð)Ò)÷ 
"×	!ús   Æ9I>É>J	c                 óÄ  € \         P                  P                  4       p\         P                  P                  ^.R7      p\         P                  P	                  \         P
                  ! . RO4      \         P
                  ! . R	O4      .RR.R7      pV P                  V P                  VP                  4      ;_uu_ 4       pVP                  V4       RRR4       V P                  4       p\         P                  P                  WQR7      p\         P                  P                  WR\         P                  ! 4       R7      pVP                  4       pVP                  4       p	VP                  ^8X  g   Q hV	P                  ^8X  g   Q h\         P                  P	                  \         P
                  ! . R	O4      .R.R7      p
Wš8X  g   Q hWƒ8X  g   Q hR#   + '       g   i     EL; i)
rÎ   )r5  ÚaÚbr  NrR   )rS   Úmemory_pool©r(   r)   Úbazr+   ©rÎ   rÏ   rÐ   é   )r,   rT   r6  r4   r  rÓ   r/   r   r'   r6   r    rÇ   Úsystem_memory_poolr™   Únum_columns)r}   Úoptions1Úoptions2rC   rã   r£   r¤   r¥   r§   r¨   rœ   s   &          r   Ú!test_read_options_included_fieldsrH  8  s|  € Ü�v‰v×$Ñ$Ó&€HÜ�v‰v×$Ñ$°a°SÐ$Ó9€HÜ�H‰H× Ñ ¤"§(¢(Ò+GÓ"HÜ!#§¢ª,Ó!7ð"9à(+¨S zð !ó 3€Eð 
×	#Ñ	# N×$7Ñ$7¸¿¹×	FÔ	FÈ"Ø
�‰�uÔ÷ 
Gà×&Ñ&Ó(€Fä�f‰f× Ñ  Ð Ó:€GÜ�f‰f× Ñ Ø¬b×.CÒ.CÓ.Eð !ó G€Gð ×ÑÓ €GØ×ÑÓ €Gà×Ñ !Ô#Ð#Ð#Ø×Ñ !Ô#Ð#Ð#ä�x‰x×#Ñ#¤R§X¢XªlÓ%;Ð$<ÀSÀEÐ#ÓJ€HØÔÐÐØÔÐÒ÷! 
G×	FÐ	Fús   Â?GÇG	c           
      óš  a a€ \         P                  ! \         P                  ! 4       \         P                  ! 4       4      p. RO. ROR R.. RORR..pV Uu. uF;  p\         P                  P                  \         P                  ! W1R7      .R.R7      NK=  	  ppVR,          pV^ ,          P                  oRV V3R llpS P                  '       d|   \        P                  ! \         P                  4      ;_uu_ 4        V! V4       RRR4       \        P                  ! \         P                  4      ;_uu_ 4        V! V4       RRR4       MTV! V4      pVP                  ^8X  g   Q hVP                  ^8X  g   Q hVP                  ^8X  g   Q hVP                  ^ 8X  g   Q hRS n        \         P"                  P%                  R	R
7      S n        S P                  '       d?   \        P                  ! \         P                  4      ;_uu_ 4        V! V4       RRR4       MTV! V4      pVP                  ^8X  g   Q hVP                  ^8X  g   Q hVP                  ^8X  g   Q hVP                  ^8X  g   Q hV! V4      pVP                  ^8X  g   Q hVP                  ^8X  g   Q hVP                  ^ 8X  g   Q hVP                  ^8X  g   Q h\         P"                  P%                  R	R7      S n        V! VR	R7      pVP                  ^8X  g   Q hS P                  '       d<   VP                  ^8X  g   Q hVP                  ^ 8X  g   Q hVP                  ^ 8X  g   Q hR# VP                  ^8X  g   Q hVP                  ^8X  g   Q hVP                  ^ 8X  g   Q hR# u upi   + '       g   i     EL–; i  + '       g   i     EL; i  + '       g   i     EL\; i)r(   Nr)   ÚquuxrË   Údictsr  :NrC  Nc                 óZ  <€ SP                  \        P                  ! 4       S4      ;_uu_ 4       pV'       d2   \        P                  P	                  V 4      pVP                  V4       MV  F  pVP                  V4       K  	  VP                  uuR R R 4       #   + '       g   i     R # ; ir
   )r/   r,   ÚMockOutputStreamr4   r5   r6   r7   r8   )r?   r<   r>   rC   rB   r†   r'   s   &&   €€r   rD   Ú,test_dictionary_delta.<locals>.write_batches_  s€   ø€ Ø×'Ñ'¬×(;Ò(;Ó(=Ø(.÷0ô 0Ø39ßÜŸ™×-Ñ-¨gÓ6�Ø×"Ñ" 5Õ)ã$�EØ×&Ñ& uÖ-ñ %à—<‘<÷0÷ 0÷ 0ó 0ús   ¯ABÂB*	T)Úemit_dictionary_deltas)Úunify_dictionariesrY   )r(   r(   N)r(   r)   r(   )r(   Nr)   rJ  ri   )r,   Ú
dictionaryÚint8r.   rà   r  rÓ   r'   rj   r‰   rŠ   r‹   r\   Únum_dictionary_batchesÚnum_replaced_dictionariesÚnum_dictionary_deltasrp   rT   r  rS   )	r†   ÚtyÚdataÚvr?   Úbatches_delta_onlyrD   rì   r'   s	   f       @r   Útest_dictionary_deltarZ  Q  sR  ù€ Ü	�Š”r—w’w“y¤"§'¢'£)Ó	,€BÚ Ú!Ø�EˆNÚ(Ø�FˆOð	€Dñ óáˆAô 	�‰×"Ñ"¤B§H¢H¨QÔ$8Ð#9À'ÀÐ"ÖKÙð ð ð ! �ÐØ�Q�Z×Ñ€F÷	 ð 	 ð ××Ðä�]Š]œ2Ÿ?™?×+Õ+Ù˜'Ô"÷ ,ô �]Š]œ2Ÿ?™?×+Õ+ÙÐ,Ô-÷ ,Ð+ñ ˜7Ó#ˆØ×$Ñ$¨Ô)Ð)Ð)Ø×(Ñ(¨AÔ-Ð-Ð-Ø×+Ñ+¨qÔ0Ð0Ð0Ø×'Ñ'¨1Ô,Ð,Ð,à+/€NÔ(ÜŸV™V×3Ñ3Ø#ð 4ó %€NÔà××Ðä�]Š]œ2Ÿ?™?×+Õ+Ù˜'Ô"÷ ,Ð+ñ ˜7Ó#ˆØ×$Ñ$¨Ô)Ð)Ð)Ø×(Ñ(¨AÔ-Ð-Ð-Ø×+Ñ+¨qÔ0Ð0Ð0Ø×'Ñ'¨1Ô,Ð,Ð,á	Ð)Ó	*€BØ× Ñ  AÔ%Ð%Ð%Ø×$Ñ$¨Ô)Ð)Ð)Ø×'Ñ'¨1Ô,Ð,Ð,Ø×#Ñ# qÔ(Ð(Ð(äŸV™V×3Ñ3Øð 4ó €NÔñ 
�w¨Ô	.€BØ× Ñ  AÔ%Ð%Ð%Ø××ÐØ×(Ñ(¨AÔ-Ð-Ð-Ø×+Ñ+¨qÔ0Ð0Ð0Ø×'Ñ'¨1Ô,Ð,Ò,à×(Ñ(¨AÔ-Ð-Ð-Ø×+Ñ+¨qÔ0Ð0Ð0Ø×'Ñ'¨1Ô,Ð,Ò,ùòA÷& ,×+Ð+ú÷ ,×+Ð+ú÷ ,×+Ð+ús+   ÁANÃ;	NÄ8	N%È	N9ÎN"	Î%N6	Î9O
	c            	      óÐ	  € \         P                  ! \         P                  ! R \         P                  ! 4       4      .4      p \         P                  P                  \         P                  ! 4       V 4      pVP                  '       d   Q hVP                  \         P                  P                  P                  8X  g   Q h\         P                  P                  \         P                  ! 4       V 4      pVP                  '       d   Q hVP                  \         P                  P                  P                  8X  g   Q h\        RR4      ;_uu_ 4        \         P                  P                  \         P                  ! 4       V 4      pVP                  '       g   Q hVP                  \         P                  P                  P                  8X  g   Q h\         P                  P                  \         P                  ! 4       V 4      pVP                  '       g   Q hVP                  \         P                  P                  P                  8X  g   Q h RRR4       \        RR4      ;_uu_ 4        \         P                  P                  \         P                  ! 4       V 4      pVP                  '       d   Q hVP                  \         P                  P                  P                  8X  g   Q h\         P                  P                  \         P                  ! 4       V 4      pVP                  '       d   Q hVP                  \         P                  P                  P                  8X  g   Q h RRR4       \        RR4      ;_uu_ 4        \        RR4      ;_uu_ 4        \         P                  P                  \         P                  ! 4       V 4      pVP                  '       g   Q hVP                  \         P                  P                  P                  8X  g   Q h\         P                  P                  \         P                  ! 4       V 4      pVP                  '       g   Q hVP                  \         P                  P                  P                  8X  g   Q h RRR4       RRR4       R#   + '       g   i     EL\; i  + '       g   i     ELZ; i  + '       g   i     LB; i  + '       g   i     R# ; i)r(   ÚARROW_PRE_0_15_IPC_FORMATÚ1NÚARROW_PRE_1_0_METADATA_VERSION)r,   r'   rÒ   Úint32rT   rn   r—   Ú_use_legacy_formatÚ_metadata_versionr'  r%  rU   r   r(  )r'   r>   s     r   Ú!test_envvar_set_legacy_ipc_formatrb  œ  sH  € Ü�YŠYœŸš ¬¯ª«
Ó3Ð4Ó5€Fä�V‰V×Ñœr×4Ò4Ó6¸Ó?€FØ×(×(Ð(Ð(Ð(Ø×#Ñ#¤r§v¡v×'=Ñ'=×'@Ñ'@Ô@Ð@Ð@Ü�V‰V�_‰_œR×2Ò2Ó4°fÓ=€FØ×(×(Ð(Ð(Ð(Ø×#Ñ#¤r§v¡v×'=Ñ'=×'@Ñ'@Ô@Ð@Ð@ä	Ð4°c×	:Õ	:Ü—‘×"Ñ"¤2×#8Ò#8Ó#:¸FÓCˆØ×(×(Ð(Ð(Ð(Ø×'Ñ'¬2¯6©6×+AÑ+A×+DÑ+DÔDÐDÐDÜ—‘—‘¤×!6Ò!6Ó!8¸&ÓAˆØ×(×(Ð(Ð(Ð(Ø×'Ñ'¬2¯6©6×+AÑ+A×+DÑ+DÔDÐDÑD÷ 
;ô 
Ð9¸3×	?Õ	?Ü—‘×"Ñ"¤2×#8Ò#8Ó#:¸FÓCˆØ×,×,Ð,Ð,Ð,Ø×'Ñ'¬2¯6©6×+AÑ+A×+DÑ+DÔDÐDÐDÜ—‘—‘¤×!6Ò!6Ó!8¸&ÓAˆØ×,×,Ð,Ð,Ð,Ø×'Ñ'¬2¯6©6×+AÑ+A×+DÑ+DÔDÐDÑD÷ 
@ô 
Ð9¸3×	?Õ	?ÜÐ8¸#×>Õ>Ü—V‘V×&Ñ&¤r×'<Ò'<Ó'>ÀÓGˆFØ×,×,Ð,Ð,Ð,Ø×+Ñ+¬r¯v©v×/EÑ/E×/HÑ/HÔHÐHÐHÜ—V‘V—_‘_¤R×%:Ò%:Ó%<¸fÓEˆFØ×,×,Ð,Ð,Ð,Ø×+Ñ+¬r¯v©v×/EÑ/E×/HÑ/HÔHÐHÑH÷ ?÷ 
@Ñ	?÷! 
;×	:Ð	:ú÷ 
@×	?Ð	?ú÷ ?×>ú÷ 
@×	?Ð	?úsQ   ÅCRÈ7RÉ"CR-Ì$7R-Í8SÎCS	Ñ7S	ÒSÒR*	Ò-R>	ÓSÓSÓS%	c                 ó<  € V P                  4       p\        P                  ! V P                  4       4      p\        P                  P                  V4      pVP                  4       p\        P                  P                  V4      pVP                  V4      '       g   Q hR # r
   )
rD   r,   rZ   r    rT   rÇ   r™   r4   r5   r`   )r}   r?   re   rf   r›   rœ   s   &     r   Útest_stream_read_allrd  À  sp   € Ø×*Ñ*Ó,€GÜ—O’O N×$=Ñ$=Ó$?Ó@€MÜ�V‰V×Ñ Ó.€Fà�_‰_Ó€FÜ�x‰x×$Ñ$ WÓ-€HØ�=‰=˜×"Ò"Ð"Ò"r   c                 óH  € V P                  4        Uu. uF  qP                  4       NK  	  ppV P                  4       p\        P                  P                  V4      pVP                  4       p\        P                  ! V4      P                  R R7      p\        WV4       R# u upi r­   )rD   r¯   r    r,   rT   rÇ   r°   r±   r²   r³   r   )r}   rB   r´   re   rf   r›   rœ   s   &      r   Útest_stream_read_pandasrf  Ê  s€   € à-;×-IÑ-IÔ-KÓLÑ-K E�o‰oÖÑ-K€FÐLØ"×-Ñ-Ó/€MÜ�V‰V×Ñ Ó.€FØ×ÑÓ!€Fä�yŠy˜Ó ×,Ñ,°$Ð,Ó7€HÜ�vÖ(ùò Ms   “Bc                 óÆ   € V P                  4       pV P                  4       p\        P                  ! V4      p\        P                  P                  V4      pV\        V4      3# r
   )rD   r    r,   rZ   ÚMessageReaderrÇ   r  )r}   r?   re   Ú
buf_readerrf   s   &    r   Úexample_messagesrj  Õ  sQ   € à×*Ñ*Ó,€GØ"×-Ñ-Ó/€MÜ—’ Ó/€JÜ×Ñ×)Ñ)¨*Ó5€FØ”D˜“LÐ Ð r   c                  óx  € \         P                  ! \        4      ;_uu_ 4        \        \        P
                  ! 4       4       R R R 4       \         P                  ! \        4      ;_uu_ 4        \        \        P                  ! 4       4       R R R 4       R #   + '       g   i     L[; i  + '       g   i     R # ; ir
   )r‰   rŠ   rð   Úreprr,   ÚMessagerh  r   r   r   Útest_message_ctors_no_segfaultrn  Þ  sc   € Ü	�Š”y×	!Õ	!ÜŒR�ZŠZ‹\Ô÷ 
"ô 
�Š”y×	!Õ	!ÜŒR×ÒÓÔ ÷ 
"Ñ	!÷ 
"×	!ú÷ 
"×	!Ð	!ús   £BÁ,B(ÂB%	Â(B9	c                 óâ  € V w  r\        V4      ^8X  g   Q hV^ ,          P                  R8X  g   Q h\        V^ ,          P                  \        P
                  4      '       g   Q h\        V^ ,          P                  \        P
                  4      '       g   Q hV^ ,          P                  \        P                  P                  8X  g   Q hVR,           F™  pVP                  R8X  g   Q h\        VP                  \        P
                  4      '       g   Q h\        VP                  \        P
                  4      '       g   Q hVP                  \        P                  P                  8X  d   K™  Q h	  R# )r    r'   ºrÎ   NNzrecord batchN)
r]   rÌ   ra   Úmetadatar,   ÚBufferÚbodyr"  r'  r%  )rj  rA   ÚmessagesÚmsgs   &   r   Útest_message_readerrv  æ  s  € Ø"�K€Aäˆx‹=˜AÔÐÐØ�A�;×Ñ˜xÔ'Ð'Ð'Ü�h˜q•k×*Ñ*¬B¯I©I×6Ò6Ð6Ð6Ü�h˜q•k×&Ñ&¬¯	©	×2Ò2Ð2Ð2Ø�A�;×'Ñ'¬2×+=Ñ+=×+@Ñ+@Ô@Ð@Ð@à˜�|ˆ|ˆØ�x‰x˜>Ô)Ð)Ð)Ü˜#Ÿ,™,¬¯	©	×2Ò2Ð2Ð2Ü˜#Ÿ(™(¤B§I¡I×.Ò.Ð.Ð.Ø×#Ñ#¤r×'9Ñ'9×'<Ñ'<Ö<Ð<Ð<ó	 r   c                 ó(  € V w  rV^ ,          pVP                  4       p\        P                  ! VP                  4       ^,          4      p\        P                  P                  V4      p\        P                  P                  V4      p\        P                  P                  VP                  4       4      p\        P                  P                  V4      p	VP                  V4      '       g   Q hVP                  V4      '       g   Q hVP                  V4      '       g   Q hVP                  V	4      '       g   Q h\        P                  ! \        P                  RR7      ;_uu_ 4        \        P                  P                  \        P                  ! R4      4       RRR4       \        P                  ! \        4      ;_uu_ 4        \        P                  P                  V4       RRR4       R#   + '       g   i     L\; i  + '       g   i     R# ; i)r   zCorrupted message©Úmatchs   abN)Ú	serializer,   rZ   Ú
to_pybytesrT   r/  r`   r‰   rŠ   r‹   ÚEOFError)
rj  rA   rt  ru  r�   rf   ÚrestoredÚ	restored2Ú	restored3Ú	restored4s
   &         r   Ú#test_message_serialize_read_messager�  ö  sZ  € Ø"�K€Aà
�1�+€CØ
�-‰-‹/€CÜ�_Š_˜SŸ^™^Ó-°Õ1Ó2€Fä�v‰v×"Ñ" 3Ó'€HÜ—‘×#Ñ# FÓ+€IÜ—‘×#Ñ# C§N¡NÓ$4Ó5€IÜ—‘×#Ñ# FÓ+€Ià�:‰:�h×ÒÐÐØ�:‰:�i× Ò Ð Ð Ø�:‰:�i× Ò Ð Ð Ø�:‰:�i× Ò Ð Ð ä	�Š”r—‘Ð.A×	BÖ	BÜ
�‰×ÑœBŸOšO¨EÓ2Ô3÷ 
Cô 
�Š”x×	 Õ	 Ü
�‰×Ñ˜FÔ#÷ 
!Ñ	 ÷ 
C×	Bú÷ 
!×	 Ð	 ús   Å%4G-Ç H Ç-G=	È H	c                 ó˜   € V w  rV F?  p\        V4      pR V9  g   Q hRV9  g   Q hRV9  g   Q hRVP                   2V9   d   K?  Q h	  R# )z{self.type}z{metadata_len}z
{body_len}ztype: N)ÚstrrÌ   )rj  rA   rt  ru  Úss   &    r   Ú%test_message_repr_shows_actual_valuesr…    s_   € Ø"�K€AãˆÜ�‹Hˆà AÔ%Ð%Ð%Ø qÔ(Ð(Ð(Ø 1Ô$Ð$Ð$Ø˜Ÿ™�zÐ" aÖ'Ð'Ð'ó r   c                 ó   € V w  rV F°  p\         P                  ! 4       p\         P                  ! VR R7      ;_uu_ 4       pVP                  V4       RRR4       VP	                  4       p\         P
                  P                  \         P                  ! VR R7      4      pVP                  V4      '       d   K°  Q h	  R#   + '       g   i     Lt; i)Úgzipr  N)	r,   r—   Úoutput_streamÚserialize_tor   rT   r/  Úinput_streamr`   )rj  rA   rt  r0  Úraw_outÚcompressed_outÚcompressed_bufr›   s   &       r   Ú!test_message_read_from_compressedrŽ    s�   € ð #�K€AÛˆÜ×'Ò'Ó)ˆÜ×Ò˜g°6×:Õ:¸nØ× Ñ  Ô0÷ ;ð !×)Ñ)Ó+ˆä—‘×$Ñ$¤R§_¢_°^ØAGô&Ió Jˆà�}‰}˜W×%Ô%Ð%Ð%ó ç:×:ús   ¿B=Â=Cc                 ó®   € V w  r\         P                  P                  V^ ,          4      pVP                  V^,          P                  4      '       g   Q hR# r  )r,   rT   Úread_schemar`   r'   )rj  r?   rt  r'   s   &   r   Útest_message_read_schemar‘  *  sA   € Ø(Ñ€GÜ�V‰V×Ñ ¨¥Ó,€FØ�=‰=˜ �×*Ñ*×+Ò+Ð+Ò+r   c                 óÈ   € V w  r\        WR ,          4       FG  w  r4\        P                  P                  WCP                  4      pVP                  V4      '       d   KG  Q h	  R# )rp  N)Úzipr,   rT   Úread_record_batchr'   r`   )rj  r?   rt  rB   r0  Ú
read_batchs   &     r   Útest_message_read_record_batchr–  0  sN   € Ø(Ñ€Gä˜g°¥|Ö4‰ˆÜ—V‘V×-Ñ-¨g·|±|ÓDˆ
Ø× Ñ  ×'Ô'Ð'Ð'ó 5r   c                  óh  € \         P                  ! \         P                  ! R .\         P                  ! 4       R7      .R.R7      p \         P                  ! 4       p\         P
                  P                  WP                  4      ;_uu_ 4       pVP                  V 4       RRR4       VP                  4       p\        P                  ! \        RR7      ;_uu_ 4        \         P
                  P                  W0P                  4       RRR4       R#   + '       g   i     Lx; i  + '       g   i     R# ; i)ó   foorË   Ústrsr  Nz type record batch but got schemarx  )r,   r1   rÓ   r.   r—   rT   rn   r'   r7   r   r‰   rŠ   ÚIOErrorr”  )rB   Ústreamr>   r�   s       r   Ú.test_read_record_batch_on_stream_error_messagerœ  8  sË   € ä�OŠOœRŸXšX v h´R·W²W³YÔ?Ð@Ø#) (ô,€Eä×"Ò"Ó$€FÜ	�‰×	Ñ	˜6§<¡<×	0Ô	0°FØ×Ñ˜5Ô!÷ 
1à
�/‰/Ó
€CÜ	�Š”wØ?÷
Aö 
Aä
�‰× Ñ  §l¡lÔ3÷
Añ 
A÷ 
1×	0ú÷
A÷ 
Að 
Aús   ÂDÃ*D ÄD	Ä D1	c                   ó2   a € ] tR tRt o R tR tR tRtV tR# )ÚStreamReaderServeriI  c                óP  € \         P                   ! \         P                  \         P                  4      V n        V P                  P	                  R4       V P                  P                  ^4       V P                  P                  4       w  r#Wn        RV n        . V n	        RV n
        V# )ú	127.0.0.1N)r   r   )ÚsocketÚAF_INETÚSOCK_STREAMÚ_sockÚbindÚlistenÚgetsocknameÚ_do_read_allÚ_schemaÚ_batchesÚ_table)r   Údo_read_allÚhostÚports   &&  r   ÚinitÚStreamReaderServer.initK  su   € Ü—]’]¤6§>¡>´6×3EÑ3EÓFˆŒ
Ø�
‰
�‰Ð(Ô)Ø�
‰
×Ñ˜!ÔØ—Z‘Z×+Ñ+Ó-‰
ˆØ'ÔØˆŒØˆŒØˆŒØˆr   c                ó$  € V P                   P                  4       w  r VP                  R R7      p\        P                  P                  V4      pVP                  V n        V P                  '       d   VP                  4       V n
        M/\        V4       F   w  rVV P                  P                  V4       K"  	  VP                  4        V P                   P                  4        R#   TP                  4        T P                   P                  4        i ; i)Úrb©ÚmodeN)r¤  ÚacceptÚmakefiler,   rT   rÇ   r'   r©  r¨  r™   r«  r^   rª  r3   r:   )r   Ú
connectionÚclient_addressr£   rf   r@   rB   s   &      r   ÚrunÚStreamReaderServer.runV  sÉ   € Ø%)§Z¡Z×%6Ñ%6Ó%8Ñ"ˆ
ð	Ø×(Ñ(¨dÐ(Ó3ˆFÜ—V‘V×'Ñ'¨Ó/ˆFØ!Ÿ=™=ˆDŒLØ× × Ð Ø$Ÿo™oÓ/�•ä )¨&Ö 1‘H�AØ—M‘M×(Ñ(¨Ö/ñ !2ð ×ÑÔØ�J‰J×ÑÖøð ×ÑÔØ�J‰J×ÑÕús   žBC# Ã#,Dc                óp   € V P                   V P                  '       d   V P                  3# V P                  3# r
   )r©  r¨  r«  rª  r   s   &r   Ú
get_resultÚStreamReaderServer.get_resulte  s5   € Ø—‘¨T×->×->Ð->˜dŸk™kð $ð 	$Ø—]‘]ð$ð 	$r   )rª  r¨  r©  r¤  r«  N)	rF   rG   rH   rI   r¯  r¹  r¼  rJ   rK   rL   s   @r   rž  rž  I  s   ø‡ € ò	ò÷$ð $r   rž  c                   ó>   a € ] tR tRt o R tR tR tR tR tRt	V t
R# )	ÚSocketStreamFixtureij  c                ó   € R # r
   r   r   s   &r   r   ÚSocketStreamFixture.__init__l  s   € ñ 	r   c                ób  € \        4       V n        V P                  P                  V4      pV P                  P                  4        \        P                  ! \        P
                  \        P                  4      V n        V P                  P                  R V34       V P                  4       V n
        R# )r   N)rž  Ú_serverr¯  Ústartr¡  r¢  r£  r¤  Úconnectr   r   )r   r¬  r®  s   && r   Ústart_serverÚ SocketStreamFixture.start_serverq  sp   € Ü)Ó+ˆŒØ�|‰|× Ñ  Ó-ˆØ�‰×ÑÔÜ—]’]¤6§>¡>´6×3EÑ3EÓFˆŒ
Ø�
‰
×Ñ˜K¨Ð.Ô/Ø—M‘M“OˆŽ	r   c                ó0  € ^ RI pV P                  P                  VP                  R^ 4      4       V P                  P	                  4        V P
                  P                  4        V P                  P                  4        V P                  P                  4       # )r   NÚQ)
Ústructr   r¼   ÚpackÚflushr¤  r:   rÃ  r¹   r¼  )r   rÊ  s   & r   Ústop_and_get_resultÚ'SocketStreamFixture.stop_and_get_resulty  sa   € ÛØ�	‰	�‰˜Ÿ™ C¨Ó+Ô,Ø�	‰	�‰ÔØ�
‰
×ÑÔØ�‰×ÑÔØ�|‰|×&Ñ&Ó(Ð(r   c                ó:   € V P                   P                  R R7      # )r¸   r³  )r¤  r¶  r   s   &r   r   ÚSocketStreamFixture.get_sink�  s   € Ø�z‰z×"Ñ"¨Ð"Ó-Ð-r   c                ó.   € \         P                  ! W4      # r
   rt   rV   s   &&&r   r/   ÚSocketStreamFixture._get_writer„  rw   r   )rÃ  r¤  r   N)rF   rG   rH   rI   r   rÆ  rÍ  r   r/   rJ   rK   rL   s   @r   r¿  r¿  j  s#   ø‡ € òò
$ò)ò.÷8ð 8r   r¿  c                  ó   € \        4       # r
   )r¿  r   r   r   Úsocket_fixturerÔ  ˆ  r~   r   c                 ó^  € V P                  R R7       V P                  4       pV P                  4       w  r#VP                  V^ ,          P                  4      '       g   Q h\        V4      \        V4      8X  g   Q h\        V4       F$  w  rEW4,          P                  V4      '       d   K$  Q h	  R# )F©r¬  N)rÆ  rD   rÍ  r`   r'   r]   r^   )rÔ  Úwriter_batchesÚreader_schemaÚreader_batchesr@   rB   s   &     r   Útest_socket_simple_roundtriprÚ  �  s—   € à×Ñ¨EÐÔ2Ø#×1Ñ1Ó3€NØ$2×$FÑ$FÓ$HÑ!€Mà×Ñ ¨qÕ 1× 8Ñ 8×9Ò9Ð9Ð9Üˆ~Ó¤# nÓ"5Ô5Ð5Ð5Ü˜nÖ-‰ˆØÕ ×'Ñ'¨×.Ô.Ð.Ð.ó .r   c                 óÞ   € V P                  R R7       V P                  4       pV P                  4       w  r#\        P                  P                  V4      pVP                  V4      '       g   Q hR# )TrÖ  N)rÆ  rD   rÍ  r,   r4   r5   r`   )rÔ  r×  rA   r›   rœ   s   &    r   Útest_socket_read_allrÜ  ™  sZ   € à×Ñ¨DÐÔ1Ø#×1Ñ1Ó3€NØ×2Ñ2Ó4�I€Aä�x‰x×$Ñ$ ^Ó4€HØ�=‰=˜×"Ò"Ð"Ò"r   c                  óX  € \         P                  ! R R./4      p \        P                  P	                  V 4      p\        P
                  ! 4       p\        W4       VP                  4       p\        P                  P                  VR,          4      pVP                  4       p\        W4       R# )r(   ç      ø?:é   NNN)r±   rÛ   r,   rà   rá   r—   Ú
write_filer   rT   rÇ   r°   r   )râ   rB   r   Úbufferrf   Úrdfs         r   Útest_ipc_file_stream_has_eosrã  ¦  s   € ô 
�Š�u˜s˜e�nÓ	%€BÜ�N‰N×&Ñ& rÓ*€EÜ× Ò Ó"€DÜˆuÔØ�]‰]‹_€Fô �V‰V×Ñ  r¥
Ó+€Fð ×
Ñ
Ó
€Cä�rÖr   c                  óˆ  € \         P                  ! R R./4      p \        P                  P	                  V 4      p\        P
                  ! 4       p\        W4       VP                  4       p\        P                  ! V4      p\        V4      pV^ ,          P                  4       p\         P                  ! V4      p\        W4       R# )r(   rÞ  N)r±   rÛ   r,   rà   rá   r—   rà  r   rZ   Ú	read_filer¯   r   )râ   rB   r   rá  rf   r?   rW  râ  s           r   Útest_ipc_zero_copy_numpyræ  ¸  s‹   € ä	�Š�u˜s˜e�nÓ	%€Bä�N‰N×&Ñ& rÓ*€EÜ× Ò Ó"€DÜˆuÔØ�]‰]‹_€FÜ�_Š_˜VÓ$€Fä˜Ó€Gà�1�:×ÑÓ!€DÜ
�,Š,�tÓ
€CÜ�rÖr   Úipc_typer›  Úfilec           
      óz  € \         P                  ! R R./4      p\        P                  P	                  V4      p\        P
                  ! 4       p^pR\        P                  P                  R\        P                  P                  /V ,          pV! W2P                  4      ;_uu_ 4       p\        V4       F!  pVP                  VR\        V4      /R7       K#  	  VP                  V4       RRR4       VP                  4       pV R8X  dK   \        P                  P                  V4      ;_uu_ 4       p	\        V	P!                  4       4      p
RRR4       Mc\        P                  P#                  V4      ;_uu_ 4       p	\        V	P$                  4       Uu. uF  pV	P'                  V4      NK  	  p
pRRR4       \        V4       F}  pX
V,          P(                  P*                  ^8X  g   Q h\-        W§,          P.                  \        P0                  4      '       g   Q hW§,          P.                  R\        V4      /8X  d   K}  Q h	  X
V,          P(                  P*                  ^8X  g   Q hW¤,          P.                  e   Q hR#   + '       g   i     EL�; i  + '       g   i     Lì; iu upi   + '       g   i     EL; i)r(   rÞ  r›  rè  Úbatch_id)Úcustom_metadataN)r±   rÛ   r,   rà   rá   r—   rT   rn   rU   r'   r0   r7   rƒ  r   rÇ   r  Ú!iter_batches_with_custom_metadatar[   r\   Úget_batch_with_custom_metadatarB   Únum_rowsra   rë  ÚKeyValueMetadata)rç  râ   rB   r   Úbatch_countÚfile_factoryr>   r@   rá  rf   Úbatch_with_metass   &          r   Ú+test_batches_with_custom_metadata_roundtripró  É  s6  € ô 
�Š�u˜s˜e�nÓ	%€Bä�N‰N×&Ñ& rÓ*€EÜ× Ò Ó"€Dà€KØœbŸf™f×/Ñ/ØœBŸF™FŸO™Oð-Ø-5õ7€Lñ 
�dŸL™L×	)Ô	)¨VÜ�{Ö#ˆAØ×Ñ˜u°zÄ3ÀqÃ6Ð6JÐÖKñ $ð 	×Ñ˜5Ô!÷	 
*ð �]‰]‹_€Fà�8ÔÜ�V‰V×Ñ ×'Ô'¨6Ü# F×$LÑ$LÓ$NÓOÐ÷ (Ð'ô �V‰V×Ñ˜f×%Ô%¨ä).¨v×/HÑ/HÔ)Ió KÙ)I Að !'× EÑ EÀaÖ HÙ)Ið ð  K÷ &ô �;ÖˆØ Õ"×(Ñ(×1Ñ1°QÔ6Ð6Ð6ÜØÕ×/Ñ/´×1DÑ1D÷Fò Fð 	Fð FàÕ"×2Ñ2°zÄ3ÀqÃ6Ð6JÖJÐJÐJñ	  ð ˜KÕ(×.Ñ.×7Ñ7¸1Ô<Ð<Ð<ØÕ(×8Ñ8Ò@Ð@Ò@÷1 
*×	)Ð	)ú÷ (×'üò K÷ &×%Ð%ús7   Â'AI=Ä/JÅ9J)ÆJ$Æ+J)É=J	ÊJ!	Ê$J)Ê)J:	c                  ó²  € \         P                  P                  \         P                  ! . RO4      \         P                  ! . RO4      .RR.R7      p \         P                  ! 4       p\         P
                  P                  WP                  4      ;_uu_ 4         RRR4       VP                  4       p\         P
                  P                  V4      ;_uu_ 4       pVP                  4       pRRR4       XP                  P                  V P                  4      '       g   Q h\        V4      ^ 8X  g   Q hR#   + '       g   i     L¡; i  + '       g   i     Ld; i)rÎ   r=  r>  r  NrB  r@  )r,   r4   r  rÓ   r—   rT   rn   r'   r   rÇ   r™   r`   r]   )rC   r   r£   rf   r›   s        r   Útest_ipc_stream_no_batchesrõ  ð  së   € ä�H‰H× Ñ ¤"§(¢(ª<Ó"8Ü"$§(¢(Ò+GÓ"Hð"Jà(+¨S zð !ó 3€Eô × Ò Ó"€DÜ	�‰×	Ñ	˜4§¡×	.Õ	.Ø÷ 
/ð �]‰]‹_€FÜ	�‰×	Ñ	˜F×	#Ô	# vØ—‘Ó"ˆ÷ 
$ð �=‰=×Ñ §¡×-Ò-Ð-Ð-Üˆv‹;˜!ÔÐÒ÷ 
/×	.ú÷ 
$×	#ús   ÂD3ÃEÄ3E	ÅE	c                  ó  € ^
p ^p\         P                  ! R\        P                  P	                  V 4      /4      p\
        P                  P                  V4      p\
        P                  P                  V4      W,          8”  g   Q hR# )rþ   r(   N)
r±   rÛ   rÜ   r2   rÝ   r,   rà   rá   rT   Úget_record_batch_size)ÚNÚitemsizerâ   rB   s       r   Útest_get_record_batch_sizerú    s_   € à
€AØ€HÜ	�Š�uœbŸi™iŸo™o¨aÓ0Ð1Ó	2€Bä�N‰N×&Ñ& rÓ*€EÜ�6‰6×'Ñ'¨Ó.°!µ,Ô?Ð?Ò?r   c                 óŒ   € \         P                  ! Y'       d   ^M^R7      p\         P                  ! W!R7      p\        W04       R# )rÏ   )Únthreadsrè   N)r,   Úserialize_pandasÚdeserialize_pandasr   )râ   ré   r�   r›   s   &&  r   Ú"_check_serialize_pandas_round_triprÿ    s0   € ä
×
Ò
˜b¶©1ÀÔ
C€CÜ×"Ò" 3Ô@€FÜ�vÖ"r   c                  ó¦   € \         P                  ! . RORR7      p RR.p\         P                  ! R. R	OR\        R4      /WR7      p\	        V4       R# )
rÎ   Úmy_index©Únamer(   r)   Úabc©ÚindexÚcolumnsNrÍ   ©rÞ  gš™™™™™ù?g333333û?©r±   ÚIndexrÛ   r  rÿ  ©r  r  râ   s      r   Ú test_pandas_serialize_round_tripr    sF   € ä�HŠH’Y ZÔ0€EØ�eˆn€GÜ	�ŠØ	’ ¬¨U«Ð4Øô
€Bô ' rÖ*r   c                  óª   € \         P                  ! . R
ORR7      p RR.p\         P                  ! R. ROR\        R4      /WR7      p\	        VRR7       R	# )rÎ   r  r  r(   r)   r  r  Trè   NrÍ   r  r	  r  s      r   Ú)test_pandas_serialize_round_trip_nthreadsr    sH   € ä�HŠH’Y ZÔ0€EØ�eˆn€GÜ	�ŠØ	’ ¬¨U«Ð4Øô
€Bô ' r°t×<r   c                  ó*  € \         P                  ! . R	ORR7      p \         P                  ! \        R4      RR7      p\         P                  P	                  W.4      pRR.p\         P
                  ! R. R
OR\        R4      /VVR7      p\        V4       R# )rÎ   Úlevel_1r  ÚdefNr(   r)   r  r  rÍ   r  )r±   r
  r  Ú
MultiIndexr  rÛ   rÿ  )Úindex1Úindex2r  r  râ   s        r   Ú,test_pandas_serialize_round_trip_multi_indexr  )  st   € ä�XŠX’i iÔ0€FÜ�XŠX”d˜5“k¨Ô-€FÜ�M‰M×%Ñ% vÐ&6Ó7€Eà�eˆn€GÜ	�ŠØ	’ ¬¨U«Ð4ØØô
€Bô
 ' rÖ*r   c                  óF   € \         P                  ! 4       p \        V 4       R # r
   )r±   rÛ   rÿ  )râ   s    r   Ú%test_serialize_pandas_empty_dataframer  8  s   € ä	�Š‹€BÜ& rÖ*r   c                  óÊ   € \         P                  ! \        \        . ROR4      4      4      p \        P
                  ! V 4      p\        P                  ! V4      p\        W 4       R# )rÞ  r  Nr  )r±   rÛ   r  r“  r,   rý  rþ  r   )râ   r�   r›   s      r   Ú3test_pandas_serialize_round_trip_not_string_columnsr  >  sD   € ä	�Š”dœ3š°Ó6Ó7Ó	8€BÜ
×
Ò
˜bÓ
!€CÜ×"Ò" 3Ó'€FÜ�vÖ"r   c                  óZ  € \         P                  ! R . RO/. ROR7      p \         P                  ! R . RO/4      p\        P                  ! V RR7      p\        P                  ! V4      p\        W14       \        P                  ! V RR7      p\        P                  ! V4      p\        W04       R# )r=  )r  Frø   TNrÍ   )r±   rÛ   r,   rý  rþ  r   )râ   rœ   r�   r›   s       r   Ú'test_serialize_pandas_no_preserve_indexr  F  s~   € ä	�Š�sšIÐ&ªiÔ	8€BÜ�|Š|˜S¢)Ð,Ó-€Hä
×
Ò
˜b°Ô
7€CÜ×"Ò" 3Ó'€FÜ�vÔ(ä
×
Ò
˜b°Ô
6€CÜ×"Ò" 3Ó'€FÜ�vÖ"r   c            
      óÞ  € ^p \         P                  ! R\        P                  P	                  V 4      RR\        P
                  RRR./4      p\        P                  P                  V4      pVP                  P                  4       pVP                  4       p\        P                  P                  V4      p\        P                  P                  WE4      pVP                  V4      '       g   Q hR# )r#   r$   r%   r(   r)   r*   r+   N)r±   rÛ   rÜ   r2   rÝ   rß   r,   rà   rá   r'   rz  rT   r�  r”  r`   )r=   râ   rB   Ús_schemaÚs_batchÚrecons_schemaÚrecons_batchs          r   Ú#test_schema_batch_serialize_methodsr!  T  s³   € à€EÜ	�ŠØŒr�y‰y�‰˜uÓ%Ø�”r—v‘v˜u h°Ð6ð8ó 
9€Bô �N‰N×&Ñ& rÓ*€Eà�|‰|×%Ñ%Ó'€HØ�o‰oÓ€Gä—F‘F×&Ñ& xÓ0€MÜ—6‘6×+Ñ+¨GÓC€LØ×Ñ˜u×%Ò%Ð%Ò%r   c                  ó  € R RRR/p R RRR/p\         P                  ! R\         P                  ! 4       4      p\         P                  ! R\         P                  ! 4       V R7      p\         P                  ! W#.VR7      pVP                  4       p\         P                  P                  V4      pVP                  V4      '       g   Q hVP                  V8X  g   Q hV^ ,          P                  e   Q hV^,          P                  V 8X  g   Q hR# )	r˜  s   bars   kinds   fields   schemar=  r>  ©rq  N)
r,   rÒ   rR  Ústringr'   rz  rT   r�  r`   rq  )Úfield_metadataÚschema_metadataÚf0Úf1r'   r  r  s          r   Ú'test_schema_serialization_with_metadatar)  d  sÛ   € Ø˜f g¨xÐ8€NØ˜v w°	Ð:€Oä	�Š�#”r—w’w“yÓ	!€BÜ	�Š�#”r—y’y“{¨^Ô	<€Bä�YŠY˜�x¨/Ô:€Fà×ÑÓ!€HÜ—F‘F×&Ñ& xÓ0€Mà×Ñ ×'Ò'Ð'Ð'Ø×!Ñ! _Ô4Ð4Ð4Ø˜Õ×$Ñ$Ò,Ð,Ð,Ø˜Õ×$Ñ$¨Ô6Ð6Ò6r   c                 óÄ   € \         P                  P                  WP                  4      ;_uu_ 4       pVP	                  V 4       R R R 4       R #   + '       g   i     R # ; ir
   )r,   rT   rU   r'   r7   )rB   r   r>   s   && r   rà  rà  v  s8   € Ü	�‰�‰˜Ÿ|™|×	,Ô	,°Ø×Ñ˜5Ô!÷ 
-×	,×	,Ò	,ús   ²AÁA	c                 óþ   € \         P                  P                  V 4      ;_uu_ 4       p\        VP                  4       Uu. uF  q!P                  V4      NK  	  upuuR R R 4       # u upi   + '       g   i     R # ; ir
   )r,   rT   r[   r0   r\   r_   )r£   rf   r@   s   &  r   rå  rå  {  sX   € Ü	�‰×	Ñ	˜&×	!Ô	! VÜ-2°6×3LÑ3LÔ-MÓNÑ-M¨× Ñ  Ö#Ñ-MÑN÷ 
"Ò	!ùÚN÷ 
"×	!Ð	!ús   ¨A+Á A&ÁA+Á&A+Á+A<	c                  óV  € \         P                  ! R \         P                  ! 4       3.4      p \         P                  ! 4       p\         P                  P                  W4      ;_uu_ 4         RRR4       VP                  4       p\         P                  ! \         P                  ! V4      4      ;_uu_ 4       pVP                  4       pRRR4       \        X4      ^ 8X  g   Q hVP                  P                  V 4      '       g   Q hR#   + '       g   i     L¢; i  + '       g   i     LZ; i)rÒ   N)r,   r'   Úint64r—   rT   rU   r   r¡   rZ   r™   r]   r`   )r'   r   r�   rf   rC   s        r   Útest_write_empty_ipc_filer.  €  sÀ   € ô �YŠY˜¤"§(¢(£*Ð-Ð.Ó/€Fä× Ò Ó"€DÜ	�‰�‰˜×	&Õ	&Ø÷ 
'ð �-‰-‹/€CÜ	×	!Ò	!¤"§/¢/°#Ó"6×	7Ô	7¸6Ø—‘Ó!ˆ÷ 
8äˆu‹:˜Œ?Ðˆ?Ø�<‰<×Ñ˜v×&Ò&Ð&Ò&÷ 
'×	&ú÷ 
8×	7ús   Á)DÂ5DÄD	ÄD(	c                  ób  a€ R  oV3R lp \        V ! 4       4      p\        P                  ! V4      p\        P                  P                  S! 4       V4      ;_uu_ 4       pRpV! 4       f   Q h\        V4      V ! 4       8X  g   Q hV! 4       e   Q h RRR4       \        \        V ! 4       4      4      p\        P                  ! V4      p\        P                  P                  S! 4       V4      ;_uu_ 4       pRpV! 4       f   Q h\        V4      V ! 4       8X  g   Q hV! 4       e   Q h RRR4       V ! 4       p\        P                  ! \        4      ;_uu_ 4        \        P                  P                  R\        P                  ! 4       3.V4      p RRR4       \        P                  ! \        4      ;_uu_ 4        \        P                  P                  RV4      p RRR4       R#   + '       g   i     EL]; i  + '       g   i     LÛ; i  + '       g   i     L…; i  + '       g   i     R# ; i)c                  óZ   € \         P                  ! R \         P                  ! 4       3.4      # )rÒ   )r,   r'   r-  r   r   r   Úmake_schemaÚ0test_py_record_batch_reader.<locals>.make_schema‘  s   € Ü�yŠy˜7¤B§H¢H£JÐ/Ð0Ó1Ð1r   c                  ó„   <€ S! 4       p \         P                  ! . RO.V R7      p\         P                  ! ^^..V R7      pW.# )rÎ   r&   rÍ   )r,   r1   )r'   Úbatch1Úbatch2r1  s      €r   Úmake_batchesÚ1test_py_record_batch_reader.<locals>.make_batches”  s;   ø€ Ù“ˆÜ—’¢) °VÔ<ˆÜ—’ 1 a & °&Ô9ˆØÐÐr   NrÒ   )r   ÚweakrefÚrefr,   ÚRecordBatchReaderr5   r  Úiterr‰   rŠ   rð   r-  )r6  r?   rã   rf   r1  s       @r   Útest_py_record_batch_readerr<  �  s­  ø€ ò2õ ô ‘|“~Ó&€GÜ	�Š�WÓ	€Bä	×	Ñ	×	*Ñ	*©;«=Ø+2÷
4ô 
4Ø7=ØˆÙ‹tÒÐÐÜ�F‹|™|›~Ô-Ð-Ð-Ù‹tŠ|Ð‰|÷
4ô ”8™L›NÓ+Ó,€GÜ	�Š�WÓ	€Bä	×	Ñ	×	*Ñ	*©;«=Ø+2÷
4ô 
4Ø7=ØˆÙ‹tÒÐÐÜ�F‹|™|›~Ô-Ð-Ð-Ù‹tŠ|Ð‰|÷
4ñ ‹n€GÜ	�Š”y×	!Õ	!Ü×%Ñ%×2Ñ2Ø”r—x’x“zÐ"Ð# Wó.ˆà÷ 
"ô
 
�Š”y×	!Õ	!Ü×%Ñ%×2Ñ2°4¸ÓAˆØ÷ 
"Ñ	!÷5
4÷ 
4ð 
4ú÷
4÷ 
4ú÷ 
"×	!ú÷
 
"×	!Ð	!ús0   Á0G#Ã30G7Å7H
Æ7!HÇ#G4	Ç7H	È
H	ÈH.	c                  ó  €  ! R  R4      p \         P                  ! \         P                  ! . R	O\         P                  ! 4       R7      .R.R7      \         P                  ! \         P                  ! . R
O\         P                  ! 4       R7      .R.R7      .pV ! V4      p\         P                  P                  V4      p\         P                  P                  V4      pVP                  4       V8X  g   Q h\         P                  P                  V4      pVP                  4       V8X  g   Q h\         P                  P                  W!^ ,          P                  R7      pVP                  4       V8X  g   Q h\         P                  ! \         P                  ! R\         P                  ! 4       4      .4      p\         P                  P                  W%R7      pVP                  4       VP                  V4      8X  g   Q h\        P                  ! \         P                  P                   RR7      ;_uu_ 4        \         P                  P                  V\         P                  ! \         P                  ! R\         P"                  ! \         P                  ! 4       4      4      .4      R7       RRR4       \        P                  ! \$        4      ;_uu_ 4        \         P                  P                  V^ ,          R,          4       RRR4       \        P                  ! \$        4      ;_uu_ 4        \         P                  P                  W1^ ,          R7       RRR4       R#   + '       g   i     L¼; i  + '       g   i     Lw; i  + '       g   i     R# ; i)c                   ó0   a € ] tR tRt o R tRR ltRtV tR# )ÚAtest_record_batch_reader_from_arrow_stream.<locals>.StreamWrapperi¿  c                ó   € Wn         R # r
   ©r?   )r   r?   s   &&r   r   ÚJtest_record_batch_reader_from_arrow_stream.<locals>.StreamWrapper.__init__À  s   € Ø"ŽLr   Nc                ó®   € \         P                  P                  V P                  ^ ,          P                  V P                  4      pVP                  V4      # )r   )r,   r:  r5   r?   r'   Ú__arrow_c_stream__)r   Úrequested_schemarf   s   && r   rD  ÚTtest_record_batch_reader_from_arrow_stream.<locals>.StreamWrapper.__arrow_c_stream__Ã  sA   € Ü×)Ñ)×6Ñ6Ø—‘˜Q•×&Ñ&¨¯©ó6ˆFà×,Ñ,Ð-=Ó>Ð>r   rA  r
   )rF   rG   rH   rI   r   rD  rJ   rK   rL   s   @r   ÚStreamWrapperr?  ¿  s   ø‡ € ò	#÷	?ò 	?r   rG  rË   r=  r  r&   úField 0 cannot be castrx  NrÍ   ©rC  r#   r    )r,   r1   rÓ   r-  r4   r5   r:  Úfrom_streamr™   r'   rÒ   r_  Úcastr‰   rŠ   ÚlibÚArrowTypeErrorÚlist_rð   )rG  rW  Úwrapperrœ   rf   Úgood_schemas         r   Ú*test_record_batch_reader_from_arrow_streamrQ  ½  sW  € ÷?ñ ?ô 	�ŠœŸš¢)´"·(²(³*Ô=Ð>ÀsÀeÔLÜ
�ŠœŸš¢)´"·(²(³*Ô=Ð>ÀsÀeÔLð€Dñ ˜DÓ!€Gô �x‰x×$Ñ$ TÓ*€HÜ×!Ñ!×-Ñ-¨hÓ7€FØ�?‰?Ó Ô(Ð(Ð(ô ×!Ñ!×-Ñ-¨gÓ6€FØ�?‰?Ó Ô(Ð(Ð(ô ×!Ñ!×-Ñ-¨gÀ1½g¿n¹nÐ-ÓM€FØ�?‰?Ó Ô(Ð(Ð(ô —)’)œRŸXšX c¬2¯8ª8«:Ó6Ð7Ó8€KÜ×!Ñ!×-Ñ-¨gÐ-ÓJ€FØ�?‰?Ó §¡¨kÓ :Ô:Ð:Ð:ô 
�Š”r—v‘v×,Ñ,Ð4L×	MÖ	MÜ
×Ñ×(Ñ(ØœBŸIšI¤r§x¢x°´R·X²X¼b¿hºh»jÓ5IÓ'JÐ&KÓLð 	)ô 	
÷ 
Nô 
�Š”y×	!Õ	!Ü
×Ñ×(Ñ(¨¨a­°­Ô6÷ 
"ô 
�Š”y×	!Õ	!Ü
×Ñ×(Ñ(¨¸q½'Ð(ÔB÷ 
"Ñ	!÷ 
N×	Mú÷ 
"×	!ú÷ 
"×	!Ð	!ús%   È-A3MË
.M'Ì"(M:ÍM$	Í'M7	Í:N	c                  ón  € \         P                  ! \         P                  ! R \         P                  ! 4       4      .4      p \         P                  ! \         P
                  ! . RO\         P                  ! 4       R7      .R .R7      \         P                  ! \         P
                  ! . R	O\         P                  ! 4       R7      .R .R7      .p\         P                  P                  V4      p\         P                  P                  W4      pVP                  V 4      P                  4       V8X  g   Q h\         P                  ! \         P                  ! R \         P                  ! 4       4      .4      p\         P                  P                  W4      pVP                  V4      P                  4       VP                  V4      8X  g   Q h\         P                  P                  W4      p\        P                  ! \        RR7      ;_uu_ 4        VP                  \         P                  ! . 4      4       RRR4       \         P                  P                  W4      p\        P                  ! \         P                  P                   RR7      ;_uu_ 4        VP                  \         P                  ! \         P                  ! R \         P"                  ! \         P                  ! 4       4      4      .4      4       RRR4       \         P                  ! \         P                  ! R \         P$                  ! 4       4      .4      p \         P
                  ! \&        P(                  ! R^^4      .\         P$                  ! 4       R7      p\         P                  ! V.R .R7      \         P                  ! V.R .R7      .p\         P                  P                  V4      p\         P                  P                  W4      pVP                  V 4      P                  4       V8X  g   Q hR#   + '       g   i     ELî; i  + '       g   i     EL@; i)
r=  rË   r  zTarget schema's field namesrx  NrH  iè  rÍ   rI  )r,   r'   rÒ   r-  r1   rÓ   r4   r5   r:  rK  r™   r_  r‰   rŠ   r)  rL  rM  rN  Údate32ÚdatetimeÚdate)Ú
schema_srcrW  Ú	table_srcrf   Ú
schema_dstÚarrs         r   Útest_record_batch_reader_castrZ  î  sª  € Ü—’œBŸHšH S¬"¯(ª(«*Ó5Ð6Ó7€Jä
�ŠœŸš¢)´"·(²(³*Ô=Ð>ÀsÀeÔLÜ
�ŠœŸš¢)´"·(²(³*Ô=Ð>ÀsÀeÔLð€Dô —‘×%Ñ% dÓ+€Iô ×!Ñ!×.Ñ.¨zÓ@€FØ�;‰;�zÓ"×+Ñ+Ó-°Ô:Ð:Ð:ô —’œBŸHšH S¬"¯(ª(«*Ó5Ð6Ó7€JÜ×!Ñ!×.Ñ.¨zÓ@€FØ�;‰;�zÓ"×+Ñ+Ó-°·±À
Ó1KÔKÐKÐKô ×!Ñ!×.Ñ.¨zÓ@€FÜ	�Š”zÐ)F×	GÖ	GØ�‰”B—I’I˜b“MÔ"÷ 
Hô ×!Ñ!×.Ñ.¨zÓ@€FÜ	�Š”r—v‘v×,Ñ,Ð4L×	MÖ	MØ�‰”B—I’IœrŸxšx¨¬R¯XªX´b·h²h³jÓ-AÓBÐCÓDÔE÷ 
Nô
 —’œBŸHšH S¬"¯)ª)«+Ó6Ð7Ó8€JÜ
�(Š(”H—M’M $¨¨2Ó.Ð/´b·i²i³kÔ
B€CÜ�OŠO˜S˜E¨#¨Ô/´·²À#ÀÈsÈeÔ1TÐU€DÜ—‘×%Ñ% dÓ+€IÜ×!Ñ!×.Ñ.¨zÓ@€FØ�;‰;�zÓ"×+Ñ+Ó-°Ô:Ð:Ò:÷ 
H×	GÐ	Gú÷
 
N×	MÐ	Mús   È&PÊ	A#P#ÐP 	Ð#P4	c                  ó’  € \         P                  ! \         P                  ! R \         P                  ! 4       4      .4      p \         P                  ! \         P
                  ! . RO\         P                  ! 4       R7      .R .R7      .p\         P                  ! \         P
                  ! . R	O\         P                  ! 4       R7      .R .R7      .p\         P                  P                  V4      p\         P                  P                  V4      p\         P                  P                  W4      p\         P                  ! \         P                  ! R \         P                  ! 4       4      .4      pVP                  V4      P                  4       VP                  V4      8X  g   Q h\         P                  P                  W4      p\         P                  ! \         P                  ! R \         P                  ! 4       RR7      .4      pVP                  V4      P                  4       VP                  V4      8X  g   Q h\         P                  P                  W4      pVP                  V4      p\        P                  ! \         P                  P                  RR7      ;_uu_ 4        VP                  4        RRR4       R#   + '       g   i     R# ; i)
r=  NrË   r  F)ÚnullablezCan't cast arrayrx  )rÎ   rÏ   NrÍ   )r,   r'   rÒ   r-  r1   rÓ   r4   r5   r:  r_  rK  r™   r‰   rŠ   rL  r‹   )rV  Údata_with_nullsÚdata_without_nullsÚtable_with_nullsÚtable_without_nullsrf   rX  Úcasted_readers           r   Ú#test_record_batch_reader_cast_nullsrb    sÖ  € Ü—’œBŸHšH S¬"¯(ª(«*Ó5Ð6Ó7€Jä
�ŠœŸš¢,´R·X²X³ZÔ@ÐAÈ#ÈÔOð€Oô 	�ŠœŸš¢)´"·(²(³*Ô=Ð>ÀsÀeÔLðÐô —x‘x×,Ñ,¨_Ó=ÐÜŸ(™(×/Ñ/Ð0BÓCÐô ×!Ñ!×.Ñ.¨zÓK€FÜ—’œBŸHšH S¬"¯(ª(«*Ó5Ð6Ó7€JØ�;‰;�zÓ"×+Ñ+Ó-Ð1A×1FÑ1FÀzÓ1RÔRÐRÐRô ×!Ñ!×.Ñ.¨zÓN€FÜ—’œBŸHšH S¬"¯(ª(«*¸uÔEÐFÓG€JØ�;‰;�zÓ"×+Ñ+Ó-Ð1D×1IÑ1IÈ*Ó1UÔUÐUÐUô ×!Ñ!×.Ñ.¨zÓK€FØ—K‘K 
Ó+€MÜ	�Š”r—v‘v×*Ñ*Ð2D×	EÖ	EØ×ÑÔ ÷ 
F×	E×	EÒ	Eús   ÊJ5Ê5K	c                  ó   € \         P                  ! R . RO/4      p RRRR/p\         P                  ! 4       p\         P                  P	                  W P
                  VR7      ;_uu_ 4       pVP                  V 4       RRR4       VP                  4       p\         P                  P                  V4      ;_uu_ 4       pVP                  V8X  g   Q h RRR4       R#   + '       g   i     Lf; i  + '       g   i     R# ; i)r=  s   creators   tests   versions   0.1.0r#  NrÍ   ©
r,   rC   r—   rT   rU   r'   r6   r   r[   rq  )ÚtblÚmetar   Úwrá  Úrs         r   Ú+test_record_batch_file_writer_with_metadatari  0  s²   € ä
�(Š(�CšÐ#Ó
$€CØ˜ ¨XÐ6€DÜ× Ò Ó"€Dä	�‰�‰˜Ÿz™z°Dˆ×	9Ô	9¸QØ	�‰�cÔ÷ 
:ð �]‰]‹_€FÜ	�‰×	Ñ	˜&×	!Ô	! QØ�z‰z˜TÔ!Ð!Ñ!÷ 
"Ñ	!÷	 
:×	9ú÷ 
"×	!Ð	!ús   Á)CÂ:C,ÃC)	Ã,C=	c                  óê  € \         P                  ! R . RO/4      p \         P                  ! 4       p\         P                  P	                  WP
                  4      ;_uu_ 4       pVP                  V 4       RRR4       VP                  4       p\         P                  P                  V4      ;_uu_ 4       pVP                  e   Q h RRR4       R#   + '       g   i     Lc; i  + '       g   i     R# ; i)r=  NrÍ   rd  )re  r   rg  rá  rh  s        r   Ú1test_record_batch_file_writer_with_empty_metadatark  >  sž   € ä
�(Š(�CšÐ#Ó
$€CÜ× Ò Ó"€Dä	�‰�‰˜Ÿz™z×	*Ô	*¨aØ	�‰�cÔ÷ 
+ð �]‰]‹_€FÜ	�‰×	Ñ	˜&×	!Ô	! QØ�z‰zÒ!Ð!Ñ!÷ 
"Ñ	!÷	 
+×	*ú÷ 
"×	!Ð	!ús   Á!CÂ2C!ÃC	Ã!C2	c                 óŽ  € V ! R/ VB pVP                  4       pVP                  4        F˜  w  rEVf   K  \        V\        4      '       g   TMRV R2pVR8X  d+   \        P
                  P                  V4      P                  pM0VR8X  d*   \        P
                  P                  V4      P                  pV RV 2V9   d   K˜  Q h	  R # )NÚ"r4  r"  Ú=r   )	Ú__repr__Úitemsra   rƒ  r,   rT   r7  r  r'  )Úoptions_objÚoptions_argsrS   rl  ÚargÚvalr,  s   &&     r   Úcheck_ipc_options_reprru  K  s´   € ÙÑ)˜LÑ)€GØ×ÑÓ€Dà ×&Ñ&Ö(‰ˆØŠ;Ùä% c¬3×/Ò/‘°r¸#¸¸b°\ˆàÐ$Ô$Ü—F‘F×$Ñ$ SÓ)×.Ñ.‰EØÐ&Ô&Ü—F‘F×*Ñ*¨3Ó/×4Ñ4ˆEà��a˜�wÐ 4Ö'Ð'Ð'ó )r   c                 ó  € V P                   R 8X  d3   RRRRR\        P                  P                  P                  RRRRR	RR
R/# V P                   R8X  d3   RRRRR\        P                  P                  P
                  RRRRR	RR
R/# / # )Údefaultr#  Fr$  r"  r  Nré   TrO  rP  Úallr  )rƒ   r,   rT   r'  r%  r(  r„   s   &r   Úwrite_options_argsry  ]  s�   € à‡}�}˜	Ô!à˜5Ø Ø¤§¡× 6Ñ 6× 9Ñ 9Ø˜4Ø˜4Ø$ eØ  %ð
ð 	
ð 
�‰˜%Ô	à˜4Ø Ø¤§¡× 6Ñ 6× 9Ñ 9Ø˜6Ø˜5Ø$ dØ  $ð
ð 	
ð ˆ	r   ry  rw  rx  )Úindirectc                 óN   € \        \        P                  P                  V 4       R # r
   )ru  r,   rT   r  )ry  s   &r   Útest_write_options_reprr|  w  s   € ô
 œ2Ÿ6™6×1Ñ1Ð3EÖFr   c           	      óþ   € V P                   R 8X  d-   RRR\        P                  P                  P                  RRRR/# V P                   R8X  d/   RRR\        P                  P                  P
                  RRR. R	O/# / # )
rw  r3  Tr4  ré   r5  Nrx  FrÍ   )rƒ   r,   rT   r7  r8  r9  r„   s   &r   Úread_options_argsr~    s   € à‡}�}˜	Ô!à" DØ¤§¡× 0Ñ 0× 4Ñ 4Ø˜4Ø˜tð	
ð 	
ð 
�‰˜%Ô	à" EØ¤§¡× 0Ñ 0× AÑ AØ˜5Øšyð	
ð 	
ð ˆ	r   r~  c                 óN   € \        \        P                  P                  V 4       R # r
   )ru  r,   rT   r6  )r~  s   &r   Útest_read_options_reprr€  “  s   € ô œ2Ÿ6™6×0Ñ0Ð2CÖDr   ri   )qÚcollectionsr   rT  r   r½   r‰   r2   r¡  Ú	threadingr8  ÚnumpyrÜ   ÚImportErrorÚpyarrowr,   Úpyarrow.tests.utilr   r   Úpandas.testingr   Úpandasr±   r   rO   rl   rr   rš   ry   r{   r}   rƒ   r†   rŽ   r’   r”   ÚmarkÚparametrizer�   r«   rµ   rÅ   rÈ   Ú	processesrÖ   rä   rç   rT   r6  rí   rñ   rô   rö   rü   r  r  r  r  r-  r  r'  r(  r1  r;  rH  rZ  rb  rd  rf  rj  rn  rv  r�  r…  r‡  rŽ  r‘  r–  rœ  ÚThreadrž  r¿  rÔ  ÚsocketsrÚ  rÜ  rã  ræ  ró  rõ  rú  rÿ  r  r  r  r  r  r  r!  r)  rà  rå  r.  r<  rQ  rZ  rb  ri  rk  ru  ry  r|  r~  r€  r   r   r   Ú<module>rŽ     s*  ðõ$ !Û Û 	Û Û Û Û Û Û ðÛó ß =ð	Ý1Û÷
$ñ $ôN>˜
ô >ô6
˜*ô 
ô 8�Zô 8ð ‡�ñó ðð ‡�ñó ðð ‡�ñ!ó ð!ð ‡‚Ø
‡L‚LØØôð ‡L‚LØØôð	ô 	ñ2ó	ð2ò/ò2ò1ð ‡�×Ñ˜ÙÙ#ð*ó ñ
#ó	ð
#ò ð. ‡�×Ññ)ó ð)òò ð ‡�×ÑØ‡�×Ññ0ó ó ð0ð$ ‡�×Ññ.ó ð.ò ;ð2 ‡�×Ñ˜Ø‡F�F×ÑÓØ‡F�F×Ñ eÐÓ,ð%ó ñ:ó	ð:ò1ð ‡�×Ñ˜Ø‡F�F×ÑÓØ‡F�F×Ñ eÐÓ,ð%ó ñ
&ó	ð
&ò/ð ‡�×Ññ?ó ð?ð( ‡�×Ññ5ó ð5ò.!ð$ ‡�×Ññó ðò<.,ðb ‡�×Ñ˜Ø‡F�F×ÑÓØ‡F�F×Ñ tÐÓ,Ø‡F�F×Ñ¨TÐÓ2Ø‡F�F×Ñ¨B¯F©F×,BÑ,B×,EÑ,EÐÓFØ‡F�F×Ñ¨TØ,.¯F©F×,BÑ,B×,EÑ,Eð ó Gð%ó ñ!óð!ò.*òDò2H-òV!IòH#ð ‡�×Ññ)ó ð)ð ‡�ñ!ó ð!ò!ò=ò $ò0	(ð ‡�×Ññ&ó ð&ò,ò(ò
4ô"$˜×)Ñ)ô $ôB8˜*ô 8ð< ‡�ñ!ó ð!ð ‡�×Ññ/ó ð/ð ‡�×Ññ#ó ð#ð ‡�×Ññ ó ð ð" ‡�×Ññ ó ð ð  ‡�×ÑØ‡�×Ñ˜ h°Ð%7Ó8ñ"Aó 9ó ð"AòJð$ ‡�×Ññ@ó ð@ð ‡�×Ñó#ó ð#ð ‡�×Ññ+ó ð+ð ‡�×Ññ=ó ð=ð ‡�×Ññ+ó ð+ð ‡�×Ññ+ó ð+ð
 ‡�×Ññ#ó ð#ð ‡�×Ññ
#ó ð
#ð ‡�×Ññ&ó ð&ò7ò$"ò
Oò
'ò *òZ.Còb";òJ!ò:"ò
"ò(ð$ ‡�ñó ðð2 ‡�×ÑØ‡�×ÑØ˜9 eÐ,°tð ó =ñGó=ó ðGð
 ‡�ñó ðð& ‡�×ÑØ˜) UÐ+°dð ó <ñEó<òEøðo+ ô Ø	ƒBðûð ô 	Úð	ús"   ¨Y5 ¹
Z Ù5	ZÚZÚZÚZ