+
    JV-jYF  ã            	       ó  € ^ RI t ^ RIt^ RIHt ^ RIHt  ^ RIHtH	t	H
t
HtHtHtHtHt  ^ RIHt ^ RIHt ] P*                  P,                  t] P0                  R 4       tR tR tR tR	 tR
 t] P*                  P?                  R]P@                  ! R. RO/4      ]PB                  ! R. RO/4      .4      R 4       t"R t#R t$R t%R t&R t'R t(R t)] P*                  P$                  R 4       t*R#   ] d     LÌi ; i  ] d    Rt LÎi ; i)é    N)Úfield)ÚDeclarationÚTableSourceNodeOptionsÚFilterNodeOptionsÚProjectNodeOptionsÚAggregateNodeOptionsÚOrderByNodeOptionsÚHashJoinNodeOptionsÚAsofJoinNodeOptions)ÚScanNodeOptionsc                  ór   € \         P                  ! R . ROR. RO/4      p \        V 4      p\        RVR7      pV# )ÚaÚbÚtable_source©Úoptions©é   é   é   ©é   é   é   )ÚpaÚtabler   r   )r   Ú
table_optsr   s      Úi/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/pyarrow/tests/test_acero.pyr   r   /   s5   € ä�HŠH�cš9 cª9Ð5Ó6€EÜ'¨Ó.€JÜ˜~°zÔB€LØÐó    c                  óü  € \         P                  ! R . ROR. RO/4      p \        V 4      p\        \	        R 4      ^8„  4      p\
        P                  ! \        RVR7      \        RVR7      .4      pVP                  4       pVP                  V P                  ^^4      4      '       g   Q h\        RVR7      p\        RW%.R7      pVP                  4       pVP                  V P                  ^^4      4      '       g   Q hR# )	r   r   r   r   Úfilter©r   ÚinputsNr   r   )
r   r   r   r   r   r   Úfrom_sequenceÚto_tableÚequalsÚslice)r   r   Úfilter_optsÚdeclÚresultr   Úfiltereds          r   Útest_declarationr,   7   s×   € ä�HŠH�cš9 cª9Ð5Ó6€EÜ'¨Ó.€JÜ#¤E¨#£J°¡NÓ3€Kô ×$Ò$Ü�N¨JÔ7Ü�H kÔ2ð&ó €Dð �]‰]‹_€FØ�=‰=˜Ÿ™ Q¨Ó*×+Ò+Ð+Ð+ô ˜~°zÔB€LÜ˜8¨[ÀÔP€HØ×ÑÓ €FØ�=‰=˜Ÿ™ Q¨Ó*×+Ò+Ð+Ò+r   c                 óN   € R \        V 4      9   g   Q hR \        V 4      9   g   Q hR# )ÚTableSourceNodeN)ÚstrÚrepr)r   s   &r   Útest_declaration_reprr1   L   s(   € à¤ LÓ 1Ô1Ð1Ð1Ø¤ \Ó 2Ô2Ð2Ò2r   c           	      ó¢  € V P                  4       ;_uu_ 4       pVP                  \        P                  ! R \        P                  ! 4       3R\        P                  ! 4       3.4      8X  g   Q hVP	                  4       pRRR4       \        P
                  ! R . ROR. RO/4      pXP                  V4      '       g   Q hR#   + '       g   i     LI; i)r   r   Nr   r   )Ú	to_readerÚschemar   Úint64Úread_allr   r&   )r   Úreaderr*   Úexpecteds   &   r   Útest_declaration_to_readerr9   R   s‘   € Ø	×	Ñ	×	!Ô	! VØ�}‰}¤§	¢	¨C´·²³Ð+<¸sÄBÇHÂHÃJÐ>OÐ*PÓ QÔQÐQÐQØ—‘Ó"ˆ÷ 
