Ë
    ^Qê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 ej                  d«      “dd“dd“dd“d ej                  d«      “d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# 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 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 d/lm!Z! ded!<   	 d d0lm"Z" ded<   	 d dl#Zded%<   d1„ Z$ e jJ                  d¬2«      d3„ «       Z& e jJ                  d¬2«      d4„ «       Z' e jJ                  d5¬6«      d7„ «       Z( e jJ                  d5¬6«      d8„ «       Z) e jJ                  d5¬6«      d9„ «       Z*y# e$ r Y �Œfw xY w# 1 sw Y   �Œ>xY w# e$ r Y �ŒDw xY w# e$ r Y �ŒFw xY w# e$ r Y �ŒHw xY w# e$ r Y �Œ2w xY w# e$ r	 ded<   Y �Œ9w xY w# e$ r	 ded<   Y �Œ@w xY w# e$ r Y �ŒBw xY w# e$ r Y �ŒDw xY w# e$ r Y �ŒFw xY w# e$ r Y �ŒFw xY w# e$ r Y �ŒFw xY w# e$ r Y �ŒFw xY w# e$ r Y �ŒFw xY w# e$ r Y �ŒHw xY w):é    N)ÚCodec)Úfs)Úis_threading_enabled)!ÚaceroÚazureÚbrotliÚbz2ÚcythonÚdatasetÚ
hypothesisÚ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   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    úU/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/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-   r2   Úgetattr)Úcollection_pathÚconfigr5   Údoctest_groupsÚgroupr-   s         r4   Úpytest_ignore_collectrA   Ô   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)Nr6   FÚtmpdir)r>   r7   r8   r<   ÚgetfixturevalueÚas_cwd)ÚrequestÚ	doctest_mÚ	doctest_crD   s       r4   Ú_docdirrJ   	  sy   è ø€ ð —‘×%Ñ%×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)	Nr6   Fr   zpyarrow-fs-example.dats   dataÚlocalÚ
local_pathÚpath)	r>   r7   r8   r<   r   ÚLocalFileSystemÚopen_output_streamr9   Úwrite)Údoctest_namespacerG   Útmp_pathrH   rI   rL   rN   Ústreams           r4   Úadd_fsrU     sÁ   è ø€ ð —‘×%Ñ%×4Ñ4€IÜ˜Ÿ™×-Ñ-Ð/?ÀÓG€Iá‘Iä"$Ð˜$Ñô ×"Ñ"Ó$ˆØÐ2Ñ2ˆØ×%Ñ%¤c¨$£iÓ0ð 	"°FØ�L‰L˜Ô!÷	"à%*Ð˜'Ñ"Ü*-¨h«-Ð˜,Ñ'Ü$'¨£IÐ˜&Ñ!Ü	÷	"ð 	"ü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     €r4   Úunary_functionz*unary_func_fixture.<locals>.unary_function<  s*   ø€ Ø×Ñ ¨¨1 vØ,/¯O©Oð  ó =ð 	=ó    zy=x+1zadd functionztest add function©ÚsummaryÚdescriptionÚarray)r3   rZ   Úregister_scalar_functionÚpaÚint64)rc   Ú	func_nameÚ	unary_docrb   s      @r4   Úunary_func_fixturern   5  s[   ø€ õ
 &ô=ð €IØ*Ø 3ñ5€Ià×Ñ Ø )Ø )Ø!(¬"¯(©(«*Ð 5Ü "§¡£
ô	,ð
 ˜9Ð$Ð$rd   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   rY   Nc                 óL   •— t        j                  ‰j                  |«      «      S )N)rj   ÚscalarÚnanmean)r`   ra   Únps     €r4   Úfuncz$unary_agg_func_fixture.<locals>.funcR  s   ø€ Ü�y‰y˜Ÿ™ A›Ó'Ð'rd   Úmean_udfzy=avg(x)zfind mean of xre   ra   )r3   rZ   r   Úregister_aggregate_functionrj   Úfloat64©rb   rt   rl   Úfunc_docrs   s       @r4   Úunary_agg_func_fixturerz   J  sc   ø€ õ
 &Ûô(ð €IØ%Ø/ñ1€Hð ×"Ñ" 4Ø#,Ø#+à'*¬B¯J©J«Lð$%ô $&§:¡:£<ô%ð �ˆ?Ðrd   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   rY   Nc                 óh   •— d}|D ]  }|‰j                  |«      z  }Œ t        j                  |«      S )Ng        )rr   rj   rq   )r`   ÚargsÚsumÚargrs   s       €r4   rt   z&varargs_agg_func_fixture.<locals>.funcl  s7   ø€ ØˆØò 	#ˆCØ�2—:‘:˜c“?Ñ"‰Cð	#ä�y‰y˜‹~Ðrd   Úsum_meanzVarargs aggregatere   )ra   Úy)r3   rZ   r   rv   rj   rk   rw   rx   s       @r4   Úvarargs_agg_func_fixturer‚   d  sj   ø€ õ
 &Ûôð €IØ.Ø2ñ4€Hð ×"Ñ" 4Ø#,Ø#+ä,.¯H©H«JÜ,.¯J©J«Lñ$%ô $&§:¡:£<ô%ð �ˆ?Ðrd   )+ÚpytestÚosr3   rj   r   r   Úpyarrow.libr   ÚsysÚgroupsÚis_availabler:   ÚplatformrN   Úexistsr
   r2   Ú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.substraitrA   ÚfixturerJ   rU   rn   rz   r‚   © rd   r4   ú<module>r™      s‘  ðó$ ã 	Û Ý Ý Ý ,Û 
