
    ^iE                       U d dl mZ d dlmZ d dlmZ d dlZd dlZd dlm	Z	 d dl
Z
d dlmZmZ d dlZd dlmZ d dlmZmZmZ d d	lmZ d dlZd d
lmZmZmZmZmZmZ d dl m!Z!m"Z"m#Z# d dl$m%Z%m&Z& d dl'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z= d dl>m?Z?m@Z@ d dlAmBZBmCZCmDZDmEZE d dlFmGZGmHZHmIZI d dlJmKZK d dlLmMZM erd dlNmOZO d dlPmQZQmRZR g dZSdeTd<   g dZUdeTd<   eVddddgZWdeTd<   g d ZXdeTd!<   eSeWz   ZYeUeXz   ZZg eYeZZ[deTd"<   e\d#d$gZ]deTd%<   d&d'gZ^deTd(<   g e]e^Z_deTd)<   e`d*d+gZadeTd,<    e            r	d-gZbdeTd.<   n
ecd/d-gZbdeTd.<   g eae]ZddeTd0<   d1d2gZedeTd3<   d4d5gZfdeTd6<   egd7gZhdeTd8<   eid9gZjdeTd:<   ekd;gZldeTd<<   e]eYz   Zme^eZz   Zng emenZodeTd=<   g eoeaZpdeTd><   emeaz   ebz   eez   efz   ehz   elz   ejz   Zqejr        ejs        ejt        eju        ejv        ejw        ejx        ejy        gZzeceVe\e`e{e|e}e~eeegeieegZd?d@dAe	         Zdej        ej         e\dB          ej         edC          gZdD ej        ej        fD             Zerd dlZ ejw                     ejx                     ejy                     ej                    gZ ejt                     eju                     ejv                     ej                    gZeez   ZdE eD             Z ejs                     ej                    gZdF eD             Z ej        dGdH          gZ ej                    gZ ej                    gZ ej        dI           ej        dJ           ej        dK           ej        dL          gZ ej                     ej                    gZdM dND             ZdO dND             Z ej                    gZeez   ez   ez   ez   ez   ez   ez   ez   ez   Zeez   Zng Zg Zg Zg Ze]enz   ez   Zg dPZg dQZdsdtdTZdU Z G dV dWe          Z G dX dYe          Zdud]ZdvdaZdb ZdwdeZdf Zdg Zdh Zdi Zdj Zdk Zg dNZdxdnZdydoZdzdqZg drZdS ){    )annotations)ThreadPoolExecutor)DecimalN)	byteorder)TYPE_CHECKINGContextManager)using_string_dtype)can_set_localeget_locales
set_locale)HAS_PYARROW)
ArrowDtype	DataFrameIndex
MultiIndex
RangeIndexSeries)round_trip_pathlibround_trip_picklewrite_to_compressed)assert_produces_warningmaybe_produces_warning)assert_almost_equalassert_attr_equalassert_categorical_equalassert_class_equalassert_contains_allassert_copyassert_datetime_array_equalassert_dict_equalassert_equalassert_extension_array_equalassert_frame_equalassert_index_equal!assert_indexing_slices_equivalentassert_interval_array_equalassert_is_sortedassert_metadata_equivalentassert_numpy_array_equalassert_period_array_equalassert_series_equalassert_sp_array_equalassert_timedelta_array_equalraise_assert_detail)	get_dtypeget_obj)decompress_fileraises_chained_assignment_errorset_timezonewith_csv_dialect)ArrowExtensionArrayBaseMaskedArrayNumpyExtensionArray)NDArrayBackedExtensionArray)extract_array)Callable)DtypeNpDtype)uint8uint16uint32uint64zlist[NpDtype]UNSIGNED_INT_NUMPY_DTYPES)UInt8UInt16UInt32UInt64zlist[Dtype]UNSIGNED_INT_EA_DTYPESint8int16int32int64SIGNED_INT_NUMPY_DTYPES)Int8Int16Int32Int64SIGNED_INT_EA_DTYPESALL_INT_DTYPESfloat32float64FLOAT_NUMPY_DTYPESFloat32Float64FLOAT_EA_DTYPESALL_FLOAT_DTYPES	complex64
complex128COMPLEX_DTYPESUSTRING_DTYPESstrCOMPLEX_FLOAT_DTYPESzdatetime64[ns]zM8[ns]DATETIME64_DTYPESztimedelta64[ns]zm8[ns]TIMEDELTA64_DTYPESboolBOOL_DTYPESbytesBYTES_DTYPESobjectOBJECT_DTYPESALL_REAL_DTYPESALL_NUMERIC_DTYPES<>)littlebignanNaNc                0    g | ]}d D ]} |d|          S ))YMWDhmsmsusnspsfsasNaT ).0clsunits      C/usr/local/lib/python3.11/dist-packages/pandas/_testing/__init__.py
<listcomp>r      sM         	 Ct       c                F    g | ]}t          t          |                    S r   r^   r   r   typs     r   r   r      s3     ' ' '!$JsOO' ' 'r   c                F    g | ]}t          t          |                    S r   r   r   s     r   r   r      s3     % % %!$JsOO% % %r         rw   rx   ry   rz   c                D    g | ]}d D ]}t          j        ||          S ))NUTCz
US/Pacificz
US/Eastern)r   tz)pa	timestamp)r   r   r   s      r   r   r      sN       ;   	$2&&&   r   )rw   rx   ry   rz   c                6    g | ]}t          j        |          S r   )r   duration)r   r   s     r   r   r      s"    VVVdD 1 1VVVr   )__add____radd____sub____rsub____mul____rmul____floordiv____rfloordiv____truediv____rtruediv____pow____rpow____mod____rmod__)__eq____ne____le____lt____ge____gt__T	transposec                ~   |t           j        u rSt          | t                    r't	          t          j        | j                            } nt          j        | d          } n|t          u rt          | d          } n|t          u rt          |           } n|t          u rEt          |                                           } |r!| j        } t          j        | gdz  d          } nY|t
          j        u s|t
          j        u rt          j        |           } n(|t          u rt          |           } nt!          |          | S )z
    Helper function to wrap the expected output of a test in a given box_class.

    Parameters
    ----------
    expected : np.ndarray, Index, Series
    box_cls : {Index, Series, DataFrame}

    Returns
    -------
    subclass of box_cls
    F)copy   T)ignore_index)pdarray
isinstancer   r7   npasarray_valuesr   r   r   to_frameTconcatndarrayto_arrayNotImplementedError)expectedbox_clsr   s      r   box_expectedr     s6    "(h
++ 	6*2:h6F+G+GHHHHxu555HH	E		...	F		(##	I		(##,,.. 	D
  zHy(adCCCH	BJ		'RX"5"58H%%	H		H%%!'***Or   c                r    t          | dd          }|t          j        |           S t          | d          S )zQ
    Similar to pd.array, but does not cast numpy dtypes to nullable dtypes.
    dtypeNT)extract_numpy)getattrr   r   r9   )objr   s     r   r   r   ;  s;    
 C$''E}z#D1111r   c                  B    e Zd ZddgZed             Zed             ZdS )SubclassedSeriestestattrnamec                    d S )Nc                     t          | i |S Nr   argskwargss     r   <lambda>z/SubclassedSeries._constructor.<locals>.<lambda>R      '7'H'H'H r   r   selfs    r   _constructorzSubclassedSeries._constructorK  s     IHHr   c                    d S )Nc                     t          | i |S r   SubclassedDataFramer   s     r   r   z9SubclassedSeries._constructor_expanddim.<locals>.<lambda>V      ':D'KF'K'K r   r   r   s    r   _constructor_expanddimz'SubclassedSeries._constructor_expanddimT      KKKr   N)__name__
__module____qualname__	_metadatapropertyr   r   r   r   r   r   r   H  sZ        V$II I XI L L XL L Lr   r   c                  @    e Zd ZdgZed             Zed             ZdS )r   r   c                    d S )Nc                     t          | i |S r   r   r   s     r   r   z2SubclassedDataFrame._constructor.<locals>.<lambda>^  r   r   r   r   s    r   r   z SubclassedDataFrame._constructor\  r   r   c                    d S )Nc                     t          | i |S r   r   r   s     r   r   z9SubclassedDataFrame._constructor_sliced.<locals>.<lambda>c  r   r   r   r   s    r   _constructor_slicedz'SubclassedDataFrame._constructor_sliceda  s    HHHr   N)r   r   r   r   r   r   r   r   r   r   r   r   Y  sW        IL L XL I I XI I Ir   r   	rows_list	list[str]returnc                J    t           j        }|                    |           |z   S )aW  
    Convert list of CSV rows to single CSV-formatted string for current OS.

    This method is used for creating expected value of to_csv() method.

    Parameters
    ----------
    rows_list : List[str]
        Each element represents the row of csv.

    Returns
    -------
    str
        Expected output of to_csv() in current OS.
    )oslinesepjoin)r   seps     r   convert_rows_list_to_csv_strr   f  s"      *C88I$$r   expected_exceptiontype[Exception]r   c                8    ddl }|                    | d          S )a$  
    Helper function to mark pytest.raises that have an external error message.

    Parameters
    ----------
    expected_exception : Exception
        Expected error to raise.

    Returns
    -------
    Callable
        Regular `pytest.raises` function with `match` equal to `None`.
    r   N)match)pytestraises)r   r   s     r   external_error_raisedr   z  s$     MMM==+4=888r   c                J    g }|D ]\  }}|                     | ||f           |S )a  
    Combine frame, functions from com._cython_table
    keys and expected result.

    Parameters
    ----------
    ndframe : DataFrame or Series
    func_names_and_expected : Sequence of two items
        The first item is a name of an NDFrame method ('sum', 'prod') etc.
        The second item is the expected return value.

    Returns
    -------
    list
        List of three items (DataFrame, function, expected result)
    )append)ndframefunc_names_and_expectedresults	func_namer   s        r   get_cython_table_paramsr     s>    " G6 7 7	8H56666Nr   op_namer:   c                    |                      d          }	 t          t          |          }n2# t          $ r% t          t          |dd                   fd}Y nw xY w|S )z
    The operator function for a given op name.

    Parameters
    ----------
    op_name : str
        The op name, in form of "add" or "__add__".

    Returns
    -------
    function
        A function performing the operation.
    _   Nc                     ||           S r   r   )xyrops     r   r   z"get_op_from_name.<locals>.<lambda>  s    ##a)) r   )stripr   operatorAttributeError)r   short_opnameopr  s      @r   get_op_from_namer    sx     ==%%L$X|,, $ $ $hQRR 011####$
 Is   . ,AAc                    | S r   r   r   s    r   getitemr
        Hr   c                    | S r   r   r	  s    r   setitemr    r  r   c                    | j         S r   )locr	  s    r   r  r    	    5Lr   c                    | j         S r   )ilocr	  s    r   r  r    s	    6Mr   c                    | j         S r   )atr	  s    r   r  r    s	    4Kr   c                    | j         S r   )iatr	  s    r   r  r    r  r   leftrightc                v    t                               |           t                               |          k    r| S |S )z2
    Find the higher of two datetime64 units.
    )_UNITSindex)r  r  s     r   get_finest_unitr    s1     ||DV\\%0000Lr   c                   t          | t          j                  r/t          |t          j                  rt          j        | |          S t          | t          j                  rt          ||           S t          | t                    rdS t          | t
                    rt          | j        |          S t          | t          t          f          rKt          |t          t          f          rt          | j	        |j	                  S t          | j	        |          S t          | t                    rt          | j        |          S t          | t          j        j        j                  rt          | j        |          S t          | t          j        j        j                  r*t          | j        |          pt          | j        |          S t          | t(                    rt          |t(                    rx| j        }|j        }|                    d                                          d         }|                    d                                          d         }|j        |j        k    S t          j        | |          S t          | t2                    rSt          |t2                    r>t          j        | j        |j                  pt          j        | j        |j                  S t          | t8                    rDt;          | j        j                  dk    r'| j        j        d         j         }t          ||          S tC          tE          |           tE          |                    )z-
    Pandas-compat for np.shares_memory.
    Fr   r   )#r   r   r   shares_memoryr   r   _codesr   r   r   r8   _ndarrayr   corearraysSparseArray	sp_valuesIntervalArray_left_rightr5   	_pa_arraychunkbuffersaddressr6   _data_maskr   len_mgrblocksvaluesr   type)r  r  left_pa_dataright_pa_data	left_buf1
right_buf1arrs          r   r  r    s    $
## *
5"*(E(E *e,,,	D"*	%	% *UD)))$
## u$
## 1T[%000$(( 2eeV_-- 	> u}===T\5111$344 3T]E222$233 4T^U333$455 UTZ//T=e3T3TT$+,, 1e011 
	1>L!OM$**1--5577:I&,,Q//7799!<J$
(::: #D%000$(( 
Z-O-O 
 
EK88 
B<LJ=
 =
 	
 $	"" )s49+;'<'<'A'Aiq!(S%(((
d4jj$u++
6
66r   Fc           	        t          |          5 }|g }nt          |          }|r)t          j        |          }|                    |           	 g }t          |          D ]#}|                     |j        | g|R             $n7# t          $ r*}dd l}	|		                    d| d|d           Y d }~nd }~ww xY wt          |          |k     r|r|                                 n0# t          |          |k     r|r|                                 w w w xY w|D ]}
|
                                 	 d d d            d S # 1 swxY w Y   d S )N)max_workersr   z	Spawning z threads failed with error z@ (likely due to resource limits on the system running the tests))r   list	threadingBarrierr   rangesubmitRuntimeErrorr   skipr.  abortresult)closurer9  	argumentspass_barriertpebarrierfuturesr   er   fs              r   run_multithreadedrK    s    		4	4	4 IIYI 	&'44GW%%%	 G;'' @ @zsz'>I>>>????@ 	 	 	MMMKK,K , ,, , ,       	 7||k))l) 7||k))l) *) 	 	AHHJJJJ	3                 sN   A E 5BC)
B< B72C)7B<<C)?*E )-DE  EE)JALL_INT_EA_DTYPESALL_INT_NUMPY_DTYPESALL_NUMPY_DTYPESALL_REAL_NUMPY_DTYPESrc   re   r[   r`   ENDIANrW   rT   NARROW_NP_DTYPESNP_NAT_OBJECTSNULL_OBJECTSrg   rP   rK   r]   ra   rF   rA   r   r   r   r   r   r   r   r   r   r    r!   r"   r#   r$   r%   r&   r'   r(   r)   r*   r   r+   r,   r-   r  r   r
   r   r1   r   r   r/   r  r   r0   r  r
  r  r  r  r   r.   r2   r   r   rK  r   r3   r  r  r   r4   r   )T)r   rb   )r   r   r   r^   )r   r   r   r   )r   r^   r   r:   )r  r^   r  r^   r   r^   )r   rb   )NF)
