archive.git - Gitblit

Ë  
oñúhÏãóXdZddlZddlmZddlmZddlZddlZddlZ    ddl
Z
ddlmZm Z ddlmZddlmZddlmZmZmZmZmZddlZddlmZdd    lmZdd
lm Z m!Z!m"Z"m#Z#m$Z$    ddl%Z%dZ&    ddl(Z(dZ)e
jTjWd «e
jTjWd«gZ,e
jZe
j\de
jTj_e)xs edd¬«dk(d¬«e
jTjae «dd¬«g¬«e
j\de
jTj_e&d¬«¬«g¬«d«Z1e
jZd«Z2e
jZd«Z3e
jZd«Z4e
jZd«Z5e
jZd «Z6e
jZejjoejpjr«ejjoejpjt«ejjoejpjv«ejjyd!d"«ejjyd#d"«ejjyd$d"«ejjyd%d"«g¬«d&«Z=                                    d:d'Z>d(Z?d)Z@d*ZAd+ZBd,ZCd-ZDd.ZEd/ZFd0ZGd1ZHGd2d3«ZIGd4d5eI«ZJGd6d7eI«ZKGd8d9eI«ZLy#e'$rdZ&Y°wxYw#e'$rdZ)Y·wxYw);z test parquet compat éN)ÚDecimal)ÚBytesIO)Úusing_copy_on_writeÚusing_string_dtype)Ú_get_option)Úis_platform_windows)Úpa_version_under11p0Úpa_version_under13p0Úpa_version_under15p0Úpa_version_under19p0Úpa_version_under20p0)ÚVersion)ÚFastParquetImplÚPyArrowImplÚ
get_engineÚread_parquetÚ
to_parquetTFz2ignore:DataFrame._data is deprecated:FutureWarningz=ignore:Passing a BlockManager to DataFrame:DeprecationWarningÚfastparquetúmode.data_manager©ÚsilentÚarrayz4fastparquet is not installed or ArrayManager is used©ÚreasonúTODO(infer_string) fastparquet©rÚstrict©ÚmarksÚpyarrowúpyarrow is not installed)Úparamscó|jS©N©Úparam©Úrequests úOH:\Change_password\venv_build\Lib\site-packages\pandas/tests/io/test_parquet.pyÚenginer*@sð4==Ðócó:tstjd«y)Nr!r )Ú _HAVE_PYARROWÚpytestÚskip©r+r)Úpar1]såÜÐ.Ô/Ør+cóútstjd«n%tdd¬«dk(rtjd«t    «r0|jtjjdd¬    ««y
)Nzfastparquet is not installedrTrrz.ArrayManager is not supported with fastparquetrFrr)Ú_HAVE_FASTPARQUETr.r/rrÚapplymarkerÚmarkÚxfailr's r)Úfpr7ds`åÜÐ2Õ3Ü    Ð(°Ô    6¸'Ò    AÜÐDÔEÜÔØ×ÑÜKK×ÑÐ%EÈeÐÓTô    
ðr+códtjgd¢ddtjddg«¬«S)N©éééÚfoo©ÚAÚBr?r@©Úcolumns)ÚpdÚ    DataFrameÚIndexr0r+r)Ú    df_compatrFqs%ä <<i¨eÑ4¼b¿h¹hÈÈSÀzÓ>RÔSÐSr+c
óÎtjtd«ttdd««t    j
ddd¬«gd¢tjd    d
¬«d«}|S) NÚabcr:éç@ç@Úfloat64©Údtype©TFTÚ20130101r<©Úperiods)ÚaÚbÚdÚeÚf)rCrDÚlistÚrangeÚnpÚarangeÚ
date_range)Údfs r)Údf_cross_compatr^vsRä    äeÜeAqkÓ"ä3 ¨9Ô5Ú$Üz°1Ô5ñ 
    