ò"
€ðH"ØˆUð"àˆUð"ð Ð ˆe× Ñ  Ó*ð"ð 
Ðˆ5×Ñ˜eÓ$ð	"ð
 ˆeð"ð ˆuð"ð ˆeð"ð ˆuð"ð 
ˆ5ð"ð 
ˆ4ð"ð ÐˆE×Ñ˜vÓ&ð"ð ˆEð"ð �%ð"ð �Eð"ð 
Ðˆ5×Ñ˜eÓ$ð"ð  �5ð!"ð" �ñ#"ð$ ˆuð%"ð& ˆUð'"ð( 
ˆ5ð)"ð* ˆeð+"ð, ˆuð-"ð. ˜%ð/"ð0 �ð1"ð2 ˜Tð3"ð4 	ˆ%ð5"ð6 ˆEð7"ð8 Ð ˆe× Ñ  Ó*ð9"ð: ˆtð;"ð< �ð="ð> Ñ%Ó'ð?"ð@ �TðA"ðB ÐˆE×Ñ˜vÓ&ñC"€ðH ‡<�<�<Òð €HˆU�OØ!€Hˆ[ÑØ€HˆYÑà‡<�<�<ÒØ "§¡§¡Ð/DÓ E€Hˆ_Ñð	ÛØ€HˆXÑð	ÛØ	 ˆ×	 Ñ	 Ó	"ñ Øˆ×Ñ˜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Ô ñó !ñøðg ò 	Úð	ú÷
ñ ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò  Ø€HˆZÔð ûð ò Ø€HˆYÔðûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ûð ò 	Úð	ús&  Ä?	J& Å	J? ÅJ2Å6J? Æ	K Æ	K Æ!K# Æ:	K/ Ç	L  Ç	L Ç	L Ç"	L) Ç,L5 Ç8M ÈM ÈM È	M% Ê&J/Ê.J/Ê2J<Ê7J? Ê?KËKËKËKËK ËK Ë#K,Ë+K,Ë/
K=Ë<K=Ì 
LÌLÌLÌLÌL&Ì%L&Ì)L2Ì1L2Ì5L>Ì=L>ÍM
Í	M
ÍMÍMÍM"Í!M"Í%M.Í-M.