"ô �xŠx˜ši¨ªiÐ8Ó9€HØ�=‰=˜×"Ò"Ð"Ò"÷	 
"×	!ús   ™A$B>Â>C	c            
      óÂ  € \         P                  ! \        4      ;_uu_ 4        \        \        P
                  ! \        P                  ! . RO4      .R.4      4       RRR4       \        R4      p \        RV 4      p\         P                  ! \        RR7      ;_uu_ 4        VP                  4       pRRR4       R#   + '       g   i     Lf; i  + '       g   i     R# ; i)r   r   Nr   z0TableSourceNode requires table which is not null©Úmatchr   )
ÚpytestÚraisesÚ	TypeErrorr   r   Úrecord_batchÚarrayr   Ú
ValueErrorr%   ©r   r)   Ú_s      r   Útest_table_sourcerE   Z   s–   € Ü	�Š”y×	!Õ	!ÜœrŸš´·²ºÓ0CÐ/DÀsÀeÓLÔM÷ 
"ô *¨$Ó/€LÜ�~ |Ó4€DÜ	�ŠÜÐL÷
ö 
ð �M‰M‹Oˆ÷
ñ 
÷ 
"×	!ú÷

÷ 
ð 
ús   £9B:ÂCÂ:C
	ÃC	c                 óh  € \         P                  ! V \        R \        \        R4      ^8„  4      R7      .4      p\        P
                  ! \        RR7      ;_uu_ 4        VP                  4       pRRR4       \        P
                  ! \        4      ;_uu_ 4        \        \        P                  ! . RO4      4       RRR4       \        P
                  ! \        4      ;_uu_ 4        \        R4       RRR4       R#   + '       g   i     L”; i  + '       g   i     L[; i  + '       g   i     R# ; i)r!   Úcr   zNo match for FieldRef.Name\(c\)r;   N)TFT)r   r$   r   r   r=   r>   rB   r%   r?   r   rA   rC   s   &  r   Útest_filterrH   f   s»   € ä×$Ò$ØÜ�HÔ&7¼¸c»
ÀQ¹Ó&GÔHð&ó €Dô 
�Š”zÐ)K×	LÖ	LØ�M‰M‹Oˆ÷ 
Mô 
�Š”y×	!Õ	!Üœ"Ÿ(š(Ò#6Ó7Ô8÷ 
"ä	�Š”y×	!Õ	!Ü˜$Ô÷ 
"Ñ	!÷ 
M×	Lú÷ 
"×	!úç	!×	!Ð	!ús$   ÁC:Â"DÃ$D Ã:D
	ÄD	Ä D1	ÚsourceÚnumberc                 ó  € V P                  \        P                  ! R 4      ^ 8  4      pVP                  ^ 8X  g   Q h\	        V4      \	        V 4      J g   Q hVP
                  P                  V P
                  4      '       g   Q hV P                  \        P                  ! . RO4      4      pVP                  ^ 8X  g   Q h\	        V4      \	        V 4      J g   Q hVP
                  P                  V P
                  4      '       g   Q hR# )rJ   N)FFF)	r!   Úpcr   Únum_rowsÚtyper4   r&   r   rA   )rI   Úresult_exprÚresult_masks   &  r   Útest_filter_all_rowsrQ   v   sÐ   € ð —-‘-¤§¢¨Ó 2°QÑ 6Ó7€Kà×Ñ 1Ô$Ð$Ð$Ü�Ó¤ V£Ó,Ð,Ð,Ø×Ñ×$Ñ$ V§]¡]×3Ò3Ð3Ð3à—-‘-¤§¢Ò)>Ó ?Ó@€Kà×Ñ 1Ô$Ð$Ð$Ü�Ó¤ V£Ó,Ð,Ð,Ø×Ñ×$Ñ$ V§]¡]×3Ò3Ð3Ò3r   c                 ót  € \         P                  ! V \        R \        \        P                  ! \        R4      ^4      .4      4      .4      pVP                  4       pVP                  P                  R.8X  g   Q hV^ ,          P                  4       . RO8X  g   Q h\         P                  ! V \        R \        \        P                  ! \        R4      ^4      .R.4      4      .4      pVP                  4       pVP                  P                  R.8X  g   Q hVR,          P                  4       . RO8X  g   Q h\        P                  ! \        4      ;_uu_ 4        \        \        P                  ! \        R4      ^4      .RR.4       RRR4       \         P                  ! V \        R \        \        P                  ! \        R4      4      .4      4      .4      p\        P                  ! \        RR7      ;_uu_ 4        VP                  4       pRRR4       R#   + '       g   i     L˜; i  + '       g   i     R# ; i)	Úprojectr   zmultiply(a, 2)Úa2Úb2Nz$cannot Execute non-scalar expressionr;   )r   r   r   )r   r$   r   rL   Úmultiplyr   r%   r4   ÚnamesÚ	to_pylistr=   r>   rB   Úsum)r   r)   r*   rD   s   &   r   Útest_projectrZ   ‰   s²  € ä×$Ò$ØÜ�IÔ1´2·;²;¼uÀS»zÈ1Ó3MÐ2NÓOÓPð&ó €Dð �]‰]‹_€FØ�=‰=×ÑÐ#3Ð"4Ô4Ð4Ð4Ø�!�9×ÑÓ ¢IÔ-Ð-Ð-ô ×$Ò$ØÜ�IÔ1´2·;²;¼uÀS»zÈ1Ó3MÐ2NÐQUÐPVÓWÓXð&ó €Dð �]‰]‹_€FØ�=‰=×Ñ 4 &Ô(Ð(Ð(Ø�$�<×!Ñ!Ó#¢yÔ0Ð0Ð0ô 