ó
BðIr+cóÜtjtd«dtjdggd¢gd¢gd¢ttdd««tjd    d
«jd«tjdd d¬«dtjdggd¢tjdd    ¬«tjd«tjtjd«gd«S)NrHrSÚc©rSNr`)ófooóbarsbaz©r=ÚbarÚbazr:rIr<éÚu1rJrKrLrMç@ç@rOrPrQÚ20130103)ÚstringÚstring_with_nanÚstring_with_noneÚbytesÚunicodeÚintÚuintÚfloatÚfloat_with_nanÚboolÚdatetimeÚdatetime_with_nat)rCrDrXrZÚnanrYr[Úastyper\Ú    TimestampÚNaTr0r+r)Údf_fullr|s¯ä <<ä5kØ #¤R§V¡V¨SÐ1Ú 0Ú-Ú,Üa Ó$ÜIIa O×*Ñ*¨4Ó0ÜYYs C¨yÔ9Ø"¤B§F¡F¨CÐ0Ú'Ü   j¸!Ô<äZÓ(ÜÜZÓ(ð"ñ    
óðr+z2019-01-04T16:41:24+0200z%Y-%m-%dT%H:%M:%S%zz2019-01-04T16:41:24+0215z2019-01-04T16:41:24-0200z2019-01-04T16:41:24-0215có|jSr$r%r's r)Útimezone_aware_date_listr~ sð==Ðr+c
óàxsddixsi|r
|d<|d<fd}
&tj«5|
|    «ddd«y|
|    «y#1swYyxYw)aVerify parquet serializer and deserializer produce the same results.
 
    Performs a pandas to disk and disk to pandas round trip,
    then compares the 2 resulting DataFrames to verify equality.
 
    Parameters
    ----------
    df: Dataframe
    engine: str, optional
        'pyarrow' or 'fastparquet'
    path: str, optional
    write_kwargs: dict of str:str, optional
    read_kwargs: dict of str:str, optional
    expected: DataFrame, optional
        Expected deserialization result, otherwise will be equal to `df`
    check_names: list of str, optional
        Closed set of column names to be compared
    check_like: bool, optional
        If True, ignore the order of index & columns.
    repeat: int, optional
        How many times to repeat the test
    ÚcompressionNr*có¾t|«D]N}jfi
¤tfi    ¤}dvrdjd<t    j
|¬«Py)Nrm©r:rm)Úcheck_namesÚ
check_likeÚcheck_dtype)rYrrÚlocÚtmÚassert_frame_equal)ÚrepeatÚ_Úactualrrrr]ÚexpectedÚpathÚread_kwargsÚwrite_kwargss   r)Úcomparez!check_round_trip.<locals>.compareÛsløÜvò    AØBMM$Ñ/ ,Ò/Ü! $Ñ6¨+Ñ6Fà  HÑ,Ø59Ð1Ñ2Ü×!Ñ!ØØØ'Ø%Ø'ö ñ     r+)rÚensure_clean)r]r*rrrrrrrrrs` ```````  r)Úcheck_round_tripr¯sÿðD Ò8 M°4Ð#8LØÒ# KàÐØá Ø!'XÑØ &HÑ÷ ó ð|Ü __Ó ð     $ÙFO÷    ð    ñ    ÷    ð    úsÁ        A$Á$A-códdlm}|j|d¬«}|jjj|k(sJy)zÂCheck partitions of a parquet file are as expected.
 
    Parameters
    ----------
    path: str
        Path of the dataset.
    expected: iterable of str
        Expected partition names.
    rNÚhive)Úpartitioning)Úpyarrow.datasetÚdatasetrÚschemaÚnames)rrÚdsrs    r)Úcheck_partition_namesrñs9õ!àjj¨FjÓ3GØ×Ñ×&Ñ&×,Ñ,°Ò8Ð8Ñ8r+cód}tjt|¬«5t|dd«ddd«y#1swYyxYw)Nz.engine must be one of 'pyarrow', 'fastparquet'©Úmatchr=re)r.ÚraisesÚ
ValueErrorr)rFÚmsgs  r)Útest_invalid_enginer¢s6Ø
:CÜ    z¨Ô    -ñ2Ü E¨5Ô1÷2÷2ñ2ús5µ>cóÀ|r&ts |jjd«|_tjdd«5t|«ddd«y#1swYyxYw)NÚstrúio.parquet.enginer )rrBryrCÚoption_contextr)rFr1Úusing_infer_strings   r)Útest_options_pyr¨sOáÕ"6Ø%×-Ñ-×4Ñ4°UÓ;    Ôä    ×    Ñ    Ð.°    Ó    :ñ$ÜÔ#÷$÷$ñ$ús¿AÁAcóptjdd«5t|«ddd«y#1swYyxYw)Nr¥r©rCr¦r)rFr7s  r)Útest_options_fpr«s2ô
×    Ñ    Ð.° Ó    >ñ$ÜÔ#÷$÷$ñ$úó,¬5cóptjdd«5t|«ddd«y#1swYyxYw)Nr¥Úautorª)rFr7r1s   r)Útest_options_autor¯s2ô
×    Ñ    Ð.°Ó    7ñ$ÜÔ#÷$÷$ñ$úr¬có^ttd«t«sJttd«t«sJt    j
dd«5ttd«t«sJttd«t«sJttd«t«sJ    ddd«t    j
dd«5ttd«t«sJttd«t«sJttd«t«sJ    ddd«t    j
dd«5ttd«t«sJttd«t«sJttd«t«sJ    ddd«y#1swYìxYw#1swYxYw#1swYyxYw)Nr rr¥r®)Ú
isinstancerrrrCr¦)r7r1s  r)Útest_options_get_enginer²sqÜj Ó+¬[Ô9Ð9Ð9Üj Ó/´ÔAÐAÐAä    ×    Ñ    Ð.°    Ó    :ñFÜ* VÓ,¬kÔ:Ð:Ð:Ü* YÓ/´Ô=Ð=Ð=Ü* ]Ó3´_ÔEÐEÑE÷Fô
 
×    Ñ    Ð.° Ó    >ñFÜ* VÓ,¬oÔ>Ð>Ð>Ü* YÓ/´Ô=Ð=Ð=Ü* ]Ó3´_ÔEÐEÑE÷Fô
 
×    Ñ    Ð.°Ó    7ñFÜ* VÓ,¬kÔ:Ð:Ð:Ü* YÓ/´Ô=Ð=Ð=Ü* ]Ó3´_ÔEÐEÑE÷FðF÷FðFú÷
FðFú÷
FðFús'Á AFÂ>AFÄ/AF#ÆFÆF Æ#F,cóDddlm}|jd«}|jd«}tsdn$t    t
j«t    |«k}tsdn$t    tj«t    |«k}txr|}txr|}|sÖ|sÓ|r6d|d}tjt|¬«5td    «ddd«n1d
}tjt|¬«5td    «ddd«|r6d|d}tjt|¬«5td    «ddd«yd}tjt|¬«5td    «ddd«yyy#1swYuxYw#1swYxYw#1swYyxYw#1swYyxYw) Nr)ÚVERSIONSr rFzPandas requires version .z. or newer of .pyarrow.rr®z%Missing optional dependency .pyarrow.z. or newer of .fastparquet.z)Missing optional dependency .fastparquet.) Úpandas.compat._optionalr´Úgetr-rr Ú__version__r3rr.rÚImportErrorr)r´Ú
pa_min_verÚ
fp_min_verÚhave_pa_bad_versionÚhave_fp_bad_versionÚhave_usable_paÚhave_usable_fprs        r)Ú"test_get_engine_auto_error_messager¿2sõ1ðiÓ(JØmÓ,Jõñ    ä W×(Ñ(Ó )¬G°JÓ,?Ñ ?ðõ!ñ    ä [×,Ñ,Ó -´¸
Ó0CÑ Cðô#Ò>Ð+>Ð'>NÜ&ÒBÐ/BÐ+BNá¡.áØ/°
¨|Ð;RÐSEÜ{°%Ô8ñ #Ü6Ô"÷ #ð #ð<EÜ{°%Ô8ñ #Ü6Ô"÷ #ñØ/°
¨|Ð;VÐWEÜ{°%Ô8ñ #Ü6Ô"÷ #ð #ð@EÜ{°%Ô8ñ #Ü6Ô"÷ #ð #ð##1>÷ #ð #ú÷ #ð #ú÷
 #ð #ú÷ #ð #ús0ÃE2Ã2E>Ä)F
ÅFÅ2E;Å>FÆ
FÆFcó|}tj«5}|j||d¬«t||¬«}tj||«t||ddg¬«}tj||ddg«ddd«y#1swYyxYw©N)r*r©r*rSrU)r*rB©rrrrr©r^r1r7r]rÚresults      r)Útest_cross_engine_pa_fprÆ]sð
BÜ    Ó    ð6dØ
  d 2°4 Ô8äd¨2Ô.Ü
×Ñf bÔ)äd¨2¸¸S°zÔBÜ
×Ñf b¨#¨s¨¡nÔ5÷6÷6ñ6úóA#BÂBcó|}tj«5}|j||d¬«t||¬«}tj||«t||ddg¬«}tj||ddg«ddd«y#1swYyxYwrÁrÃrÄs      r)Útest_cross_engine_fp_parÉksà    BÜ    Ó    ð6dØ
  d 2°4 Ô8äd¨2Ô.Ü
×Ñf bÔ)äd¨2¸¸S°zÔBÜ
×Ñf b¨#¨s¨¡nÔ5÷6÷6ñ6úrÇcótjdgd¢i«}d}tj«5}tjt
|dd¬«5|j ||«ddd«ddd«y#1swYxYw#1swYyxYw)NrSr9zqStarting with pandas version 3.0 all arguments of to_parquet except for the argument 'path' will be keyword-only.F)rÚcheck_stacklevelÚraise_on_extra_warnings)rCrDrrÚassert_produces_warningÚ FutureWarningr)r*r]r¡rs    r)Ú!test_parquet_pos_args_deprecationrÏxsä    sIÐ&Ó    'Bð    1ðô
Ó    ð(dÜ × 'Ñ 'ÜØØ"Ø$)ô    
ñ    (ð MM$ Ô'÷     (÷(ð(÷    (ð    (ú÷(ð(ús#°A>ÁA2Á!A>Á2A;    Á7A>Á>BcóeZdZdZdZy)ÚBasecóÌtj«5}tj||¬«5t    |||d¬«ddd«ddd«y#1swYxYw#1swYyxYw)Nr©r)rrr.rr)Úselfr]r*ÚexcÚerr_msgrs      r)Úcheck_error_on_writezBase.check_error_on_writesYä __Ó ð    ? $Üs¨'Ô2ñ ?Ü2t V¸Õ>÷ ?÷    ?ð    ?÷ ?ð ?ú÷    ?ð    ?ús!AA½AÁA    ÁAÁA#cóÈtj«5}tj|«5t|||d¬«ddd«ddd«y#1swYxYw#1swYyxYw)NrÓ)rrÚexternal_error_raisedr)rÔr]r*rÕrs     r)Úcheck_external_error_on_writez"Base.check_external_error_on_writesYä __Ó ð    ? $Ü×)Ñ)¨#Ó.ñ ?Ü2t V¸Õ>÷ ?÷    ?ð    ?÷ ?ð ?ú÷    ?ð    ?ús!A«A»AÁA    ÁAÁA!N)Ú__name__Ú
__module__Ú__qualname__r×rÚr0r+r)rÑrÑsò?ó?r+rÑcóZeZdZdZdZejjdgd¢«d«ZdZ    dZ
dZd    Zd
Z dZdZd ZdZdZdZdZejjdgd¢«d«Zejj,ejj.d««Zy)Ú    TestBasiccóÊtjgd¢«ddtjd«tjgd¢«fD]}d}|j||t|«y)Nr9r:r=rPz+to_parquet only supports IO with DataFrames)rCÚSeriesrzrZrr×r )rÔr*Úobjr¡s    r)Ú
test_errorzTestBasic.test_errors[äIIiÓ Ø ØÜLLÓ$ÜHHYÓð
ò    DCð@CØ×%Ñ% c¨6´:¸sÕCñ    Dr+c    ótjtd«ttdd««d«}ddg|_t||«y)NrHr:rI©rlrqr=re©rCrDrXrYrBr)rÔr*r]s   r)Útest_columns_dtypeszTestBasic.test_columns_dtypes£s;Ü \\¤T¨%£[¼¼eÀAÀq»kÓ9JÑKÓ LðU^
ÜVÕ$r+r)NÚgzipÚsnappyÚbrotlicóVtjdgd¢i«}t||d|i¬«y)Nr?r9r©r©rCrDr)rÔr*rr]s    r)Útest_compressionzTestBasic.test_compressionªs&ä \\3¢    Ð*Ó +ÜV°=À+Ð2NÖOr+c    óÐtjtd«ttdd««d«}tjdtd«i«}t    |||ddgi¬«y)NrHr:rIrårlrB©rr©rCrDrXrYr)rÔr*r]rs    r)Útest_read_columnszTestBasic.test_read_columns¯sSä \\¤T¨%£[¼¼eÀAÀq»kÓ9JÑKÓ Lä<< ¬4°«;Ð 7Ó8ÜØ ¸    ÀHÀ:Ð7Nö    
r+c
óÐtjttd««td«d«}tjdddgi«}t    ||||ddgid    gdgd
d¬«y)NrIÚaabb)rqÚpartrqrr:Úpartition_colsrõ)rõú==rS)ÚfiltersrB)rrrrrrñ)rÔr*Útmp_pathr]rs     r)Útest_read_filterszTestBasic.test_read_filters¸smÜ \\äE !H~ÜVñ ó
ô<< ¨¨A¨ Ó0ÜØØØØØ*¨V¨HÐ5Ø%8Ð$9ÀuÀgÑNØö    
r+có |dk7}tjdgd¢i«}t||«gd¢tjdd¬«t    d«gd    ¢g}|D]Q}||_t |tj«r |j
jd«|_t|||¬
«Sgd¢|_d|j
_    t||«y) Nrr?r9)r;r<rIrPr<rQrH)r:r<rI)r)rr:r;r=)
rCrDrr\rXÚindexr±Ú DatetimeIndexÚ
_with_freqÚname)rÔr*rr]Úindexesrüs      r)Útest_write_indexzTestBasic.test_write_indexËs·Ø  Ñ-ä \\3¢    Ð*Ó +ÜVÔ$ò ÜMM*¨aÔ0ÜKÚð    
ðò    BEØBHÜ%¤×!1Ñ!1Ô2Ø88×.Ñ.¨tÓ4ÜR °[ÖAð        BòØ ÜVÕ$r+có¢|}tjdgd¢i«}tjjgd¢«}||_t||«y)Nr?r9©)rSr:)rSr;)rTr:)rCrDÚ
MultiIndexÚfrom_tuplesrür)rÔr1r*r]rüs     r)Útest_write_multiindexzTestBasic.test_write_multiindexãs@àä \\3¢    Ð*Ó +Ü  ×)Ñ)Ò*HÓIØÜVÕ$r+c    óÆ|}tjddd¬«}tjtjjd«j dt|«zdf«td«¬«}tjjd    d
g|gddg¬ «}|jd¬ «}||fD]-}||_t||«t||dddgi|ddg¬«/y)Nz01-Jan-2018z01-Dec-2018ÚMS)Úfreqr;r<ÚABCrAÚLevel1ÚLevel2ÚlevelÚdate)rrBr?r@©rr)rCr\rDrZÚrandomÚdefault_rngÚstandard_normalÚlenrXrÚfrom_productÚcopyrür)rÔr1r*Údatesr]Úindex1Úindex2rüs        r)Útest_multiindex_with_columnsz&TestBasic.test_multiindex_with_columnsìsáØÜ  m¨]ÀÔFÜ \\ÜII×!Ñ! !Ó$×4Ñ4°a¼#¸e»*±nÀaÐ5HÓIÜKô
ô×+Ñ+ØÐ ! 5Ð)°'¸6Ð1Bð,ó
ð 4Ó(ØfÐ%ò    EØBHäR Ô(ÜØF¨°S¸#°JÐ(?È"ÈcÐSVÈZÉ.ö ñ        r+cóÊtjgd¢gd¢d«}ddd}|jd¬«}t||||¬«tjgd¢gd¢dgd    ¢¬
«}t||||¬«gd¢gd¢g}tjt    td ««td «Dcgc]}|c}d|¬
«}|jd¬«}t||||¬«ycc}w)Nr9)ÚqÚrÚs)rSrTF)rrüT)Údrop©rr)ÚzyxÚwvuÚtsr©rü©rererfrfr=r=Úquxr%©ÚoneÚtwor'r(r'r(r'r(é)r'r()rCrDÚreset_indexrrXrY)rÔr*r]rrÚarraysÚis       r)Útest_write_ignoring_indexz#TestBasic.test_write_ignoring_indexÿsÕô\\¢    ²Ñ@Ó Aà'+°eÑ<ð>> t>Ó,äV°,ÈÕRô\\Ú¢/Ñ2Ò:Oô
ô    V°,ÈÕRò EÚDð
ô\\ÜqN¼¸a»Ö+A°1¨QªBÒ+AÑBÈ&ô
ð>> t>Ó,ÜV°,ÈÖRùò    ,BsÂ)
C 
có,tjjgd¢«}tjtj
j d«jd«|¬«}|dk(r|j||td«y|dk(r t||«yy)Nrr;)rIr<rArúColumn name must be a stringr )rCrrrDrZrrrr×Ú    TypeErrorr)rÔr*Ú
mi_columnsr]s    r)Útest_write_column_multiindexz&TestBasic.test_write_column_multiindexsä]]×.Ñ.Ò/MÓN
Ü \\ÜII×!Ñ! !Ó$×4Ñ4°VÓ<Àjô
ð]Ò"Ø×%Ñ%ØFIÐ'Eõ ðyÒ  ÜR Õ(ð!r+có gd¢gd¢g}tjtjj    d«jd«|¬«}ddg|j_|dk(r|j||td    «y|d
k(r t||«yy)Nr$)r:r;r:r;r:r;r:r;r;©r)r)rArrrzColumn namer )rCrDrZrrrrBrr×r r©rÔr*r+r]s    r)Ú&test_write_column_multiindex_nonstringz0TestBasic.test_write_column_multiindex_nonstring-sò
 EÚ$ð
ô\\ÜII×!Ñ! !Ó$×4Ñ4°VÓ<Àfô
ð% hÐ/

ÔØ]Ò"Ø×%Ñ% b¨&´*¸mÕLØ yÒ  ÜR Õ(ð!r+cóÜ|}gd¢gd¢g}tjtjj    d«jd«|¬«}ddg|j_t||«y)Nr$r&r;r4rAÚ    ColLevel1Ú    ColLevel2)    rCrDrZrrrrBrr©rÔr1r*r+r]s     r)Ú#test_write_column_multiindex_stringz-TestBasic.test_write_column_multiindex_string>seðò EÚDð
ô\\ÜII×!Ñ! !Ó$×4Ñ4°VÓ<Àfô
ð(¨Ð5

ÔäVÕ$r+cóÐ|}gd¢}tjtjj    d«jd«|¬«}d|j_t||«y)N)rerfr=r%r;©r)rIrAÚ    StringCol)    rCrDrZrrrrBrÿrr:s     r)Útest_write_column_index_stringz(TestBasic.test_write_column_index_stringOsTðò.Ü \\ÜII×!Ñ! !Ó$×4Ñ4°VÓ<Àfô
ð&

äVÕ$r+cógd¢}tjtjj    d«jd«|¬«}d|j_|dk(r|j||td«yt||«y)N©r:r;r<rIr;r=rAÚNonStringColrr/)rCrDrZrrrrBrÿr×r0rr5s    r)Ú!test_write_column_index_nonstringz+TestBasic.test_write_column_index_nonstring]soòÜ \\ÜII×!Ñ! !Ó$×4Ñ4°VÓ<Àfô
ð)

Ø]Ò"Ø×%Ñ%ØFIÐ'Eõ ô R Õ(r+cóþtjd«}|dk(r1tjjd¬«}|j    |«tjtjgd¢d«tjgd¢d«tjgd¢«tjgd    ¢«tjgd
¢d«tjgd¢d«tjgd¢d «d«}tj«5}|j||«t||¬«}t||d¬«}ddd«djtjd «k(sJtjtjgd¢d¬«tjgd¢d¬«tjgd¢d¬«tjgd    ¢d¬«tjgd
¢d¬«tjgd¢d¬«tjgd¢d¬«d«}    |dk(r&j!dd¬«}|    j!dd¬«}    tj"|    «y#1swY1xYw)Nzpyarrow.parquetrz.Fastparquet nullable dtype support is disabledr©r:r;r<NÚint64Úuint8)rSrTr`N)TFTNrA)çð?rirjNÚfloat32rL)rSrTr`rUrVrWÚgrÂÚnumpy_nullable©r*Ú dtype_backendrSÚInt64rMÚUInt8rlÚbooleanÚFloat32ÚFloat64r`r:)Úaxis)r.Úimportorskipr5r6r4r ÚtablerrrÚwrite_tablerrNrZrCrDrr)
rÔr*r(Úpqr5rUrÚresult1Úresult2rs
          r)Útest_dtype_backendzTestBasic.test_dtype_backendmsêÜ ×  Ñ  Ð!2Ó 3à]Ò"ô;;×$Ñ$ØGð%óDð ×Ñ Ô%ä  ä]]¢?°GÓ<Ü]]¢?°GÓ<Ü]]Ò#8Ó9Ü]]Ò#<Ó=ä]]¢<°Ó9ä]]Ò#8¸)ÓDÜ]]Ò#8¸)ÓDñ
 ó
