Ë
    ¿š§j°(  ã                   ó  — d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlZg d¢Z	i dd“dd“d	 ej                  d	«      “d
 ej                  d
«      “dd“dd“dd“dd“dd“dd“dd“d ej                  d«      “dd“dd“dd“d ej                  d«      “dd“i dd“dd“dd“dd“dd“dd“dd“d d“d!d“d"d“d#d“d$ ej                  d$«      “d%d“d&d“d' e«       “d(d“d) ej                  d)«      “¥Zej                  d*k(  rded<   ded <   ded%<   ej                  d*k(  rej                  j                  d+«      ed(<   	 d dlZded<   	 d dlZded<   	 d dlZ ej&                  «       5   ej(                  d,e«       d dlZddd«       ded<   	 d dlZded<   	 d dlZded<   	 d dlZej                  d-k(  rded<   ned(   ed<   	 d dlZded<   	 d dlZded<   	 d dlZded<   	 d dlZded<   	 d dlZded<   	 d d.lm Z  ded<   	 d d/lm!Z! ded<   	 d d0lm"Z" ded"<   	 d d1lm#Z# ded<   	 d dl$Zded&<   d2„ Z% e jL                  d¬3«      d4„ «       Z' e jL                  d¬3«      d5„ «       Z( e jL                  d6¬7«      d8„ «       Z) e jL                  d6¬7«      d9„ «       Z* e jL                  d6¬7«      d:„ «       Z+y# e$ r Y �Œpw xY w# e$ r Y �Œrw xY w# 1 sw Y   �ŒJxY w# e$ r Y �ŒPw xY w# e$ r Y �ŒRw xY w# e$ r Y �ŒTw xY w# e$ r Y �Œ>w xY w# e$ r	 ded<   Y �ŒEw xY w# e$ r	 ded<   Y �ŒLw xY w# e$ r Y �ŒNw xY w# e$ r Y �ŒPw xY w# e$ r Y �ŒRw xY w# e$ r Y �ŒRw xY w# e$ r Y �ŒRw xY w# e$ r Y �ŒRw xY w# e$ r Y �ŒRw xY w# e$ r Y �ŒTw xY w);é    N)ÚCodec)Úfs)Úis_threading_enabled)"ÚaceroÚazureÚbrotliÚbz2ÚcythonÚdatasetÚ
hypothesisÚfastparquetÚflightÚgandivaÚgcsÚgdbÚgzipÚhdfsÚlarge_memoryÚlz4Úmemory_leakÚnopandasÚnonumpyÚnumpyÚorcÚpandasÚparquetÚparquet_encryptionÚ	processesÚrequires_testing_dataÚs3ÚslowÚsnappyÚsocketsÚ	substraitÚ	threadingÚtimezone_dataÚzstdr   Fr   r   r	   r
   r   r   r   r   r   r   Tr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r    r!   r"   r#   r$   r%   r&   r'   Ú
emscriptenz/usr/share/zoneinfoÚignoreÚwin32)ÚAzureFileSystem)ÚGcsFileSystem©ÚS3FileSystem)ÚHadoopFileSystemc                 óÐ  — d„ }|j                   j                  rvdt        | «      v ryg d¢}|D ]  }d|› �t        | «      v sŒt        |   rŒ y dt        | «      v r
t        d   sydt        | «      v r |«        S d	t        | «      v r	 d
dlm} yt        |j                   dd«      r1dt        | «      v rydt        | «      v rydt        | «      v r |«        S y# t        $ r Y yw xY w)Nc                  ó,   — 	 dd l } y# t        $ r Y yw xY w)Nr   TF)Úpyarrow.cudaÚImportError)Úpyarrows    úSC:\Users\Luka\AppData\Local\Temp\pip-target-o84fipzb\lib\python\pyarrow/conftest.pyÚ_cuda_is_availablez1pytest_ignore_collect.<locals>._cuda_is_availableÝ   s   € ð	ÛØøÜò 	Ùð	ús   ‚ ‡	’z/pyarrow/tests/T)r   r   r   r   r$   zpyarrow/zpyarrow/parquet/encryptionr   zpyarrow/cudaz
pyarrow/fsr   r-   FÚdoctest_cythonz/pyarrow/_parquet_encryptionz/pyarrow/_cuda)ÚoptionÚdoctestmodulesÚstrÚdefaultsÚ
pyarrow.fsr.   r3   Úgetattr)Úcollection_pathÚconfigr6   Údoctest_groupsÚgroupr.   s         r5   Úpytest_ignore_collectrB   Ü   s  € òð ‡}�}×#Ò#à¤ OÓ 4Ñ4Øò
ˆó $ˆEØ˜%˜Ð!¤S¨Ó%9Ò9Ü “Ùð $ð
 (¬3¨Ó+?Ñ?ÜÐ0Ò1ØàœS Ó1Ñ1Ù)Ó+Ð+Ð+àœ3˜Ó/Ñ/ðÝ3Øô ˆv�}‰}Ð.°Ô6Ø¤ OÓ 4Ñ4ØØ)¬S°Ó-AÑAØØœs ?Ó3Ñ3Ù)Ó+Ð+Ð+àøô ò Ùðús   Â	C Ã	C%Ã$C%)Úautousec              #   ó  K  — | j                   j                  j                  }t        | j                   j                  dd«      }|s|r/| j	                  d«      }|j                  «       5  d –— d d d «       y d –— y # 1 sw Y   y xY w­w)Nr7   FÚtmpdir)r?   r8   r9   r=   ÚgetfixturevalueÚas_cwd)ÚrequestÚ	doctest_mÚ	doctest_crE   s       r5   Ú_docdirrK     sn   è ø€ ð —‘×%Ñ%×4Ñ4€IÜ˜Ÿ™×-Ñ-Ð/?ÀÓG€Iá‘Ið ×(Ñ(¨Ó2ˆð �]‰]�_Û÷ ˆ_ô 	÷	 ˆ_üs   ‚A'BÁ)A<Á.BÁ<BÂBc              #   ó¤  K  — |j                   j                  j                  }t        |j                   j                  dd«      }|s|rwt        | d<   t	        j
                  «       }|dz  }|j                  t        |«      «      5 }|j                  d«       d d d «       || d<   t        |«      | d<   t        |«      | d<   d –— y # 1 sw Y   Œ/xY w­w)	Nr7   Fr   zpyarrow-fs-example.dats   dataÚlocalÚ