�Š”z×	"Õ	"ÜœBŸKšK¬¨c«
°AÓ6Ð7¸$À¸ÔF÷ 
#ô ×$Ò$ØÜ�IÔ1´2·6²6¼%À»*Ó3EÐ2FÓGÓHð&ó €Dô 
�Š”zÐ)O×	PÖ	PØ�M‰M‹Oˆ÷ 
QÑ	P÷ 
#×	"ú÷ 
Q×	PÐ	Pús   Å.HÇ8H&ÈH#	È&H7	c           	      óÚ  € \         P                  ! V \        R \        R.4      4      .4      pVP                  4       pVP                  P
                  R.8X  g   Q hVR,          P                  4       ^.8X  g   Q h\        P                  ! R. RO/4      p\        RR\        P                  ! RR7      R3.4      p\         P                  ! \        R\        V4      4      \        R V4      .4      pVP                  4       pVP                  P
                  R.8X  g   Q hVR,          P                  4       R.8X  g   Q hR\        R4      ^ \        ^ 4      R.\        R4      .^ .3 F‚  p\        VRRR3.4      p\         P                  ! V \        R V4      .4      pVP                  4       pVP                  P
                  R.8X  g   Q hVR,          P                  4       ^.8X  d   K‚  Q h	  \        RR.RRR3.4      p\         P                  ! V \        R V4      .4      p\        P                  ! \        R	R
7      ;_uu_ 4        VP                  4       pRRR4       \        R.4      p\         P                  ! V \        R V4      .4      p\        P                  ! \        RR
7      ;_uu_ 4        VP                  4       pRRR4       R#   + '       g   i     L}; i  + '       g   i     R# ; i)Ú	aggregater   rY   NÚa_sumF)Ú
skip_nullsr   r   z/Function 'sum' accepts 1 arguments but 2 passedr;   zis a hash aggregate function©r   rY   Nr]   ©r   r   N)r   Úhash_sumNr]   )r   r$   r   r%   r4   rW   rX   r   r   rL   ÚScalarAggregateOptionsr   r   r=   r>   rB   )r   r)   r*   r   Ú	aggr_optsÚtargetrD   s   &      r   Útest_aggregate_scalarre   ©   sœ  € Ü×$Ò$ØÜ�KÔ!5Ð7RÐ6SÓ!TÓUð&ó €Dð �]‰]‹_€FØ�=‰=×Ñ 7 )Ô+Ð+Ð+Ø�'�?×$Ñ$Ó&¨1¨#Ô-Ð-Ð-ô �HŠH�cš<Ð(Ó)€EÜ$Ø
ˆu”b×/Ò/¸5ÔAÀ7Ð	KÐLó€Iô ×$Ò$Ü�NÔ$:¸5Ó$AÓBÜ�K Ó+ð&ó €Dð �]‰]‹_€FØ�=‰=×Ñ 7 )Ô+Ð+Ð+Ø�'�?×$Ñ$Ó&¨4¨&Ô0Ð0Ð0ð œ˜c›
 A¤u¨Q£x°#°¼¸s»¸ÀqÀcÓJˆÜ(¨6°5¸$ÀÐ*HÐ)IÓJˆ	Ü×(Ò(Øœ; {°IÓ>Ð?ó