ô__Ó ð    X $àNN5 $Ô'Ü" 4°Ô7GÜ" 4°ÐFVÔWG÷        Xðs|×!Ñ!¤R§X¡X¨iÓ%8Ò8Ð8Ð8Ü<<äXXo°WÔ=ÜXXo°WÔ=ÜXXÒ3¸8ÔDÜXXÒ7¸yÔIÜXXl°'Ô:ÜXXÒ3¸9ÔEÜXXÒ3¸9ÔEñ ó
 
ð]Ò"ðll 3¨QlÓ/GØ}} S¨q}Ó1HÜ
×Ñg xÕ0÷/    Xñ    XúsÄ.I2É2I<rN)    rNrOrPÚobjectzdatetime64[ns, UTC]rsz    period[D]rRrlcóätjdtjg|¬«i«}d}|dk(r,tjdtjgd¬«i«}t||ddi|¬«y)NÚvaluerMrsrRrMrKr)rCrDrr)rÔr1rNr]rs     r)Útest_read_empty_arrayzTestBasic.test_read_empty_arraysrô \\à "¨EÔ2ð ó
ðØGÒÜ||àRXX b°    Ô:ðóHô
    Ø Ð2BÐ CÈhö    
r+có(|dk7rtj|«t|dddd«d¬«5}|j|j    «¬«t|j|¬    «}ddd«tj|«y#1swY xYw)
Nr®ÚioÚdataÚparquetzsimple.parquetÚrb)Úmode)ÚcontentrÂ)    r.rTÚopenÚ serve_contentÚreadrÚurlrr)rÔÚ
httpserverÚdatapathrFr*rWr]s       r)Útest_parquet_read_from_urlz$TestBasic.test_parquet_read_from_url¿sðVÒÜ×Ñ Ô'Ü (4 ¨Ð4DÓEÈDÔ Qð    =ÐUVØ×$Ñ$¨Q¯V©V«XÐ$Ô6Üjnn°VÔ<B÷    =ô    ×Ñb )Õ,÷    =ð    =ús±8BÂBN)rÛrÜrÝrãrçr.r5Úparametrizerîròrúrrrr-r2r6r;r?rCrZr^ÚnetworkÚ
single_cpurlr0r+r)rßrßsÐò    Dò%ð[[×Ñ]Ò,NÓOñPóPðPò
ò
ò&%ò0%òò&Sò@)ò)ò"%ò"%ò)ò /1ðb[[×ÑØò
    
ó ñ
ó ð
ð&[[×ÑØ[[×Ññ-óóñ-r+rßc óeZdZdZdZdZdZdZdZdZ    e
jje «d¬    «e
jjed
¬    «e
jj!deej&g«d«««Zd Ze
jj,d«Ze
jj,d«Ze
jj,e
jj!ddggg«d««ZdZdZdZdZe
jj!dedgddg¬«d«ZdZdZ dZ!dZ"d Z#d!Z$d"Z%d#Z&d$Z'd%Z(d&Z)e
jj!d'd(d)ge
jTd*d+ge
jje+e,d,¬-«¬.«e-jZd/d)d)d(d(«e-jZd/d)d)d)d)«gg«d0«Z.d1Z/d2Z0d3Z1e
jje2d4¬    «d5«Z3d6Z4y7)8ÚTestParquetPyArrowcó|}tjddd¬«}|jd«}||d<gd¢|d<t||«y)NrPr<úEurope/Brussels©rRÚtzÚdatetime_tz©TNTÚbool_with_none)rCr\rþr)rÔr1r|r]Údtis     r)Ú
test_basiczTestParquetPyArrow.test_basicËsIØ ômmJ°Ð6GÔHØnnTÓ"Ø=ÑÚ1ÐÑäRÕ r+cón|}tjddd¬«|d<t|||ddgdddgi¬    «y)
NrPr<rsrtrvrlrqrBrð)rCr\r)rÔr1r|r]s    r)Útest_basic_subset_columnsz,TestParquetPyArrow.test_basic_subset_columnsÖsIðäMM¨*¸aÐDUÔV=ÑäØØØ 5Ð)Ñ*Ø" X¨uÐ$5Ð6ö        
r+cóâ|j|¬«}t|t«sJt|«}t    |«}|j«}d|jd<tj||«y)NrÂr)    rr±rorrrrrr)rÔr1r|Ú    buf_bytesÚ
buf_streamÚresrs       r)Ú*test_to_bytes_without_path_or_buf_providedz=TestParquetPyArrow.test_to_bytes_without_path_or_buf_providedäscà×&Ñ&¨bÐ&Ó1    Ü)¤UÔ+Ð+Ð+äYÓ'
Ü:Ó&à<<>Ø-1Ð)Ñ*Ü
×Ñc 8Õ,r+cóÖtjtjd«j    dd«td«¬«j «}|j||td«y)NérIr<ÚaaarAzDuplicate column names found©    rCrDrZr[ÚreshaperXrr×r ©rÔr1r]s   r)Útest_duplicate_columnsz)TestParquetPyArrow.test_duplicate_columnsðsIä \\")) B-×/Ñ/°°1Ó5¼tÀE»{Ô K× PÑ PÓ RØ×!Ñ! " b¬*Ð6TÕUr+cóttjdtjdd¬«i«}t||«y)NrSú1 dayr<rQ)rCrDÚtimedelta_rangerrs   r)Útest_timedeltaz!TestParquetPyArrow.test_timedeltaõs,Ü \\3¤× 2Ñ 2°7ÀAÔ FÐGÓ HÜRÕ r+cóxtjdgd¢i«}|j||tj«y)NrS©rSr:ri)rCrDrÚr ÚArrowExceptionrs   r)Útest_unsupportedz#TestParquetPyArrow.test_unsupportedùs/ä \\3¢ Ð.Ó /ð     ×*Ñ*¨2¨r´7×3IÑ3IÕJr+cóètjddtj¬«}tj|dg¬«}t
r"|j ||tj«yt||«y)Nr;é
rMÚfp16©rarB)
rZr[Úfloat16rCrDrrÚr rr)rÔr1rar]s    r)Útest_unsupported_float16z+TestParquetPyArrow.test_unsupported_float16sQôyyB¤b§j¡jÔ1Ü \\t¨f¨XÔ 6ÝØ×.Ñ.¨r°2´w×7MÑ7MÕNäR Õ$r+zqPyArrow does not cleanup of partial files dumps when unsupported dtypes are passed to_parquet function in windowsrzfloat16 works on 15Ú    path_typecó¼tjddtj¬«}tj|dg¬«}tj«5}||«}tjtj«5|j||¬«ddd«tjj|«rJ    ddd«y#1swY4xYw#1swYyxYw)Nr;rrMrr)rr*)rZr[rrCrDrrrÙr rrÚosrÚisfile)rÔr1rrar]Úpath_strrs       r)Ú test_unsupported_float16_cleanupz3TestParquetPyArrow.test_unsupported_float16_cleanup
s®ôyyB¤b§j¡jÔ1Ü \\t¨f¨XÔ 6ä __Ó ð    , (ÙXÓ&DÜ×)Ñ)¬'×*@Ñ*@ÓAñ 4Ø   4° Ô3÷ 4äww~~ dÔ+Ð+Ð+Ð+÷        ,ð    ,÷ 4ð 4ú÷    ,ð    ,ús$Á,CÁ?CÂ)CÃC    ÃCÃCc
ótjtjtd««tjgd¢tjgd¢«¬«tjgd¢gd¢d¬«d    «}t||«y)
NÚabcdef)rer=r=reNrerdrM)rSrTr`rSr`rT)rTr`rUT)Ú
categoriesÚordered©rSrTr`)rCrDÚCategoricalrXÚCategoricalDtyperrs   r)Útest_categoricalz#TestParquetPyArrow.test_categorical sfä \\ä^^¤D¨£NÓ3ä^^Ú=Ü×-Ñ-Ò.CÓDôô
^^Ú2Ú.Ø ôñ  ó
ô"    RÕ r+cótjd«}|jdi|¤}d|i}t|||jd||¬«y)NÚs3fsÚ
filesystemú/pyarrow.parquet©rrrr0)r.rTÚS3FileSystemrrÿ)rÔrFÚs3_public_bucketr1Ús3sor¦Ús3Úkws        r)Útest_s3_roundtrip_explicit_fsz0TestParquetPyArrow.test_s3_roundtrip_explicit_fs5sWä×"Ñ" 6Ó*Ø T× Ñ Ñ & Ñ &ØBÐ ÜØØØ$×)Ñ)Ð*Ð*:Ð;ØØö    
r+cóHd|i}t||d|jd||¬«y)NÚstorage_optionsús3://r¨r©©rrÿ)rÔrFr«r1r¬s     r)Útest_s3_roundtripz$TestParquetPyArrow.test_s3_roundtripBs7ð" 4Ð(ÜØØØÐ)×.Ñ.Ð/Ð/?Ð@ØØö    
r+Ú partition_colr?có8tjd«|j«}|rL|jtj|tj««}d}||j|«||<t|||d|jdd|i|d|ddd¬    «y)
Nr¦Úcategoryr²z/parquet_dirr±)rörr±Tr:)rrrrrr)
r.rTrryÚdictÚfromkeysrZÚint32rrÿ)rÔrFr«r1rµr¬Úexpected_dfÚpartition_col_types        r)Útest_s3_roundtrip_for_dirz,TestParquetPyArrow.test_s3_roundtrip_for_dirNsªô    ×ÑFÔ#ànnÓ&ñØ%×,Ñ,¬T¯]©]¸=Ì"Ï(É(Ó-SÓTKØ!+Ðà)4°]Ñ)C×)JÑ)JØ"ó*K Ñ&ô    ØØØ ØÐ)×.Ñ.Ð/¨|Ð<Ø*¨DÐ1à"/Ø#Ø#'ñð
Øö     
r+cóötjd«t«}|j|«t    |«}|r&t
s |jjd«|_tj||«y)Nr r¤)
r.rTrrrrrBryrr)rÔrFr§ÚbufferÚdf_from_bufs     r)Útest_read_file_like_obj_supportz2TestParquetPyArrow.test_read_file_like_obj_supportus^Ü×ÑIÔ&ÜØ×ÑVÔ$Ü" 6Ó*ÙÕ&:Ø )× 1Ñ 1× 8Ñ 8¸Ó ?IÔÜ
×Ñi¨Õ5r+cóntjd«|jdd«|jdd«tjtd¬«5td«ddd«tjtd¬«5|j d«ddd«y#1swY?xYw#1swYyxYw)Nr ÚHOMEÚTestingUserÚUSERPROFILEz.*TestingUser.*rz~/file.parquet)r.rTÚsetenvrÚOSErrorrr)rÔrFÚmonkeypatchs   r)Útest_expand_userz#TestParquetPyArrow.test_expand_user~sÜ×ÑIÔ&Ø×Ñ6 =Ô1Ø×Ñ=¨-Ô8Ü ]]7Ð*<Ô =ñ    +ÜÐ)Ô*÷    +ä ]]7Ð*<Ô =ñ    3Ø× Ñ Ð!1Ô2÷    3ð    3÷    +ð    +ú÷    3ð    3úsÁBÂB+ÂB(Â+B4códdg}|}|j||d¬«t||«t|«j|jk(sJy)Nrurq©rör©rrrÚshape)rÔrùr1r|rör]s      r)Útest_partition_cols_supportedz0TestParquetPyArrow.test_partition_cols_supportedsIà  %Ø Ø
  h¨~È4 ÔPÜh¨Ô7ÜHÓ%×+Ñ+¨r¯x©xÒ7Ð7Ñ7r+cód}|g}|}|j||d¬«t||«t|«j|jk(sJy)NrurËrÌ)rÔrùr1r|röÚpartition_cols_listr]s       r)Útest_partition_cols_stringz-TestParquetPyArrow.test_partition_cols_stringsOàØ-Ð.ÐØ Ø
  h¨~È4 ÔPÜhÐ(;Ô<ÜHÓ%×+Ñ+¨r¯x©xÒ7Ð7Ñ7r+có|Sr$r0)Úxs r)ú<lambda>zTestParquetPyArrow.<lambda>s Qr+rlzpathlib.Path)Úidscód}|g}|}||«}|j||¬«t|«j|jk(sJy)Nr@)rö)rrrÍ)    rÔrùr1rFrrörÐr]rs             r)Útest_partition_cols_pathlibz.TestParquetPyArrow.test_partition_cols_pathlibsOðØ-Ð.ÐØ áÓ"Ø
  dÐ+> Ô?ÜDÓ!×'Ñ'¨2¯8©8Ò3Ð3Ñ3r+cóJtjgg¬«}t||«y)N)rürBrírs   r)Útest_empty_dataframez'TestParquetPyArrow.test_empty_dataframe¦sä \\ ¨BÔ /ÜRÕ r+cóòddl}tjdddgi«}|j|jd|j