local_pathÚpath)	r?   r8   r9   r=   r   ÚLocalFileSystemÚopen_output_streamr:   Úwrite)Údoctest_namespacerH   Útmp_pathrI   rJ   rM   rO   Ústreams           r5   Úadd_fsrV   &  sº   è ø€ ð —‘×%Ñ%×4Ñ4€IÜ˜Ÿ™×-Ñ-Ð/?ÀÓG€Iá‘Iä"$Ð˜$Ñô ×"Ñ"Ó$ˆØÐ2Ñ2ˆØ×%Ñ%¤c¨$£iÔ0°FØ�L‰L˜Ô!÷ 1à%*Ð˜'Ñ"Ü*-¨h«-Ð˜,Ñ'Ü$'¨£IÐ˜&Ñ!Ü	÷ 1Ð0üs   ‚BCÂCÂ.CÃCÃ	CÚsession)Úscopec                  ó¦   ‡— ddl mŠ ˆfd„} d}dddœ}‰j                  | ||dt        j                  «       it        j                  «       «       | |fS )	z+
    Register a unary scalar function.
    r   ©Úcomputec                 óD   •— ‰j                  d|dg| j                  ¬«      S )NÚaddé   )Úmemory_pool)Úcall_functionr_   )ÚctxÚxÚpcs     €r5   Úunary_functionz*unary_func_fixture.<locals>.unary_functionD  s*   ø€ Ø×Ñ ¨¨1 vØ,/¯O©Oð  ó =ð 	=ó    zy=x+1zadd functionztest add function©ÚsummaryÚdescriptionÚarray)r4   r[   Úregister_scalar_functionÚpaÚint64)rd   Ú	func_nameÚ	unary_docrc   s      @r5   Úunary_func_fixturero   =  s[   ø€ õ
 &ô=ð €IØ*Ø 3ñ5€Ià×Ñ Ø )Ø )Ø!(¬"¯(©(«*Ð 5Ü "§¡£
ô	,ð
 ˜9Ð$Ð$re   c                  ó®   ‡— ddl m}  ddlŠˆfd„}d}dddœ}| j                  |||d	t	        j
                  «       it	        j
                  «       «       ||fS )