ˆð —‘“ˆØ�}‰}×"Ñ" w iÔ/Ð/Ð/Ø�g�×(Ñ(Ó*¨q¨cÖ1Ð1Ð1ñ Kô %¨¨S z°5¸$ÀÐ&HÐ%IÓJ€IÜ×$Ò$Ø	”{ ;°	Ó:Ð;ó€Dô 
�ŠÜÐK÷
ö 
ð �M‰M‹Oˆ÷
ô %Ð&FÐ%GÓH€IÜ×$Ò$Ø	”{ ;°	Ó:Ð;ó€Dô 
�Š”zÐ)G×	HÖ	HØ�M‰M‹Oˆ÷ 
IÑ	H÷
÷ 
ú÷ 
I×	HÐ	Hús   É KÊ+KËK	ËK*	c                  óH  € \         P                  ! R . ROR. RO/4      p \        V 4      p\        RVR7      p\	        R.R.R	7      p\        P
                  ! V\        R
V4      .4      pVP                  4       p\         P                  ! RRR.R^^./4      pVP                  V4      '       g   Q h\	        R R\        P                  ! R4      R3.R.R	7      p\        P
                  ! V\        R
V4      .4      pVP                  4       p\         P                  ! RRR.R^^./4      pVP                  V4      '       g   Q h\	        R.\        R4      .R	7      p\        P
                  ! V\        R
V4      .4      pVP                  4       pVP                  V4      '       g   Q h\	        R.R.R	7      p\        P
                  ! V\        R
V4      .4      p\        P                  ! \        4      ;_uu_ 4        VP                  4       pRRR4       R#   + '       g   i     R# ; i)r   Nr   ÚfooÚbarr   r   Ú
hash_countúcount(a))Úkeysr\   Úallr`   )rg   rh   rg   )r   ri   Nrj   r_   )r   r   r   r   r   r$   r%   r&   rL   ÚCountOptionsr   r=   r>   rB   )	r   r   r   rc   r)   r*   r8   Úexpected_allrD   s	            r   Útest_aggregate_hashro   Ü   só  € Ü�HŠH�cš<¨Ò.CÐDÓE€EÜ'¨Ó.€JÜ˜~°zÔB€Lô %Ø	.Ð/°s°eô=€Iä×$Ò$Ø”k +¨yÓ9ð&ó €Dð �]‰]‹_€FÜ�xŠx˜˜u e˜n¨j¸1¸a¸&ÐAÓB€HØ�=‰=˜×"Ò"Ð"Ð"ô %Ø
ˆ|œRŸ_š_¨UÓ3°ZÐ	@ÐAÈÈô€Iô ×$Ò$Ø”k +¨yÓ9ð&ó €Dð �]‰]‹_€FÜ—8’8˜S 5¨% .°*¸qÀ!¸fÐEÓF€LØ�=‰=˜×&Ò&Ð&Ð&ô %Ø	.Ð/´u¸S³z°lô€Iô ×$Ò$Ø”k +¨yÓ9ð&ó €Dð �]‰]‹_€FØ�=‰=˜×"Ò"Ð"Ð"ô %Ð&AÐ%BÈ#ÈÔO€IÜ×$Ò$Ø”k +¨yÓ9ð&ó €Dô 
�Š”z×	"Õ	"Ø�M‰M‹Oˆ÷ 
#×	"×	"Ò	"ús   Ç5HÈH!	c                  ót  € \         P                  ! R . ROR. RO/4      p \        R\        V 4      4      p\	        R.4      p\        P
                  ! V\        RV4      .4      pVP                  4       p\         P                  ! R . ROR. RO/4      pVP                  V4      '       g   Q h\	        \        R4      R3.4      p\        P
                  ! V\        RV4      .4      pVP                  4       p\         P                  ! R . ROR. RO/4      pVP                  V4      '       g   Q h\	        R.RR7      p\        P
                  ! V\        RV4      .4      pVP                  4       p\         P                  ! R . ROR. RO/4      pVP                  V4      '       g   Q h\	        . 4      p\        P
                  ! V\        RV4      .4      p\        P                  ! \        RR	7      ;_uu_ 4        VP                  4       pRRR4       \        P                  ! \        R
R	7      ;_uu_ 4        \	        R.4      pRRR4       \        P                  ! \        RR	7      ;_uu_ 4        \	        R.RR7      pRRR4       R#   + '       g   i     L†; i  + '       g   i     L`; i  + '       g   i     R# ; i)r   r   Nr   Úorder_byÚ
descendingÚat_start)Únull_placementz1`ordering` must be an explicit non-empty orderingr;   z&"decreasing" is not a valid sort orderz%"start" is not a valid null placementÚstart)r   r   r   r   )r   r   Nr   )r   Ú	ascending)r   r   r   r   )r   r   r   N)r   r   r   r   )r   r   r   N)r   rr   )r   r   r   r   )Nr   r   r   )r   Ú
decreasing)r   r   r   r   r	   r$   r%   r&   r   r=   r>   rB   )r   r   Úord_optsr)   r*   r8   rD   s          r   Útest_order_byry   
  s   € Ü�HŠH�cš<¨ªoÐ>Ó?€EÜ˜~Ô/EÀeÓ/LÓM€Lä!Ð#5Ð"6Ó7€HÜ×$Ò$ l´KÀ