«¬«g«}|j t«}t||d|i|¬«y)NrrÓr:)Útyperr)    r rCrDrÚfieldÚbool_ryrur)rÔr1r r]rÚout_dfs      r)Útest_write_with_schemaz)TestParquetPyArrow.test_write_with_schema«scÛä \\3  A -Ó (Ø  §¡¨s¸¸¿¹»Ô!IÐ JÓKØ4ÜR¨x¸Ð.@È6ÖRr+cóÆtjd«tjtjgd¢d¬«tjgd¢d¬«tjgd¢d¬«d«}|r&t
r t |||jd    d
i«¬«nt ||«tjdtjgd ¢d¬«i«}t ||«y)Nr r9rNrMÚUInt32rarlr¡r`r¤©rrSrE)r.rTrCrDrárrry)rÔr1r§r]s    r)Ú test_additional_extension_arraysz3TestParquetPyArrow.test_additional_extension_arrays³s£ô    ×ÑIÔ&Ü \\äYYy°Ô8ÜYYy°Ô9ÜYYÒ/°xÔ@ñ ó
ñÕ"6ÜR ¨b¯i©i¸¸e¸Ó.EÖFäR Ô$ä \\3¤§    ¡    ª/ÀÔ IÐJÓ KÜRÕ r+cóÆtjd«tjdtjgd¢d¬«i«}tj
d|«5|rNtr|jd«}n|jd|d    «}|jjd«|_n|jd|d    «}t|||¬
«ddd«y#1swYyxYw)Nr rSraústring[pyarrow]rMÚstring_storager¤zstring[ú]râ)
r.rTrCrDrár¦rryrBr)rÔr1rær§r]rs      r)Ú test_pyarrow_backed_string_arrayz3TestParquetPyArrow.test_pyarrow_backed_string_arrayÆs¿ä×ÑIÔ&Ü \\3¤§    ¡    Ò*:ÐBSÔ TÐUÓ VÜ × Ñ Ð/°Ó @ñ        8Ù!Ý'Ø!yy¨Ó/Hà!yy¨7°>Ð2BÀ!Ð)DÓEHØ#+×#3Ñ#3×#:Ñ#:¸5Ó#AÕ à99 w¨~Ð.>¸aÐ%@ÓAÜR ¨hÕ7÷        8÷        8ñ        8ús ÁA4CÃC cóHtjd«tjtjjgd¢«tjddd¬«tjjtjddd¬««d«}t||«y)    Nr ))rr:)r:r;)r<rIz
2012-01-01r<ÚD)rRr    rI)r`rUrV)
r.rTrCrDÚ IntervalIndexrÚperiod_rangeÚfrom_breaksr\rrs   r)Útest_additional_extension_typesz2TestParquetPyArrow.test_additional_extension_typesÕszô    ×ÑIÔ&Ü \\ä×%Ñ%×1Ñ1Ò2JÓKÜ__ \¸1À3ÔGä×%Ñ%×1Ñ1ÜMM ,¸ÀÔDóñ     ó    
ô    RÕ r+cód}tjdtjddd¬«i«}t||d|i¬«y)    Nz2.6rSz
2017-01-01Ú1nsr©r    rRÚversionrì)rCrDr\r)rÔr1Úverr]s    r)Útest_timestamp_nanosecondsz-TestParquetPyArrow.test_timestamp_nanosecondsås;ðÜ \\3¤§ ¡ ¨lÀÐPRÔ SÐTÓ UÜR¨y¸#Ð.>Ö?r+cóhtjdd«d|gz}tj|d|i¬«}|dd}tr |j
j d«|_|jtjjk7r    ddl}|j
jj|«}|j|j«dz«}|j
j!|«|_|dj"j!|«|d<t'||d    |¬
«y#t$$rYwxYw)Nr ú11.0.0éÚindex_as_col©rüraÚnsré<F)rr)r.rTrCrDr    rüÚas_unitÚtzinforvÚtimezoneÚutcÚpytzruÚ    utcoffsetÚFixedOffsetÚ total_secondsÚ
tz_convertÚdtr¸r)    rÔr1r~Úidxr]rrÚoffsetrus             r)Útest_timezone_aware_indexz,TestParquetPyArrow.test_timezone_aware_indexísÜ×ÑI xÔ0àÐ+Ð,Ñ,Ü \\ ¨>¸3Ð*?Ô @ða5ÝØ%^^×3Ñ3°DÓ9HNØ#×*Ñ*¬h×.?Ñ.?×.CÑ.CÒCð VÛð×.Ñ.Ð/GÓHØ×%Ñ% f×&:Ñ&:Ó&<¸rÑ&AÓBØ!)§¡×!:Ñ!:¸2Ó!>Ø+3°NÑ+C×+FÑ+F×+QÑ+QÐRTÓ+UÑ(ÜR¨U¸XÖFøôò Ùð úsÂ    D%Ä%    D1Ä0D1có6tjd«tjdt    td««i«}t j«5}|j||¬«t||dg¬«}ddd«t«dk(sJy#1swYxYw)Nr rSr<rÂ©rSr÷r©rør:)r.rTrCrDrXrYrrrrr)rÔr1r]rrÅs     r)Útest_filter_row_groupsz)TestParquetPyArrow.test_filter_row_groupssä×ÑIÔ&Ü \\3¤¤U¨1£X£Ð/Ó 0Ü __Ó ð    F $ØMM$ rMÔ*Ü! $¨°^Ð4DÔEF÷    Fô6{aÒÐÑ÷    Fð    FúsÁ#BÂBcótjtjj    d«jd«gd¢¬«}t j«5}|j||¬«t||«}ddd«|r;tjtjjj«sJytjtjjj«sJy#1swYxYw)Nr;)rr<)r?r@ÚCrArÂ)rCrDrZrrrrrrrr±Ú_mgrÚcoreÚ    internalsÚArrayManagerÚBlockManager)rÔr1Úusing_array_managerr]rrÅs      r)Útest_read_parquet_managerz,TestParquetPyArrow.test_read_parquet_managers»ä \\ÜII×!Ñ! !Ó$×4Ñ4°WÓ=Âô
ô__Ó ð    , $ØMM$ rMÔ*Ü! $¨Ó+F÷    ,ñÜfkk¬2¯7©7×+<Ñ+<×+IÑ+IÔJÐJÑJäfkk¬2¯7©7×+<Ñ+<×+IÑ+IÔJÐJÑJ÷     ,ð    ,úsÁ C:Ã:Dcóòddl}|}tjddd¬«}|jd«}||d<gd¢|d<|jj|«}|j tj¬    «}trj|d
jd«|d
<|djd«|d<|djtj|jd d¬«««|d<t||ddi|¬«y)NrrPr<rsrtrvrwrx)Útypes_mapperrvztimestamp[us][pyarrow]rwÚus)ÚunitrurMr ©r*rr)r rCr\rþÚTableÚfrom_pandasÚ    to_pandasÚ
ArrowDtyper
ryÚ    timestampr)rÔr1r|r r]ryÚpa_tablers        r)Ú&test_read_dtype_backend_pyarrow_configz9TestParquetPyArrow.test_read_dtype_backend_pyarrow_config%sþÛà ômmJ°Ð6GÔHØnnTÓ"Ø=ÑÚ1ÐÑà==×,Ñ,¨RÓ0Ø×%Ñ%´2·=±=Ð%ÓAÝà#+¨JÑ#7×#>Ñ#>Ð?WÓ#XHZÑ Ø,4Ð5HÑ,I×,PÑ,PØ(ó-HÐ(Ñ)ð'/¨}Ñ&=×&DÑ&DÜ  Ð/g×/Ñ/°TÐ>OÔPÓQó'H]Ñ#ô    ØØØ(¨)Ð4Øö        
r+có6tjdddgitjddgd¬«d¬    «}|j«}d
dl}t|j«td«kDr |jjd«|_t||dd i|¬«y)NrSr:r;r<rIÚtest©rÿzint64[pyarrow])rürNrrörMr r)
rCrDrErr rr·rüryr)rÔr1r]rr s     r)Ú,test_read_dtype_backend_pyarrow_config_indexz?TestParquetPyArrow.test_read_dtype_backend_pyarrow_config_indexCsÜ \\Ø 1a&M¤§¡¨1¨a¨&°vÔ!>ÐFVô
ð779Ûä7×&Ñ&Ó'¬'°(Ó*;Ò;Ø%^^×2Ñ2Ð3CÓDHNÜØØØ(¨)Ð4Øö        
r+rBrr:rbrcz*https://github.com/apache/arrow/pull/44171)rrréÛc    ótjtd«ttdd««d«}||_t||«y)NrHr:rIråræ)rÔr1rBr]s    r)Útest_columns_dtypes_not_invalidz2TestParquetPyArrow.test_columns_dtypes_not_invalidSs7ô&\\¤T¨%£[¼¼eÀAÀq»kÓ9JÑKÓ Là
ÜRÕ r+cóvtjtjgd¢d¬«¬«}t||«y)Nr¡úcustom namer$r#©rCrDrErrs   r)Útest_empty_columnsz%TestParquetPyArrow.test_empty_columnsks%ä \\¤§¡ª¸}Ô MÔ NÜRÕ r+cóÈ|dz}tjddgi¬«}ddi|_|j||¬«t    ||¬«}|j|jk(sJy)Nztest_df_metadata.pr:©raÚtest_attributerÂ)rCrDÚattrsrr)rÔrùr1rr]Únew_dfs      r)Útest_df_attrs_persistencez,TestParquetPyArrow.test_df_attrs_persistenceps_ØÐ.Ñ.Ü \\  A 3xÔ (Ø$ aÐ(Ø
  d 2 Ô&Üd¨2Ô.Ø||rxxÒ'Ð'Ñ'r+c    ó|dz}tjdddgiddg¬«}|j||¬«tjdd    «5t    ||¬«}ddd«tj