z4
    Register a unary aggregate function (mean)
    r   rZ   Nc                 óL   •— t        j                  ‰j                  |«      «      S )N)rk   ÚscalarÚnanmean)ra   rb   Únps     €r5   Úfuncz$unary_agg_func_fixture.<locals>.funcZ  s   ø€ Ü�y‰y˜Ÿ™ A›Ó'Ð're   Úmean_udfzy=avg(x)zfind mean of xrf   rb   )r4   r[   r   Úregister_aggregate_functionrk   Úfloat64©rc   ru   rm   Úfunc_docrt   s       @r5   Úunary_agg_func_fixturer{   R  sc   ø€ õ
 &Ûô(ð €IØ%Ø/ñ1€Hð ×"Ñ" 4Ø#,Ø#+à'*¬B¯J©J«Lð$%ô $&§:¡:£<ô%ð �ˆ?Ðre   c                  óÔ   ‡— ddl m}  ddlŠˆfd„}d}dddœ}| j                  |||t	        j
                  «       t	        j                  «       dœt	        j                  «       «       ||fS )	z-
    Register a unary aggregate function
    r   rZ   Nc                 óh   •— d}|D ]  }|‰j                  |«      z  }Œ t        j                  |«      S )Ng        )rs   rk   rr   )ra   ÚargsÚsumÚargrt   s       €r5   ru   z&varargs_agg_func_fixture.<locals>.funct  s2   ø€ ØˆÛˆCØ�2—:‘:˜c“?Ñ"‰Cð ä�y‰y˜‹~Ðre   Úsum_meanzVarargs aggregaterf   )rb   Úy)r4   r[   r   rw   rk   rl   rx   ry   s       @r5   Úvarargs_agg_func_fixturerƒ   l  sj   ø€ õ
 &Ûôð €IØ.Ø2ñ4€Hð ×"Ñ" 4Ø#,Ø#+ä,.¯H©H«JÜ,.¯J©J«Lñ$%ô $&§:¡:£<ô%ð �ˆ?Ðre   ),ÚpytestÚosr4   rk   r   r   Úpyarrow.libr   ÚsysÚgroupsÚis_availabler;   ÚplatformrO   Úexistsr
   r3   r   ÚwarningsÚcatch_warningsÚsimplefilterÚFutureWarningÚpyarrow.gandivaÚpyarrow.aceroÚpyarrow.datasetÚpyarrow.orcr   r   Úpyarrow.parquetÚpyarrow.parquet.encryptionÚpyarrow.flightr<   r+   r,   r.   r/   Úpyarrow.substraitrB   ÚfixturerK   rV   ro   r{   rƒ   © re   r5   Ú<module>rš      s½  ðó$ ã 	Û Ý Ý Ý ,Û 
ò#
€ðJ#ØˆUð#àˆUð#ð Ð ˆe× Ñ  Ó*ð#ð 
Ðˆ5×Ñ˜eÓ$ð	#ð
 ˆeð#ð ˆuð#ð �5ð#ð ˆeð#ð ˆuð#ð 
ˆ5ð#ð 
ˆ4ð#ð ÐˆE×Ñ˜vÓ&ð#ð ˆEð#ð �%ð#ð �Eð#ð  
Ðˆ5×Ñ˜eÓ$ð!#ð" �5ñ##ð$ �ð%#ð& ˆuð'#ð( ˆUð)#ð* 
ˆ5ð+#ð, ˆeð-#ð. ˆuð/#ð0 ˜%ð1#ð2 �ð3#ð4 ˜Tð5#ð6 	ˆ%ð7#ð8 ˆEð9#ð: Ð ˆe× Ñ  Ó*ð;#ð< ˆtð=#ð> �ð?#ð@ Ñ%Ó'ðA#ðB �TðC#ðD ÐˆE×Ñ˜vÓ&ñE#€ðJ ‡<�<�<Òð €HˆU�OØ!€Hˆ[ÑØ€HˆYÑà‡<�<�<ÒØ "§¡§¡Ð/DÓ E€Hˆ_Ñð	ÛØ€HˆXÑð	ÛØ"€Hˆ]Ñð	ÛØ	 ˆ×	 Ñ	 Õ	"Øˆ×Ñ˜h¨Ô6Û÷ 
#ð €HˆYÑð	ÛØ€HˆWÑð	ÛØ€HˆYÑð
	ÛØ
‡|�|�wÒØˆ�Šð
 # ?Ñ3ˆ�‰ð ÛØ€HˆXÑðÛØ€HˆWÑð	ÛØ€HˆYÑð	Û%Ø%)€HÐ!Ñ"ð	ÛØ€HˆXÑð	Ý*Ø€HˆWÑð	Ý(Ø€HˆU�Oð	Ý'Ø€HˆT�Nð	Ý+Ø€HˆVÑð	ÛØ €Hˆ[Ñò1ðj €‡�˜Ôñó ðð( €‡�˜Ôñ
ó ð
ð, €‡��iÔ ñ%ó !ð%ð( €‡��iÔ ñó !ðð2 €‡��iÔ ñó !ñøðs ò 	Úð	ûð ò 	Úð	ú÷
 
#Ñ	"ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò  Ø€HˆZÔð ûð ò Ø€HˆYÔðûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ús8  Å	J3 Å	J? ÅK Å+KÆK Æ	K$ Æ	K0 Æ%!K< Ç	L Ç	L Ç	L* Ç%	L6 Ç/	M Ç9M ÈM ÈM& ÈM2 È)	M> Ê3J<Ê;J<Ê?KËKËKËK ËK!Ë K!Ë$K-Ë,K-Ë0K9Ë8K9Ë<LÌLÌ
LÌLÌ
L'Ì&L'Ì*L3Ì2L3Ì6L?Ì>L?ÍMÍ
MÍMÍMÍM#Í"M#Í&M/Í.M/Í2M;Í:M;Í>NÎN