ÈHÓ4UÐ%VÓW€DØ�]‰]‹_€FÜ�xŠx˜šl¨C²ÐAÓB€HØ�=‰=˜×"Ò"Ð"Ð"ä!¤E¨#£J°Ð#=Ð">Ó?€HÜ×$Ò$ l´KÀ
ÈHÓ4UÐ%VÓW€DØ�]‰]‹_€FÜ�xŠx˜šl¨C²ÐAÓB€HØ�=‰=˜×"Ò"Ð"Ð"ä!Ð#4Ð"5ÀjÔQ€HÜ×$Ò$ l´KÀ
ÈHÓ4UÐ%VÓW€DØ�]‰]‹_€FÜ�xŠx˜šl¨C²ÐAÓB€HØ�=‰=˜×"Ò"Ð"Ð"ô " "Ó%€HÜ×$Ò$ l´KÀ
ÈHÓ4UÐ%VÓW€DÜ	�ŠÜÐM÷
ö 
ð �M‰M‹Oˆ÷
ô
 
�Š”zÐ)S×	TÖ	TÜÐ 3Ð4Ó5ˆ÷ 
Uô 
�Š”zÐ)R×	SÖ	SÜÐ 2Ð3ÀGÔLˆ÷ 
TÑ	S÷
÷ 
ú÷
 