tj¬
«}tjdddgi|tjddg|¬«tjdgtr|stn|¬«¬«}tj|«y#1swYxYw) Nztest_string_inference.prSrÓÚyrT)rarürÂúfuture.infer_stringT©Úna_valuerM)rarNrürB) rCrDrr¦rÚStringDtyperZrxrErr[rr)    rÔrùr1r§rr]rÅrNrs             r)Útest_string_inferencez(TestParquetPyArrow.test_string_inferencexsÞàÐ3Ñ3Ü \\  c¨3 ZÐ0¸¸c¸
Ô CØ
  d 2 Ô&Ü × Ñ Ð4°dÓ ;ñ    3Ü! $¨rÔ2F÷    3ä¬¯©Ô/Ü<<ØSzÐ"ØÜ((C :¨UÔ3ÜHHØå'Ñ0Bõàô    ô    
 
ô    ×Ñf hÕ/÷    3ð    3úsÁC5Ã5C>znot supported before 11.0c    óddl}|dz}tjdtd«gid¬«}|j    ||jd|j d«fg«¬«t|«}trtjdd    gid
¬«}n#tjdtd«gid¬«}tj||«y)Nrz    decimal.prSz123.00rårMr÷)rÚ123zstring[python]r[)r rCrDrrrÚ
decimal128rrrr)rÔrùr1rr]rÅrs       r)Útest_roundtrip_decimalz)TestParquetPyArrow.test_roundtrip_decimalsªó    à+Ñ%Ü \\3¤¨Ó!2Ð 3Ð4Ð<MÔ NØ
  d 2§9¡9¨s°B·M±MÀ!Ó4DÐ.EÐ-FÓ#G ÔHÜdÓ#ÝÜ|| S¨5¨' NÐ:JÔKHä|| S¬7°8Ó+<Ð*=Ð$>ÀhÔOHÜ