__future__r   concurrent.futuresr   decimalr   r  r   sysr   r;  typingr   r   numpyr   pandas._configr	   pandas._config.localizationr
   r   r   pandas.compatr   pandasr   r   r   r   r   r   r   pandas._testing._ior   r   r   pandas._testing._warningsr   r   pandas._testing.assertersr   r   r   r   r   r   r   r    r!   r"   r#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   pandas._testing.compatr/   r0   pandas._testing.contextsr1   r2   r3   r4   pandas.core.arraysr5   r6   r7   pandas.core.arrays._mixinsr8   pandas.core.constructionr9   collections.abcr:   pandas._typingr;   r<   rA   __annotations__rF   intrK   rP   rM  rL  rQ   floatrT   rW   rX   complexr[   r]   r^   r_   r`   ra   rb   rc   rd   re   rf   rg   rO  ALL_REAL_EXTENSION_DTYPESrh   ri   rN  float16rR   rG   rH   rI   r=   r>   r?   rQ  r:  tupler=  dictset	frozenset	bytearray
memoryviewPYTHON_DATA_TYPESrP  rn   r~   NArS  
datetime64timedelta64rR  pyarrowr   r@   UNSIGNED_INT_PYARROW_DTYPESrJ   SIGNED_INT_PYARROW_DTYPESALL_INT_PYARROW_DTYPESALL_INT_PYARROW_DTYPES_STR_REPRrS   FLOAT_PYARROW_DTYPESFLOAT_PYARROW_DTYPES_STR_REPR
decimal128DECIMAL_PYARROW_DTYPESstringSTRING_PYARROW_DTYPESbinaryBINARY_PYARROW_DTYPEStime32time64TIME_PYARROW_DTYPESdate32date64DATE_PYARROW_DTYPESDATETIME_PYARROW_DTYPESTIMEDELTA_PYARROW_DTYPESbool_BOOL_PYARROW_DTYPESALL_PYARROW_DTYPES ALL_REAL_PYARROW_DTYPES_STR_REPRALL_REAL_NULLABLE_DTYPESarithmetic_dunder_methodscomparison_dunder_methodsr   r   r   r   r   r   r   r  r
  r  r  r  r  r  r  r  r  rK  __all__r   r   r   <module>r     s
   " " " " " " " 1 1 1 1 1 1        				                 
     - - - - - -          & % % % % %                            
                                                      0                           
 C B B B B B 2 2 2 2 2 2 ((((((        ,S+R+R  R R R R&M&M&M  M M M M*-vw)Q  Q Q Q Q$G$G$G  G G G G03JJ *-AA I 4I7HI I I I I%*Iy$A  A A A A )95 5 5 5 5 G"4 G G  G G G G&\B B B B B 3"%M&&&&&"%uc!2M2222$Jn$J7I$J  J J J J"2H!=  = = = =#4h"?  ? ? ? ? &> ) ) ) )"G, , , , ,$h/ / / / /*-AA +.?? S!6S9RS S S S S"EO"En"E  E E E E   	
     JJGHHHII	  				 " 	$	$Y	/bfbfeeEllBE775>>J r~.  (  9*#+28::yry{{IBIKK"U!(HBHJJ

HBHJJ O8;TT' '(>' ' '# 'BJLL*"*,,7% %(<% % %! ,bmAq112&RY[[M&RY[[M 		#	$	$	$	 %29;;		4 +  
  WV>UVVV#28::,
 	
	
 	!  	   		 
 	 	 "	" #	# 		  	(*GG %$ %'!&(#')$ 225UU    " YXX & & & & &R
2 
2 
2L L L L Lv L L L"
I 
I 
I 
I 
I) 
I 
I 
I% % % %(9 9 9 9&  .   :             
!	 	    27 27 27 27j   <K K Kr   