U×	Tú÷ 
T×	SÐ	Sús$   Ç1J È.JÉ'J&Ê J	ÊJ#	Ê&J7	c            	      ót  € \         P                  ! R . ROR. RO/4      p \        R\        V 4      R7      p\         P                  ! R . ROR. RO/4      p\        R\        V4      R7      p\	        RR R R7      p\        RWAV.R7      pVP                  4       p\         P                  ! ^^.^^.^^.^^... ROR	7      pVP                  V4      '       g   Q h\        R 4      R .\        R 4      .3 FH  p\	        RWˆR7      p\        RWAV.R7      pVP                  4       pVP                  V4      '       d   KH  Q h	  \	        R
R R R7      p\        RWAV.R7      pVP                  4       p\         P                  ! . RO. RO. RO. RO.. ROR	7      pVP                  R4      P                  V4      '       g   Q h\	        R
R R RRR7      p\        RWAV.R7      pVP                  4       p\         P                  ! . RO. RO. RO. RO.. ROR	7      pVP                  R4      P                  V4      '       g   Q h\	        R
R R R R.\        R4      .R7      p\        RWAV.R7      pVP                  4       p\         P                  ! . RO. RO. RO.. ROR	7      pVP                  R4      P                  V4      '       g   Q hR# )Úkeyr   r   r   r   Úinner)Ú	left_keysÚ
right_keysÚhashjoinr"   ©rW   ú
left outerNÚ_leftÚ_right)r}   r~   Úoutput_suffix_for_leftÚoutput_suffix_for_right)r}   r~   Úleft_outputÚright_outputr   r   ©r   r   r   ©r{   r   r{   r   )Nr   r   )Nr   r   )Úkey_leftr   Ú	key_rightr   )r{   r   r   )	r   r   r   r   r
   r%   r&   r   Úsort_by)	ÚleftÚleft_sourceÚrightÚright_sourceÚ	join_optsÚjoinedr*   r8   rk   s	            r   Útest_hash_joinr“   /  s˜  € Ü�8Š8�UšI sªIÐ6Ó7€DÜ˜nÔ6LÈTÓ6RÔS€KÜ�HŠH�ešY¨ªYÐ7Ó8€EÜ˜~Ô7MÈeÓ7TÔU€Lô $ G°uÈÔO€IÜØ˜I¸LÐ.IôK€Fà�_‰_Ó€FÜ�xŠxØ