×Ñf hÕ/r+c
ó0ddl}ddlm}|dz}|jd|j    gd¢|j««i«}|j ||«tjdd«5t|«}ddd«tjdgd¢itjtj¬«tjdgtjtj¬«¬«¬    «}tj |«y#1swYxYw)
Nrzlarge_string.prS)NrTr`r5Tr6rM)rarNrB)r Úpyarrow.parquetrbrUrÚlarge_stringrVrCr¦rrDr8rZrxrErr)rÔrùr1rWrrUrÅrs        r)Ú#test_infer_string_large_string_typez6TestParquetPyArrow.test_infer_string_large_string_typesÍãÝ$àÐ*Ñ*à#rxxÒ(8¸"¿/¹/Ó:KÓLÐMÓNØ
udÔ#ä × Ñ Ð4°dÓ ;ñ    (Ü! $Ó'F÷    (ä<<ØÒ'Ð(Ü..¬"¯&©&Ô1ÜHHcU¬"¯.©.Ä"Ç&Á&Ô*IÔJô
ô
    ×Ñf hÕ/÷    (ð    (úsÁ+DÄDN)5rÛrÜrÝrzr|rrrrrr.r5r6rÚskipifrrmr¤ÚpathlibÚPathrr¤ror¯r´r½rÁrÉrÎrÑr×rÙrßrãrèrîrôrrrr!r%r&r ÚNotImplementedErrorrvr(r,r2r9r    r=rAr0r+r)rqrqÊsò    !ò
ò
-òVò
!òKò%ð[[×ÑÙÓð ?ðóð[[×ÑÐ0Ð0Ð9NÐÓOØ[[×Ñ[¨3°·±Ð*=Ó>ñ,ó?óPóð,ò!ð*[[×Ññ
 
óð
 
ð[[×Ññ    
óð    
ð[[×ÑØ[[×ÑØà EØð    
óñ
óóð
ò>6ò3ò8ò8ð[[×ÑØc;Ð'¨h¸Ð-Gðóñ    4óð    4ò!ò
Sò!ò& 8ò!ò @òGòB òKò
ò<
ð [[×ÑØà FØFLLØÐ Økk×'Ñ'Ø(Ø.ØGð(óô ð"×!Ñ! $¨¨1¨a°Ó3Ø!×!Ñ! $¨¨1¨a°Ó3ð ð    
óñ$!ó%ð$!ò!ò
(ò0ð*[[×ÑÐ,Ð5PÐÓQñ0óRð0ó0r+rqcóVeZdZdZdZdZdZdZdZdZ    e
jjd«Z d    Zd
ZdZdZe
jj%e«d ¬«d«ZdZdZdZdZdZdZdZdZe
jj%e«d ¬«d«Zy)ÚTestParquetFastParquetcó°|}tjddd¬«}|jd«}||d<tjdd¬«|d<t    ||«y)    NrPr<z
US/EasternrtrvrrQÚ    timedelta)rCr\rþrr)rÔr7r|r]rys     r)rzz!TestParquetFastParquet.test_basic½sQØ ämmJ°°lÔCØnnTÓ"Ø=ÑÜ×,Ñ,¨W¸aÔ@;ÜRÕ r+c    ótjtd«ttdd««d«}t}d}ddg|_|j ||||«ddg|_|j ||||«tjd    dddd«tjd    dddd«g|_|j ||||«y)
NrHr:rIrår/rrbrcr&)rCrDrXrYr0rBr×rv)rÔr7r]Úerrr¡s     r)Útest_columns_dtypes_invalidz2TestParquetFastParquet.test_columns_dtypes_invalidÆs¾Ü \\¤T¨%£[¼¼eÀAÀq»kÓ9JÑKÓ LäØ,ðV
Ø×!Ñ! " b¨#¨sÔ3ðfÐ%
Ø×!Ñ! " b¨#¨sÔ3ô ×Ñd A q¨!¨QÓ/Ü×Ñd A q¨!¨QÓ/ð

ð     ×!Ñ! " b¨#¨sÕ3r+cóÚtjtjd«j    dd«td«¬«j «}d}|j||t|«y)NrrIr<rrAz9Cannot create parquet dataset with duplicate column namesr©rÔr7r]r¡s    r)rz-TestParquetFastParquet.test_duplicate_columnsÛsMä \\")) B-×/Ñ/°°1Ó5¼tÀE»{Ô K× PÑ PÓ RØIØ×!Ñ! " b¬*°cÕ:r+códdl}t|j«td«krTttj«td«k\r/|j    t
jjd¬««tjdgd¢i«}tjddtjd    gid
¬«}t|||d¬ «y)Nrú    2024.11.0z2.0.0z$fastparquet uses np.float_ in numpy2rrS)TNFrHgrrMF)rr)rrr·rZr4r.r5r6rCrDrxr)rÔr7r(rr]rs      r)Útest_bool_with_nonez*TestParquetFastParquet.test_bool_with_noneásªÛä;×*Ñ*Ó+¬g°kÓ.BÒBÄwÜNNóH
ä WÓ òHð ×ÑÜ×!Ñ!ØBð"óô ô
\\3Ò 3Ð4Ó 5Ü<<  s¬B¯F©F°CÐ&8Ð 9ÀÔKô    R¨(ÀÖFr+cóôtjdtjddd¬«i«}|j||td«tjdgd¢i«}d}|j||t|«y)NrSÚ2013ÚMr<rñrz"Can't infer object conversion type)rCrDrìr×r rNs    r)rz'TestParquetFastParquet.test_unsupportedòsdä \\3¤§¡°¸SÈ!Ô LÐMÓ Nà×!Ñ! " b¬*°dÔ;ô\\3¢ Ð.Ó /Ø2Ø×!Ñ! " b¬*°cÕ:r+cótjdtjtd««i«}t    ||«y)NrSrH)rCrDr¢rXr)rÔr7r]s   r)r¤z'TestParquetFastParquet.test_categoricalýs,Ü \\3¤§¡¬t°E«{Ó ;Ð<Ó =ÜRÕ r+códttd««i}tj|«}t    j
«5}|j ||dd¬«t||dg¬«}ddd«t«dk(sJy#1swYxYw)NrSr<r:)r*rÚrow_group_offsetsr
r)    rXrYrCrDrrrrr)rÔr7rUr]rrÅs      r)rz-TestParquetFastParquet.test_filter_row_groupssØ $uQx.Ð!Ü \\!_Ü __Ó ð    F $ØMM$ r°tÈqMÔQÜ! $¨°^Ð4DÔEF÷    Fô6{aÒÐÑ÷    Fð    FúsÁ%A>Á>Bc    óJt||d|jdd|id|d¬«y)Nr²z/fastparquet.parquetr±)rr±r©r³)rÔrFr«r7r¬s     r)r´z(TestParquetFastParquet.test_s3_roundtrip    s7ô    ØØØÐ)×.Ñ.Ð/Ð/CÐDØ*¨DÐ1Ø)-À$ÑGö    
r+cóðddg}|}|j|d|d¬«tjj|«sJddl}|j
t |«d«j}t|«dk(sJy)Nrurqr©r*rörrFr;©    rrrÚexistsrÚParquetFiler¤Úcatsr©rÔrùr7r|rör]rÚactual_partition_colss        r)rÎz4TestParquetFastParquet.test_partition_cols_supporteds{à  %Ø Ø
  ØØ Ø)Øð        ô    
ôww~~hÔ'Ð'Ð'Ûà 7 × 7Ñ 7¼¸H» ÀuÓ M× RÑ RÐÜÐ(Ó)¨QÒ.Ð.Ñ.r+cóìd}|}|j|d|d¬«tjj|«sJddl}|j
t |«d«j}t|«dk(sJy)NrurrZrFr:r[r_s        r)rÑz1TestParquetFastParquet.test_partition_cols_string$swàØ Ø
  ØØ Ø)Øð        ô    
ôww~~hÔ'Ð'Ð'Ûà 7 × 7Ñ 7¼¸H» ÀuÓ M× RÑ RÐÜÐ(Ó)¨QÒ.Ð.Ñ.r+cóðddg}|}|j|dd|¬«tjj|«sJddl}|j
t |«d«j}t|«dk(sJy)Nrurqr)r*rÚpartition_onrFr;r[r_s        r)Útest_partition_on_supportedz2TestParquetFastParquet.test_partition_on_supported4s{à  %Ø Ø
  ØØ ØØ'ð        ô    
ôww~~hÔ'Ð'Ð'Ûà 7 × 7Ñ 7¼¸H» ÀuÓ M× RÑ RÐÜÐ(Ó)¨QÒ.Ð.Ñ.r+có ddg}|}d}tjt|¬«5|j|dd||¬«ddd«y#1swYyxYw)NrurqzYCannot use both partition_on and partition_cols. Use partition_cols for partitioning datarr)r*rrcrö)r.rr r)rÔrùr7r|rör]r¡s       r)Ú3test_error_on_using_partition_cols_and_partition_onzJTestParquetFastParquet.test_error_on_using_partition_cols_and_partition_onDsað! %Ø ð  ð    ô]]:¨SÔ 1ñ    ØMMØØ$Ø Ø+Ø-ð ô ÷    ÷    ñ    ús¤AÁA zfastparquet writes into Indexrcóhtj«}|j«}t|||¬«y)Nrâ)rCrDrr©rÔr7r]rs    r)rÙz+TestParquetFastParquet.test_empty_dataframeWs&ô\\^Ø779ÜR¨(Ö3r+códdl}t|j«td«kDrPt|j«td«kr/|jtj
j d¬««d|gz}tj|d|i¬«}|j«}d    |j_t|||¬
«y)Nrz2022.12rPzCfastparquet bug, see https://github.com/dask/fastparquet/issues/929rr÷rørùrürâ) rrr·r4r.r5r6rCrDrrürÿr)rÔr7r~r(rrr]rs        r)rz0TestParquetFastParquet.test_timezone_aware_index^s±Ûä;×*Ñ*Ó+¬g°iÓ.@Ò@ÄWØ×#Ñ#óF
äKÓ òF!ð ×ÑÜ×!Ñ!ðIð"óô ðÐ+Ð,Ñ,ä \\ ¨>¸3Ð*?Ô @à779Ø%ÔÜR¨(Ö3r+cóþtjdddgi«}tj«5}|j    |«tjtd¬«5tjt«5t|dd¬«ddd«ddd«tjtd¬«5t|dd    ¬
«ddd«ddd«y#1swYLxYw#1swYPxYw#1swY*xYw#1swYyxYw)NrSr:r;z!not supported for the fastparquetrrT)r*Úuse_nullable_dtypesr rL)rCrDrrrr.rr rÍrÎr)rÔr7r]rs    r)Ú&test_use_nullable_dtypes_not_supportedz=TestParquetFastParquet.test_use_nullable_dtypes_not_supportedusáÜ \\3  A -Ó (ä __Ó ð    R $ØMM$ÔÜzÐ1TÔUñ WÜ×/Ñ/´ Ó>ñWÜ  ¨mÐQUÕV÷W÷ WôzÐ1TÔUñ RÜT¨-ÀyÕQ÷ R÷    Rð    R÷WðWú÷ Wð Wú÷ Rð Rú÷    Rð    RúsS®-C3ÁCÁ5CÂCÂ#C3Â/C'Â>C3ÃCÃCÃC$    Ã C3Ã'C0    Ã,C3Ã3C<códtjd«5}tj|«j    d«tjtd¬«5t|d¬«ddd«tj|«jd¬«ddd«y#1swY7xYw#1swYyxYw)    Nútest.parquetsbreakitÚrrrÂF)Ú
missing_ok)
rrrCrDÚwrite_bytesr.rÚ    ExceptionrÚunlink)rÔrs  r)Ú$test_close_file_handle_on_read_errorz;TestParquetFastParquet.test_close_file_handle_on_read_errorsÜ __^Ó ,ð    8°ÜLLÓ×*Ñ*¨:Ô6Üy°Ô3ñ 9ÜT¨-Õ8÷ 9ô LLÓ×%Ñ%°Ð%Ô7÷    8ð    8÷ 9ð 9ú÷    8ð    8ús$AB&ÁBÁ$-B&ÂB#    ÂB&Â&B/cóXtjddgddgd¬«}tjd«5}t    |j«d«5}|j |«ddd«t||¬«}ddd«tj|«y#1swY5xYw#1swY,xYw)Nrr:r>r.rnÚwbrÂ)    rCrDrrrfÚencoderrr)rÔr*r]rrWrÅs      r)Útest_bytes_file_namez+TestParquetFastParquet.test_bytes_file_namesä \\ a¨ V°1°a°&Ñ9Ô :Ü __^Ó ,ð    7°Üdkkm TÓ*ð !¨aØ  aÔ ÷ !ô" $¨vÔ6F÷        7ô
    ×Ñf bÕ)÷     !ð !ú÷    7ð    7ús#³B ÁBÁ B ÂB    ÂB Â B)cóXtjd«tjddgddgd¬«}t    j
«5}tjtd¬«5|j|dd¬    «ddd«ddd«t    j
«5}tj|«jd
«tjtd¬«5t|dd¬    «ddd«ddd«y#1swYxYw#1swYxYw#1swY*xYw#1swYyxYw)Nrrr:r>r.zfilesystem is not implementedrr=©r*r§rb) r.rTrCrDrrrrErrCrDrqr©rÔr]rs   r)Útest_filesystem_notimplementedz5TestParquetFastParquet.test_filesystem_notimplementedsÜ×ÑMÔ*Ü \\ a¨ V°1°a°&Ñ9Ô :Ü __Ó ð    L $ÜÜ#Ð+Jôñ Lð  d¨=ÀU ÔK÷ L÷    Lô__Ó ð    K $ÜLLÓ×*Ñ*¨6Ô2ÜÜ#Ð+Jôñ KôT¨-ÀEÕJ÷ K÷    Kð    K÷ Lð Lú÷    Lð    Lú÷ Kð Kú÷    Kð    KúóIÁDÁ#C<Á8DÂAD ÃDÃ+D Ã<D    ÄDÄDÄD    ÄD Ä D)cóXtjd«tjddgddgd¬«}t    j
«5}tjtd¬«5|j|dd¬    «ddd«ddd«t    j
«5}tj|«jd
«tjtd¬«5t|dd¬    «ddd«ddd«y#1swYxYw#1swYxYw#1swY*xYw#1swYyxYw)Nr rr:r>r.z1filesystem must be a pyarrow or fsspec FileSystemrr=rzrb) r.rTrCrDrrrr rrCrDrqrr{s   r)Útest_invalid_filesystemz.TestParquetFastParquet.test_invalid_filesystem¢sÜ×ÑIÔ&Ü \\ a¨ V°1°a°&Ñ9Ô :Ü __Ó ð    H $ÜÜÐ"Uôñ Hð  d¨9À ÔG÷ H÷    Hô__Ó ð    G $ÜLLÓ×*Ñ*¨6Ô2ÜÜÐ"Uôñ GôT¨)ÀÕF÷ G÷    Gð    G÷ Hð Hú÷    Hð    Hú÷ Gð Gú÷    Gð    Gúr}c    ótjd«}tjddgddgd¬«}t    j
«5}tjtd¬«5|j|d|j«d    d
i¬«ddd«ddd«t    j
«5}tj|«jd«tjtd¬«5t|d|j«d    d
i¬«ddd«ddd«y#1swYxYw#1swYxYw#1swY*xYw#1swYyxYw) Nz
pyarrow.fsrr:r>r.z8storage_options not supported with a pyarrow FileSystem.rr r=re)r*r§r±rb)r.rTrCrDrrrrErÚLocalFileSystemrCrDrqr)rÔÚpa_fsr]rs    r)Ú.test_unsupported_pa_filesystem_storage_optionszETestParquetFastParquet.test_unsupported_pa_filesystem_storage_options²s*Ü×#Ñ# LÓ1Ü \\ a¨ V°1°a°&Ñ9Ô :Ü __Ó ð
     $ÜÜ#ØPôñ     ð  ØØ$Ø$×4Ñ4Ó6Ø%*¨E Nð    ô÷         ÷
    ô__Ó ð     $ÜLLÓ×*Ñ*¨6Ô2ÜÜ#ØPôñ     ôØØ$Ø$×4Ñ4Ó6Ø%*¨E Nõ    ÷         ÷    ð    ÷     ð     ú÷
    ð
    ú÷     ð     ú÷    ð    úsIÁD*Á#&DÂ    D*Â-AEÃ- D6Ä EÄD'    Ä#D*Ä*D3Ä6D?    Ä;EÅEc    óLd}tjdttdd««i«}t    j
d«5}|j |«tjt|¬«5t|d¬«ddd«ddd«y#1swYxYw#1swYyxYw)    NzPdtype_backend numpy is invalid, only 'numpy_nullable' and 'pyarrow' are allowed.rqr:rIztmp.parquetrÚnumpy)rM)rCrDrXrYrrrr.rr r)rÔr*r¡r]rs     r)Útest_invalid_dtype_backendz1TestParquetFastParquet.test_invalid_dtype_backendÎsð %ð    ô\\5¤$¤u¨Q°£{Ó"3Ð4Ó 5Ü __]Ó +ð    :¨tØMM$ÔÜz°Ô5ñ :ÜT°Õ9÷ :÷    :ð    :÷ :ð :ú÷    :ð    :ús$Á-BÁ/BÁ=BÂB    ÂBÂB#cóÔtjtjgd¢d¬«¬«}tjtjgd¢d¬«¬«}t|||¬«y)Nr¡r*r$r#râr+rhs    r)r,z)TestParquetFastParquet.test_empty_columnsÙsBô\\¤§¡ª¸}Ô MÔ NÜ<<¤b§h¡hªÀ]Ô&SÔTÜR¨(Ö3r+N)rÛrÜrÝrzrLrrQrr¤rr.r5ror´rÎrÑrdrfrBrrÙrrlrtrxr|rrrr,r0r+r)rGrG¼sßò!ò4ò*;òGò"    ;ò!ò ð[[×Ññ
óð
ò/ò /ò /ò ð&[[×ÑÑ+Ó-Ð6UÐÓVñ4óWð4ò4ò.    Rò8ò*òKò Gò ò8    :ð[[×ÑÑ+Ó-Ð6UÐÓVñ4óWñ4r+rG)    NNNNNTFTr;)MÚ__doc__rvÚdecimalrr`rrrCrrZr.Úpandas._configrrÚpandas._config.configrÚ pandas.compatrÚpandas.compat.pyarrowr    r
rrr ÚpandasrCÚpandas._testingÚ_testingrÚpandas.util.versionrÚpandas.io.parquetrrrrrr r-r¸rr3r5ÚfilterwarningsÚ
pytestmarkÚfixturer&rBr6r*r1r7rFr^r|ÚnowrþrÿÚminÚmaxÚstrptimer~rrr¢r¨r«r¯r²r¿rÆrÉrÏrÑrßrqrGr0r+r)ú<module>rsuðÙÛÝÝÛ    ÛãÛ ÷õ.å-÷õóÝÝ'÷õðÛàMðÛàÐðKK×ÑÐSÓTØ
KK×ÑØGóð
ðàØà×"Ñ"Ø)Ð)òPÙ"Ð#6¸tÔDÈÑOØQð#óð
×!Ñ!Ù&Ó(Ø;Ø ð"óð ô    
ð    ØØ++×$Ñ$Ø!Ð!Ð*Dð%óô    
ð!ôñ2ó3ð2ðñóððñ    óð    ðñTóðTðñóðð"ñóðð.à×Ñ×Ñh×/Ñ/×3Ñ3Ó4Ø×Ñ×Ñh×/Ñ/×3Ñ3Ó4Ø×Ñ×Ñh×/Ñ/×3Ñ3Ó4Ø×Ñ×"Ñ"Ð#=Ð?TÓUØ×Ñ×"Ñ"Ð#=Ð?TÓUØ×Ñ×"Ñ"Ð#=Ð?TÓUØ×Ñ×"Ñ"Ð#=Ð?TÓUðô
ñó
ððØ     ØØØ ØØØØó?òD 9ò 2ò$ò$ò$òFò((#òV6ò
6ò(÷"?ñ?ôp-ôp-ôf    c0ôc0ôdb4Tõb4øðe$òØMðûðòØÓðús$Á$LÁ+LÌLÌLÌL)Ì(L)