ˆQˆ�!�Q�˜!˜Q˜ ! Q Ð(Ú&ô(€Hð �=‰=˜×"Ò"Ð"Ð"ä�u“ ˜w¬¨u«¨Ó7ˆÜ'¨¸4ÔQˆ	ÜØ 	ÀÐ2MôOˆà—‘Ó"ˆØ�}‰}˜X×&Ô&Ð&Ð&ñ 8ô $Ø °%ô9€IäØ˜I¸LÐ.IôK€Fà�_‰_Ó€FÜ�xŠxÚ	’Iš|ª\Ð:Ú&ô€Hð �>‰>˜#Ó×%Ñ% h×/Ò/Ð/Ð/ô $Ø °%Ø&ÀôJ€Iô Ø˜I¸LÐ.IôK€Fà�_‰_Ó€FÜ�xŠxÚ	’Iš|ª\Ð:Ú1ô€Hð �>‰>˜#Ó×%Ñ% h×/Ò/Ð/Ð/ô $Ø °%Ø˜C�L´°c³
¨|ô=€Iô Ø˜I¸LÐ.IôK€Fà�_‰_Ó€FÜ�xŠxÚ	’Iš|Ð,Úô€Hð �>‰>˜#Ó×%Ñ% h×/Ò/Ð/Ò/r   c                  óÊ  € \         P                  ! R . ROR. RO/4      p \        R\        V 4      R7      p\         P                  ! R . ROR. RO/4      p\        R\        V4      R7      p\	        RR R \
        P                  ! \
        P                  ! R4      ^4      R7      p\        RWAV.R7      pVP                  4       p\         P                  ! ^.^.^.^... ROR	7      pVP                  V4      '       g   Q h\	        R
R R \
        P                  ! \
        P                  ! R4      ^4      \
        P                  ! \
        P                  ! R4      ^
4      ,          R7      p\        RWAV.R7      pVP                  4       p\         P                  ! . RO. RO. RO. RO.. ROR	7      pVP                  V4      '       g   Q h\
        P                  ! R4      p\	        RR R VR7      p\        RWAV.R7      pVP                  4       p\         P                  ! ^^.^^.^^.^^... ROR	7      pVP                  V4      '       g   Q h\
        P                  ! R4      p	\	        RR R V	R7      p\        RWAV.R7      pVP                  4       p\         P                  ! \         P                  ! . \         P                  ! 4       R7      \         P                  ! . \         P                  ! 4       R7      \         P                  ! . \         P                  ! 4       R7      \         P                  ! . \         P                  ! 4       R7      .. ROR	7      pVP                  V4      '       g   Q hR# )r{   r   r   r   r   r|   )r}   r~   Úfilter_expressionr   r"   r€   r�   NTF)rN   r   r   rˆ   r‰   )r   r   r   )r   r   r   )r   NN)r   NN)r   r   r   r   r
   rL   Úequalr   r%   r&   ÚscalarrA   r5   )
r�   rŽ   r�   r�   r‘   r’   r*   r8   Úalways_trueÚalways_falses
             r   Ú#test_hash_join_with_residual_filterrš   m  sÂ  € Ü�8Š8�UšI sªIÐ6Ó7€DÜ˜nÔ6LÈTÓ6RÔS€KÜ�HŠH�ešY¨ªYÐ7Ó8€EÜ˜~Ô7MÈeÓ7TÔU€Lä#Ø˜5¨UÜŸ(š(¤2§8¢8¨C£=°!Ó4ô6€Iô Ø˜I¸LÐ.IôK€Fà�_‰_Ó€FÜ�xŠxØ
ˆˆqˆc�A�3˜˜ÐÚ&ô(€Hð �=‰=˜×"Ò"Ð"Ð"ô $Ø °%ÜŸ(š(¤2§8¢8¨C£=°!Ó4´r·x²xÄÇÂÈÃÈrÓ7RÕRô€Iô Ø˜I¸LÐ.IôK€Fà�_‰_Ó€FÜ�xŠxÚ	’Iš²Ð@Ú&ô(€Hð �=‰=˜×"Ò"Ð"Ð"ô —)’)˜D“/€KÜ#Ø˜5¨UØ%ô'€Iô Ø˜I¸LÐ.IôK€Fà�_‰_Ó€FÜ�xŠxØ
ˆQˆ�!�Q�˜!˜Q˜ ! Q Ð(Ú&ô€Hð �=‰=˜×"Ò"Ð"Ð"ô —9’9˜UÓ#€LÜ#Ø˜5¨UØ&ô(€Iô Ø˜I¸LÐ.IôK€Fà�_‰_Ó€FÜ�xŠxä�HŠH�RœbŸhšh›jÔ)Ü�HŠH�RœbŸhšh›jÔ)Ü�HŠH�RœbŸhšh›jÔ)Ü�HŠH�RœbŸhšh›jÔ)ð		
ò 'ô€Hð �=‰=˜×"Ò"Ð"Ò"r   c            
      óv  € \         P                  ! R . ROR. ROR. RO/4      p \        R\        V 4      R7      p\         P                  ! R . ROR. ROR. RO/4      p\        R\        V4      R7      p\	        RR .RR .^R7      p\        RWAV.R7      pVP                  4       p\         P                  ! . RO. RO. RO. RO.. ROR
7      pWg8X  g   Q h\        R 4      R .\        R 4      .3 FL  p\        R4      R3 F8  p	\	        W˜W˜^R7      p\        RWAV.R7      pVP                  4       pWg8X  d   K8  Q h	  KN  	  R	# )r{   Útsr   r   r   r   )Úleft_onÚleft_byÚright_onÚright_byÚ	toleranceÚasofjoinr"   Nr€   r   )r   r   r   r   rˆ   )r   r   r   )Nr   N)r{   rœ   r   r   )r   r   r   r   r   r%   r   )
r�   rŽ   r�   r�   r‘   r’   r*   r8   ÚbyÚons
             r   Útest_asof_joinr¥   ­  s:  € Ü�8Š8�UšI tªY¸ºYÐGÓH€DÜ˜nÔ6LÈTÓ6RÔS€KÜ�HŠH�ešY¨ªi¸ºiÐHÓI€EÜ˜~Ô7MÈeÓ7TÔU€Lô $Ø˜u˜gØ  Øô€Iô
 Ø˜I¸LÐ.Iô€Fð �_‰_Ó€FÜ�xŠxÚ	’Išyª/Ð:Ú%ô'€Hð ÔÐÐä�U‹|˜e˜W¤u¨U£| nÓ5ˆÜ˜“; Ó%ˆBÜ+ØØØôˆIô
 !Ø IÀLÐ6QôSˆFà—_‘_Ó&ˆFØÖ%Ð%Ð%ó &ó 6r   c           	      ó  € \         P                  ! R . R
OR. RO/4      p\        P                  ! WR,          RR7       \        P                  ! V R,          RR7      p\        R\        V4      4      pVP                  4       pVP                  P                  . RO8X  g   Q hVP                  R R.4      P                  V4      '       g   Q h\        V\        R 4      ^8„  R7      p\        RV4      pVP                  4       P                  ^8X  g   Q h\        V\        R 4      ^8„  R7      p\        RV4      pVP                  4       P                  ^ 8X  g   Q h\        VR\        P                  ! \        R 4      ^4      /R7      p\        RV4      pVP                  4       pVR ,          P!                  4       . R
O8X  g   Q h\        P"                  ! VR,          P%                  4       4      P'                  4       '       g   Q hR	# )r   r   ÚdatasetÚparquet)ÚformatÚscan)r!   rT   )ÚcolumnsNr   r   )r   r   Ú__fragment_indexÚ__batch_indexÚ__last_in_fragmentÚ
__filename)r   r   ÚdsÚwrite_datasetr§   r   r   r%   r4   rW   Úselectr&   r   rM   rL   rV   rX   rl   Úis_nullÚas_py)Útempdirr   r§   r)   r*   Ú	scan_optss   &     r   Ú	test_scanr·   Ï  sœ  € ä�HŠH�cš9 cª9Ð5Ó6€EÜ×Ò�U iÕ/¸	ÕBÜ�jŠj˜ 9Õ,°YÔ?€GÜ�vœ¨wÓ7Ó8€DØ�]‰]‹_€FØ�=‰=×Ñò #ô ð ð ð �=‰=˜#˜s˜Ó$×+Ñ+¨E×2Ò2Ð2Ð2ô   ´°c³
¸Q±Ô?€IÜ�v˜yÓ)€Dà�=‰=‹?×#Ñ# qÔ(Ð(Ð(ä ´°c³
¸Q±Ô?€IÜ�v˜yÓ)€Dà�=‰=‹?×#Ñ# qÔ(Ð(Ð(ô   °$¼¿ºÄEÈ#ÃJÐPQÓ8RÐ1SÔT€IÜ�v˜yÓ)€DØ�]‰]‹_€Fà�#�;× Ñ Ó"¢iÔ/Ð/Ð/ä�6Š6�&˜•+×%Ñ%Ó'Ó(×.Ñ.×0Ò0Ð0Ò0r   r   )+r=   Úpyarrowr   Úpyarrow.computeÚcomputerL   r   Úpyarrow.aceror   r   r   r   r   r	   r
   r   ÚImportErrorÚpyarrow.datasetr§   r°   r   ÚmarkÚaceroÚ
pytestmarkÚfixturer   r,   r1   r9   rE   rH   Úparametrizer@   r   rQ   rZ   re   ro   ry   r“   rš   r¥   r·   © r   r   Ú<module>rÄ      s3  ðó$ ã Ý Ý !ð	÷	÷ 	ó 	ðÝ Ý-ð �[‰[×Ñ€
ð ‡�ñó ðò,ò*3ò#ò	ò ð  ‡�×Ñ˜Ø‡O‚O�XšyÐ)Ó*Ø‡H‚Hˆhš	Ð"Ó#ð$ó ñ4ó	ð4òò@0òf+ò\"MòJ;0ò|=#ò@&ðD ‡�×Ññ 1ó ò 1øð[ ô 	Ùð	ûð ô Ø	‚Bðús"   –C- «C: Ã-C7Ã6C7Ã:	DÄD