§
    Šhþh±>  ã                  ó¶  — U d dl mZ d dlmZmZmZmZ d dlm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mZmZmZmZmZmZ d dlmZmZmZmZmZm Z  d dl!m"Z" d dl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z. e
r‰d d	l/m0Z0 d d
l1m2Z2 d dl3m4Z4 d dl5Z6d dl7Z8d dl9Z:d dl;m<Z<m=Z= d dl>m?Z?m@Z@ d dlAmBZB d dlCmDZD d dlmEZE d dlFmGZGmHZH d dl#mIZImJZJ d dlKmLZL d dlMmNZN d dlOmPZP d dlQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_ eZ`dead<   g d¢Zb ed¦  «        ZcdZddead<    ed¦  «        Ze G d„ d e&ee         eee         ee          eeeee f         ¦  «        Zf G d!„ d"ed#         ed$eegef         f         ed%         eefeee f         eeeee f         ¦  «        Zh G d&„ d'efeee f         eeee f         ¦  «        Zi G d(„ d)eheeed*f         eiedd*f         e$eeeeef         ¦  «        ZjdS )+é    )Úannotations)ÚIteratorÚMappingÚSequenceÚSized)Úchain)ÚTYPE_CHECKINGÚAnyÚLiteralÚProtocolÚTypeVarÚoverload)	ÚCompliantDataFrameAnyÚCompliantExprT_contraÚCompliantLazyFrameAnyÚCompliantSeriesTÚ
EagerExprTÚEagerSeriesTÚNativeDataFrameTÚNativeLazyFrameTÚNativeSeriesT)ÚArrowConvertibleÚDictConvertibleÚ
FromNativeÚNumpyConvertibleÚ
ToNarwhalsÚToNarwhalsT_co)Úassert_never)ÚValidateBackendVersionÚVersionÚ_StoresNativeÚcheck_columns_existÚis_compliant_seriesÚis_index_selectorÚis_rangeÚis_sequence_likeÚis_sized_multi_index_selectorÚis_slice_indexÚis_slice_none)ÚBytesIO)ÚPath)Ú
ModuleTypeN)ÚSelfÚ	TypeAlias)ÚCompliantGroupByÚDataFrameGroupBy)ÚEagerNamespace)ÚSparkSession)ÚIntoArrowTable)Ú_EagerAllowedImplÚ_LazyAllowedImpl)ÚImplementationÚ_LimitedContext)Ú	DataFrame)ÚDType)ÚColumnNotFoundError)ÚAsofJoinStrategyÚ
IntoSchemaÚJoinStrategyÚMultiColSelectorÚMultiIndexSelectorÚPivotAggÚSingleIndexSelectorÚSizedMultiIndexSelectorÚSizedMultiNameSelectorÚSizeUnitÚUniqueKeepStrategyÚ_2DArrayÚ_SliceIndexÚ
_SliceNamer.   Ú
Incomplete)ÚCompliantDataFrameÚCompliantFrameÚCompliantLazyFrameÚEagerDataFrameÚTú2dict[str, CompliantSeriesT] | dict[str, list[Any]]Ú_ToDictÚ_NativeFrameTc                  óB  — e Zd ZU dZded<   ded<   ded<   dWd
„ZdXd„ZdYd„ZdZd„Ze	d[d„¦   «         Z
ed\d„¦   «         Zed]d„¦   «         Zed^d„¦   «         Zd^d„Zd_d„Zd`d"„Zdad#„Zdbd&„Zdcd+„Zddd.„Zded6„Zdfd;„Zdgd>„ZdhdA„ZdidC„ZdjdH„ZdddI„ZdkdM„ZdldR„ZdhdS„ZdmdU„Z dVS )nrK   z)Common parts of `DataFrame`, `LazyFrame`.rQ   Ú_native_framer6   Ú_implementationr    Ú_versionÚreturnr,   c                ó   — d S ©N© ©Úselfs    úT/var/www/histauto/venv/lib/python3.11/site-packages/narwhals/_compliant/dataframe.pyÚ__native_namespace__z#CompliantFrame.__native_namespace__d   ó   € € € ó    r
   c                ó   — d S rX   rY   rZ   s    r\   Ú__narwhals_namespace__z%CompliantFrame.__narwhals_namespace__e   r^   r_   Údfr-   c                ó   — d S rX   rY   )r[   rb   s     r\   Ú_with_nativezCompliantFrame._with_nativef   r^   r_   Úversionc                ó   — d S rX   rY   )r[   re   s     r\   Ú_with_versionzCompliantFrame._with_versiong   r^   r_   ÚdataÚcontextr7   c              ó   — d S rX   rY   ©Úclsrh   ri   s      r\   Úfrom_nativezCompliantFrame.from_nativeh   ó   € ØWZÐWZr_   úSequence[str]c                ó   — d S rX   rY   rZ   s    r\   ÚcolumnszCompliantFrame.columnsj   ó   € Ø(+¨r_   c                ó   — | j         S rX   )rS   rZ   s    r\   ÚnativezCompliantFrame.nativel   s   € àÔ!Ð!r_   úMapping[str, DType]c                ó   — d S rX   rY   rZ   s    r\   ÚschemazCompliantFrame.schemap   s   € Ø-0¨Sr_   c                ó   — d S rX   rY   rZ   s    r\   Úcollect_schemazCompliantFrame.collect_schemas   r^   r_   rq   ÚstrictÚboolc               ó   — d S rX   rY   )r[   rq   rz   s      r\   ÚdropzCompliantFrame.dropt   r^   r_   ÚsubsetúSequence[str] | Nonec                ó   — d S rX   rY   ©r[   r~   s     r\   Ú
drop_nullszCompliantFrame.drop_nullsu   r^   r_   c                ó   — d S rX   rY   ©r[   rq   s     r\   ÚexplodezCompliantFrame.explodev   r^   r_   Ú	predicateú"CompliantExprT_contra | Incompletec                ó   — d S rX   rY   )r[   r†   s     r\   ÚfilterzCompliantFrame.filterw   r^   r_   Úkeysú/Sequence[str] | Sequence[CompliantExprT_contra]Údrop_null_keysú-CompliantGroupBy[Self, CompliantExprT_contra]c               ó   — d S rX   rY   ©r[   rŠ   rŒ   s      r\   Úgroup_byzCompliantFrame.group_byx   s	   € ð
 9<¸r_   ÚnÚintc                ó   — d S rX   rY   ©r[   r‘   s     r\   ÚheadzCompliantFrame.head~   r^   r_   ÚotherÚhowr=   Úleft_onÚright_onÚsuffixÚstrc               ó   — d S rX   rY   )r[   r–   r—   r˜   r™   rš   s         r\   ÚjoinzCompliantFrame.join   ó	   € ð ˆsr_   Úby_leftÚby_rightÚstrategyr;   c               ó   — d S rX   rY   )r[   r–   r˜   r™   rŸ   r    r¡   rš   s           r\   Ú	join_asofzCompliantFrame.join_asofˆ   s	   € ð ˆsr_   ÚmappingúMapping[str, str]c                ó   — d S rX   rY   )r[   r¤   s     r\   ÚrenamezCompliantFrame.rename“   r^   r_   Úexprsr   c                ó   — d S rX   rY   ©r[   r¨   s     r\   ÚselectzCompliantFrame.select”   r^   r_   Úcolumn_namesc                ó   — dS )z)`select` where all args are column names.NrY   )r[   r¬   s     r\   Úsimple_selectzCompliantFrame.simple_select•   ó   € àˆr_   ÚbyÚ
descendingúbool | Sequence[bool]Ú
nulls_lastc               ó   — d S rX   rY   )r[   r±   r³   r°   s       r\   ÚsortzCompliantFrame.sort™   ó   € àˆsr_   c                ó   — d S rX   rY   r”   s     r\   ÚtailzCompliantFrame.tailœ   r^   r_   ÚkeeprE   Úorder_byc               ó   — d S rX   rY   )r[   r~   r¹   rº   s       r\   ÚuniquezCompliantFrame.unique�   ó	   € ð ˆsr_   ÚonÚindexÚvariable_nameÚ
value_namec                ó   — d S rX   rY   )r[   r¾   r¿   rÀ   rÁ   s        r\   ÚunpivotzCompliantFrame.unpivot¤   r½   r_   c                ó   — d S rX   rY   rª   s     r\   Úwith_columnszCompliantFrame.with_columns«   r^   r_   Únamec                ó   — d S rX   rY   ©r[   rÆ   rº   s      r\   Úwith_row_indexzCompliantFrame.with_row_index¬   r^   r_   N)rV   r,   )rV   r
   )rb   rQ   rV   r-   )re   r    rV   r-   )rh   rQ   ri   r7   rV   r-   )rV   ro   )rV   rQ   )rV   ru   )rq   ro   rz   r{   rV   r-   )r~   r   rV   r-   )rq   ro   rV   r-   )r†   r‡   rV   r-   )rŠ   r‹   rŒ   r{   rV   r�   )r‘   r’   rV   r-   )r–   r-   r—   r=   r˜   r   r™   r   rš   r›   rV   r-   )r–   r-   r˜   r›   r™   r›   rŸ   r   r    r   r¡   r;   rš   r›   rV   r-   )r¤   r¥   rV   r-   ©r¨   r   rV   r-   )r¬   r›   rV   r-   )r°   r›   r±   r²   r³   r{   rV   r-   )r~   r   r¹   rE   rº   r   rV   r-   )
r¾   r   r¿   r   rÀ   r›   rÁ   r›   rV   r-   )rÆ   r›   rº   ro   rV   r-   )!Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú__annotations__r]   ra   rd   rg   Úclassmethodrm   Úpropertyrq   rt   rw   ry   r}   r‚   r…   r‰   r�   r•   r�   r£   r§   r«   r®   rµ   r¸   r¼   rÃ   rÅ   rÉ   rY   r_   r\   rK   rK   X   sé  € € € € € € ð 4Ð3à Ð Ð Ñ Ø#Ð#Ð#Ñ#ØÐÐÑà5Ð5Ð5Ð5Ø0Ð0Ð0Ð0Ø:Ð:Ð:Ð:Ø:Ð:Ð:Ð:ØØZÐZÐZñ „[ØZØØ+Ð+Ð+ñ „XØ+Øð"ð "ð "ñ „Xð"ð Ø0Ð0Ð0ñ „XØ0à8Ð8Ð8Ð8ØHÐHÐHÐHØCÐCÐCÐCØ:Ð:Ð:Ð:ØPÐPÐPÐPð<ð <ð <ð <ð (Ð'Ð'Ð'ðð ð ð ð
ð 
ð 
ð 
ð >Ð=Ð=Ð=Ø@Ð@Ð@Ð@ðð ð ð ðð ð ð ð (Ð'Ð'Ð'ðð ð ð ðð ð ð ð GÐFÐFÐFØMÐMÐMÐMÐMÐMr_   rK   c                  ó´  — e Zd Zdud„Zedvd„¦   «         Zedwd„¦   «         Zedxd„¦   «         Zedyd„¦   «         Zdzd„Z	d{d„Z
ed|d„¦   «         Zdud„Zd}d „Zd~d$„Zdd(„Zd€d.„Zd�d3„Zd‚d5„Zdƒd9„Zd„d:„Zd…d@„Zd†dJ„Zd‡dL„ZdˆdN„Zd‰dS„ZdŠdU„Zd‹dW„ZdŒdY„Zed�d]„¦   «         ZedŽd`„¦   «         Zd�db„Zdcddœd�dj„Z d‘dk„Z!ed’dn„¦   «         Z"ed“dp„¦   «         Z"d”ds„Z"d“dt„Z#dcS )•rJ   rV   r-   c                ó   — d S rX   rY   rZ   s    r\   Ú__narwhals_dataframe__z)CompliantDataFrame.__narwhals_dataframe__·   r^   r_   rh   r3   ri   r7   c              ó   — d S rX   rY   rk   s      r\   Ú
from_arrowzCompliantDataFrame.from_arrow¸   rn   r_   úMapping[str, Any]rw   úIntoSchema | Nonec              ó   — d S rX   rY   ©rl   rh   ri   rw   s       r\   Ú	from_dictzCompliantDataFrame.from_dictº   rž   r_   úSequence[Mapping[str, Any]]c              ó   — d S rX   rY   rÚ   s       r\   Ú
from_dictszCompliantDataFrame.from_dictsÃ   rž   r_   rF   ú!IntoSchema | Sequence[str] | Nonec              ó   — d S rX   rY   rÚ   s       r\   Ú
from_numpyzCompliantDataFrame.from_numpyÌ   rž   r_   Údtyper
   Úcopyúbool | Nonec               ó   — d S rX   rY   )r[   râ   rã   s      r\   Ú	__array__zCompliantDataFrame.__array__Õ   r^   r_   Úitemúetuple[SingleIndexSelector | MultiIndexSelector[CompliantSeriesT], MultiColSelector[CompliantSeriesT]]c                ó   — d S rX   rY   )r[   rç   s     r\   Ú__getitem__zCompliantDataFrame.__getitem__Ö   r½   r_   útuple[int, int]c                ó   — d S rX   rY   rZ   s    r\   ÚshapezCompliantDataFrame.shapeÞ   rr   r_   c                ó   — d S rX   rY   rZ   s    r\   ÚclonezCompliantDataFrame.cloneà   r^   r_   ÚunitrD   úint | floatc                ó   — d S rX   rY   )r[   rð   s     r\   Úestimated_sizez!CompliantDataFrame.estimated_sizeá   r^   r_   r‘   r’   Úoffsetc                ó   — d S rX   rY   )r[   r‘   rô   s      r\   Úgather_everyzCompliantDataFrame.gather_everyâ   r^   r_   rÆ   r›   r   c                ó   — d S rX   rY   )r[   rÆ   s     r\   Ú
get_columnzCompliantDataFrame.get_columnã   r^   r_   rŠ   r‹   rŒ   r{   úDataFrameGroupBy[Self, Any]c               ó   — d S rX   rY   r�   s      r\   r�   zCompliantDataFrame.group_byä   s	   € ð
 '* cr_   Úrowú
int | NoneÚcolumnúint | str | Nonec                ó   — d S rX   rY   )r[   rû   rý   s      r\   rç   zCompliantDataFrame.itemê   r^   r_   úIterator[CompliantSeriesT]c                ó   — d S rX   rY   rZ   s    r\   Úiter_columnszCompliantDataFrame.iter_columnsë   r^   r_   ÚnamedÚbuffer_sizeú7Iterator[tuple[Any, ...]] | Iterator[Mapping[str, Any]]c               ó   — d S rX   rY   )r[   r  r  s      r\   Ú	iter_rowszCompliantDataFrame.iter_rowsì   ó   € àBEÀ#r_   c                ó   — d S rX   rY   rZ   s    r\   Ú	is_uniquezCompliantDataFrame.is_uniqueï   r^   r_   Úbackendú_LazyAllowedImpl | NoneÚsessionúSparkSession | Noner   c               ó   — d S rX   rY   )r[   r  r  s      r\   ÚlazyzCompliantDataFrame.lazyð   ó   € à # r_   r¾   ro   r¿   r   ÚvaluesÚaggregate_functionúPivotAgg | NoneÚsort_columnsÚ	separatorc               ó   — d S rX   rY   )r[   r¾   r¿   r  r  r  r  s          r\   ÚpivotzCompliantDataFrame.pivotó   s	   € ð ˆsr_   útuple[Any, ...]c                ó   — d S rX   rY   )r[   r¿   s     r\   rû   zCompliantDataFrame.rowý   r^   r_   ú7Sequence[tuple[Any, ...]] | Sequence[Mapping[str, Any]]c               ó   — d S rX   rY   )r[   r  s     r\   ÚrowszCompliantDataFrame.rowsþ   r  r_   Úfractionúfloat | NoneÚwith_replacementÚseedc               ó   — d S rX   rY   )r[   r‘   r  r   r!  s        r\   ÚsamplezCompliantDataFrame.sample  ó	   € ð ˆsr_   úpa.Tablec                ó   — d S rX   rY   rZ   s    r\   Úto_arrowzCompliantDataFrame.to_arrow	  r^   r_   úpd.DataFramec                ó   — d S rX   rY   rZ   s    r\   Ú	to_pandaszCompliantDataFrame.to_pandas
  r^   r_   úpl.DataFramec                ó   — d S rX   rY   rZ   s    r\   Ú	to_polarszCompliantDataFrame.to_polars  r^   r_   Ú	as_seriesúLiteral[True]údict[str, CompliantSeriesT]c               ó   — d S rX   rY   ©r[   r.  s     r\   Úto_dictzCompliantDataFrame.to_dict  s   € ØSVÐSVr_   úLiteral[False]údict[str, list[Any]]c               ó   — d S rX   rY   r2  s     r\   r3  zCompliantDataFrame.to_dict  s   € ØMPÈSr_   rO   c               ó   — d S rX   rY   r2  s     r\   r3  zCompliantDataFrame.to_dict  s   € à=@¸Sr_   N)Úmaintain_orderr~   r¹   rE   r8  rº   c               ó   — d S rX   rY   )r[   r~   r¹   r8  rº   s        r\   r¼   zCompliantDataFrame.unique  r$  r_   c                ó   — d S rX   rY   rÈ   s      r\   rÉ   z!CompliantDataFrame.with_row_index  r^   r_   ÚfileÚNonec                ó   — d S rX   rY   ©r[   r;  s     r\   Ú	write_csvzCompliantDataFrame.write_csv  s   € Ø,/¨Cr_   ústr | Path | BytesIOc                ó   — d S rX   rY   r>  s     r\   r?  zCompliantDataFrame.write_csv  s   € Ø=@¸Sr_   ústr | Path | BytesIO | Noneú
str | Nonec                ó   — d S rX   rY   r>  s     r\   r?  zCompliantDataFrame.write_csv   r^   r_   c                ó   — d S rX   rY   r>  s     r\   Úwrite_parquetz CompliantDataFrame.write_parquet!  r^   r_   ©rV   r-   )rh   r3   ri   r7   rV   r-   )rh   r×   ri   r7   rw   rØ   rV   r-   )rh   rÜ   ri   r7   rw   rØ   rV   r-   )rh   rF   ri   r7   rw   rß   rV   r-   )râ   r
   rã   rä   rV   rF   )rç   rè   rV   r-   )rV   rë   )rð   rD   rV   rñ   )r‘   r’   rô   r’   rV   r-   )rÆ   r›   rV   r   )rŠ   r‹   rŒ   r{   rV   rù   )rû   rü   rý   rþ   rV   r
   )rV   r   )r  r{   r  r’   rV   r  )rV   r   )r  r  r  r  rV   r   )r¾   ro   r¿   r   r  r   r  r  r  r{   r  r›   rV   r-   )r¿   r’   rV   r  )r  r{   rV   r  )
r‘   rü   r  r  r   r{   r!  rü   rV   r-   )rV   r%  )rV   r(  )rV   r+  )r.  r/  rV   r0  )r.  r4  rV   r5  )r.  r{   rV   rO   )
r~   r   r¹   rE   r8  rä   rº   r   rV   r-   )rÆ   r›   rº   r   rV   r-   )r;  r<  rV   r›   ©r;  r@  rV   r<  )r;  rB  rV   rC  )$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'  r*  r-  r   r3  r¼   rÉ   r?  rF  rY   r_   r\   rJ   rJ   ¯   s”  € € € € € ð 2Ð1Ð1Ð1ØØZÐZÐZñ „[ØZØðð ð ñ „[ðð ðð ð ñ „[ðð ðð ð ñ „[ðð KÐJÐJÐJðð ð ð ð Ø+Ð+Ð+ñ „XØ+Ø Ð Ð Ð Ø@Ð@Ð@Ð@Ø<Ð<Ð<Ð<Ø<Ð<Ð<Ð<ð*ð *ð *ð *ð JÐIÐIÐIØ=Ð=Ð=Ð=ðFð Fð Fð Fð 1Ð0Ð0Ð0ð$ð $ð $ð $ð	ð 	ð 	ð 	ð 6Ð5Ð5Ð5ðFð Fð Fð Fðð ð ð ð (Ð'Ð'Ð'Ø,Ð,Ð,Ð,Ø,Ð,Ð,Ð,ØØVÐVÐVñ „XØVØØPÐPÐPñ „XØPðAð Að Að Að '+ðð ð ð ð ð ð UÐTÐTÐTØØ/Ð/Ð/ñ „XØ/ØØ@Ð@Ð@ñ „XØ@ØMÐMÐMÐMØDÐDÐDÐDÐDÐDr_   rJ   )rF   rF   z_ToDict[CompliantSeriesT])r%  r3   c                  ó6   — e Zd Zdd„Zdd„Zdd„Zdd„Zdd„ZdS )rL   rV   r-   c                ó   — d S rX   rY   rZ   s    r\   Ú__narwhals_lazyframe__z)CompliantLazyFrame.__narwhals_lazyframe__(  r^   r_   úIterator[Any]c                ó   — d S rX   rY   rZ   s    r\   Ú_iter_columnsz CompliantLazyFrame._iter_columns*  r^   r_   r¨   r   c                ó   — dS )zk`select` where all args are aggregations or literals.

        (so, no broadcasting is necessary).
        NrY   rª   s     r\   Ú	aggregatezCompliantLazyFrame.aggregate+  s	   € ð
 	ˆr_   r  ú_EagerAllowedImpl | NoneÚkwargsr
   r   c                ó   — d S rX   rY   )r[   r  rR  s      r\   ÚcollectzCompliantLazyFrame.collect2  r  r_   r;  r@  r<  c                ó   — d S rX   rY   r>  s     r\   Úsink_parquetzCompliantLazyFrame.sink_parquet5  r^   r_   NrG  )rV   rL  rÊ   )r  rQ  rR  r
   rV   r   rH  )rË   rÌ   rÍ   rK  rN  rP  rT  rV  rY   r_   r\   rL   rL   $  sa   € € € € € ð 2Ð1Ð1Ð1à1Ð1Ð1Ð1ðð ð ð ð$ð $ð $ð $ð DÐCÐCÐCÐCÐCr_   rL   c                  óÌ   — e Zd Zed9d„¦   «         Zd:d„Zd;d„Zd<d„Zddœd=d„Zd>d„Z	d?d„Z
d@d„ZdAd„ZdBd„ZedCd%„¦   «         ZdDd(„ZdEd*„ZdFd+„ZdGd-„ZdHd.„ZdId0„ZdJd3„ZdKd7„Zd8S )LrM   rV   útuple[int, ...]c                ó4   — | j                              ¦   «         S rX   )rT   Ú_backend_versionrZ   s    r\   rZ  zEagerDataFrame._backend_version@  s   € àÔ#×4Ò4Ñ6Ô6Ð6r_   úOEagerNamespace[Self, EagerSeriesT, EagerExprT, NativeDataFrameT, NativeSeriesT]c                ó   — d S rX   rY   rZ   s    r\   ra   z%EagerDataFrame.__narwhals_namespace__D  s	   € ð €sr_   úDataFrame[NativeDataFrameT]c                ó:   — | j                              | d¬¦  «        S )NÚfull)Úlevel)rU   Ú	dataframerZ   s    r\   Úto_narwhalszEagerDataFrame.to_narwhalsJ  s   € ØŒ}×&Ò& t°6Ð&Ñ:Ô:Ð:r_   r¨   r   r-   c                ó   —  | j         |Ž S rX   )r«   rª   s     r\   rP  zEagerDataFrame.aggregateM  s   € ð ˆtŒ{˜EÐ"Ð"r_   T)Úvalidate_column_namesrb   r   rd  r{   c               ó   — d S rX   rY   )r[   rb   rd  s      r\   rd   zEagerDataFrame._with_nativeW  r¶   r_   r~   ro   úColumnNotFoundError | Nonec                ó.   — t          || j        ¬¦  «        S )N)Ú	available)r"   rq   r�   s     r\   Ú_check_columns_existz#EagerDataFrame._check_columns_exist[  s   € Ý" 6°T´\ÐBÑBÔBÐBr_   Úexprr   c               óR   —  || ¦  «        }t          |¦  «        dk    sJ ‚|d         S )z6Evaluate `expr` and ensure it has a **single** output.é   r   )Úlen)r[   rj  Úresults      r\   Ú_evaluate_exprzEagerDataFrame._evaluate_expr^  s0   € à)-¨¨d©¬ˆÝ�6‰{Œ{˜aÒÐÐÐØ�aŒyÐr_   úSequence[EagerSeriesT]c                ó^   ‡ — t          t          j        ˆ fd„|D ¦   «         ¦  «        ¦  «        S )Nc              3  óB   •K  — | ]}‰                      |¦  «        V — Œd S rX   )Ú_evaluate_into_expr)Ú.0rj  r[   s     €r\   ú	<genexpr>z6EagerDataFrame._evaluate_into_exprs.<locals>.<genexpr>i  s1   øè è € ÐQÐQÀ4 × 8Ò 8¸Ñ >Ô >ÐQÐQÐQÐQÐQÐQr_   )Útupler   Úfrom_iterablerª   s   ` r\   Ú_evaluate_into_exprsz#EagerDataFrame._evaluate_into_exprsd  s:   ø€ õ ÝÔÐQÐQÐQÐQÈ5ÐQÑQÔQÑQÔQñ
ô 
ð 	
r_   c               ó²   — |                      | ¦  «        } || ¦  «        }t          |¦  «        d„ |D ¦   «         x}k    rd|› d|› �}t          |¦  «        ‚|S )a†  Return list of raw columns.

        For eager backends we alias operations at each step.

        As a safety precaution, here we can check that the expected result names match those
        we were expecting from the various `evaluate_output_names` / `alias_output_names` calls.

        Note that for PySpark / DuckDB, we are less free to liberally set aliases whenever we want.
        c                ó   — g | ]	}|j         ‘Œ
S rY   )rÆ   )rt  Úss     r\   ú
<listcomp>z6EagerDataFrame._evaluate_into_expr.<locals>.<listcomp>y  s   € Ð6Ð6Ð6¨!˜qœvÐ6Ð6Ð6r_   z"Safety assertion failed, expected z, got )Ú_evaluate_aliasesÚlistÚAssertionError)r[   rj  Úaliasesrn  Úresult_aliasesÚmsgs         r\   rs  z"EagerDataFrame._evaluate_into_exprl  sx   € ð ×(Ò(¨Ñ.Ô.ˆØ��d‘”ˆÝ�‰=Œ=Ø6Ð6¨vÐ6Ñ6Ô6Ð6ˆNò
ð 
ð W°wÐVÐVÀnÐVÐVˆCÝ  Ñ%Ô%Ð%Øˆr_   r–   r
   c               ó   — dS )z@Extract native Series, broadcasting to `len(self)` if necessary.NrY   )r[   r–   s     r\   Ú_extract_comparandz!EagerDataFrame._extract_comparand  r¯   r_   rh   rF   rq   r   ú	list[str]c               óh   — t          |p#d„ t          | j        d         ¦  «        D ¦   «         ¦  «        S )Nc              3  ó    K  — | ]	}d |› �V — Œ
dS )Úcolumn_NrY   )rt  Úxs     r\   ru  z5EagerDataFrame._numpy_column_names.<locals>.<genexpr>‡  s(   è è € ÐLÐL°! ¨!  ÐLÐLÐLÐLÐLÐLr_   rl  )r~  Úrangerí   )rh   rq   s     r\   Ú_numpy_column_namesz"EagerDataFrame._numpy_column_namesƒ  s4   € õ �GÐLÐLÐLµu¸T¼ZÈ¼]Ñ7KÔ7KÐLÑLÔLÑMÔMÐMr_   r  ú&SizedMultiIndexSelector[NativeSeriesT]c                ó   — d S rX   rY   ©r[   r  s     r\   Ú_gatherzEagerDataFrame._gather‰  r^   r_   ú_SliceIndex | rangec                ó   — d S rX   rY   rŽ  s     r\   Ú_gather_slicezEagerDataFrame._gather_sliceŠ  r^   r_   c                ó   — d S rX   rY   r„   s     r\   Ú_select_multi_indexz"EagerDataFrame._select_multi_index‹  r¶   r_   ú%SizedMultiNameSelector[NativeSeriesT]c                ó   — d S rX   rY   r„   s     r\   Ú_select_multi_namez!EagerDataFrame._select_multi_nameŽ  r¶   r_   c                ó   — d S rX   rY   r„   s     r\   Ú_select_slice_indexz"EagerDataFrame._select_slice_index‘  r^   r_   rH   c                ó   — d S rX   rY   r„   s     r\   Ú_select_slice_namez!EagerDataFrame._select_slice_name’  r^   r_   rç   ú]tuple[SingleIndexSelector | MultiIndexSelector[EagerSeriesT], MultiColSelector[EagerSeriesT]]c                óZ  — |\  }}| }t          |¦  «        �sHt          |t          ¦  «        r't          |¦  «        dk    r|                     ¦   «         S t          |¦  «        rtt          |¦  «        st          |¦  «        r|                     |¦  «        }nÉt          |¦  «        r|  
                    |j        ¦  «        }nŸ| 
                    |¦  «        }n‰t          |t          ¦  «        r|                     |¦  «        }n^t          |¦  «        r|                      |j        ¦  «        }n4t          |¦  «        r|                      |¦  «        }nt!          |¦  «         t          |¦  «        s¼t          |t"          ¦  «        r|                     |g¦  «        }n�t          |t          t&          f¦  «        r|                     |¦  «        }n^t          |¦  «        r|                     |j        ¦  «        }n4t+          |¦  «        r|                     |¦  «        }nt!          |¦  «         |S )Nr   )r)   Ú
isinstancer   rm  r«   r$   r(   r%   r™  r#   r”  rt   Úslicer›  r—  r&   r   r’   r�  rŠ  r’  r'   )r[   rç   r  rq   Ú	compliants        r\   rê   zEagerDataFrame.__getitem__“  s  € ð ‰ˆˆgØˆ	Ý˜WÑ%Ô%ñ 	&Ý˜'¥5Ñ)Ô)ð *­c°'©l¬l¸aÒ.?Ð.?Ø ×'Ò'Ñ)Ô)Ð)Ý  Ñ)Ô)ð &Ý! 'Ñ*Ô*ð G­h°wÑ.?Ô.?ð GØ )× =Ò =¸gÑ FÔ F�I�IÝ(¨Ñ1Ô1ð GØ $× 8Ò 8¸¼Ñ HÔ H�I�Ià )× =Ò =¸gÑ FÔ F�I�IÝ˜G¥UÑ+Ô+ð &Ø%×8Ò8¸ÑAÔA�	�	Ý$ WÑ-Ô-ð &Ø ×3Ò3°G´NÑCÔC�	�	Ý! 'Ñ*Ô*ð &Ø ×3Ò3°GÑ<Ô<�	�	å˜WÑ%Ô%Ð%å˜TÑ"Ô"ð 
	#Ý˜$¥Ñ$Ô$ð 	#Ø%×-Ò-¨t¨fÑ5Ô5�	�	Ý˜D¥5­% .Ñ1Ô1ð #Ø%×3Ò3°DÑ9Ô9�	�	Ý$ TÑ*Ô*ð #Ø%×-Ò-¨d¬kÑ:Ô:�	�	Ý.¨tÑ4Ô4ð #Ø%×-Ò-¨dÑ3Ô3�	�	å˜TÑ"Ô"Ð"àÐr_   r;  r@  r<  c                ó,   — |                       |¦  «        S rX   )rF  r>  s     r\   rV  zEagerDataFrame.sink_parquet½  s   € Ø×!Ò! $Ñ'Ô'Ð'r_   N)rV   rX  )rV   r[  )rV   r]  )r¨   r   rV   r-   )rb   r   rd  r{   rV   r-   )r~   ro   rV   rf  )rj  r   rV   r   )r¨   r   rV   rp  )rj  r   rV   rp  )r–   r   rV   r
   )rh   rF   rq   r   rV   r…  )r  rŒ  rV   r-   )r  r�  rV   r-   )rq   rŒ  rV   r-   )rq   r•  rV   r-   )rq   r�  rV   r-   )rq   rH   rV   r-   )rç   rœ  rV   r-   rH  )rË   rÌ   rÍ   rÑ   rZ  ra   rb  rP  rd   ri  ro  rx  rs  r„  Ústaticmethodr‹  r�  r’  r”  r—  r™  r›  rê   rV  rY   r_   r\   rM   rM   8  s¨  € € € € € ð ð7ð 7ð 7ñ „Xð7ðð ð ð ð;ð ;ð ;ð ;ð#ð #ð #ð #ð FJðð ð ð ð ð ðCð Cð Cð Cðð ð ð ð
ð 
ð 
ð 
ðð ð ð ð&ð ð ð ð ðNð Nð Nñ „\ðNð
 QÐPÐPÐPØCÐCÐCÐCðð ð ð ðð ð ð ð MÐLÐLÐLØBÐBÐBÐBð(ð (ð (ð (ðT(ð (ð (ð (ð (ð (r_   rM   r]  )kÚ
__future__r   Úcollections.abcr   r   r   r   Ú	itertoolsr   Útypingr	   r
   r   r   r   r   Únarwhals._compliant.typingr   r   r   r   r   r   r   r   r   Únarwhals._translater   r   r   r   r   r   Únarwhals._typing_compatr   Únarwhals._utilsr   r    r!   r"   r#   r$   r%   r&   r'   r(   r)   Úior*   Úpathlibr+   Útypesr,   ÚpandasÚpdÚpolarsÚplÚpyarrowÚpaÚtyping_extensionsr-   r.   Únarwhals._compliant.group_byr/   r0   Únarwhals._compliant.namespacer1   Únarwhals._spark_like.utilsr2   r3   Únarwhals._typingr4   r5   r6   r7   Únarwhals.dataframer8   Únarwhals.dtypesr9   Únarwhals.exceptionsr:   Únarwhals.typingr;   r<   r=   r>   r?   r@   rA   rB   rC   rD   rE   rF   rG   rH   rI   rÏ   Ú__all__rN   rP   rQ   rK   r›   rJ   rL   rM   rY   r_   r\   ú<module>r¾     s¥  ðØ "Ð "Ð "Ð "Ð "Ð "Ð "à >Ð >Ð >Ð >Ð >Ð >Ð >Ð >Ð >Ð >Ð >Ð >Ø Ð Ð Ð Ð Ð Ø KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ Kð
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð 1Ð 0Ð 0Ð 0Ð 0Ð 0ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð $ ØÐÐÐÐÐØÐÐÐÐÐØ Ð Ð Ð Ð Ð àÐÐÐØÐÐÐØÐÐÐØ1Ð1Ð1Ð1Ð1Ð1Ð1Ð1àOÐOÐOÐOÐOÐOÐOÐOØ<Ð<Ð<Ð<Ð<Ð<Ø7Ð7Ð7Ð7Ð7Ð7Ø2Ð2Ð2Ð2Ð2Ð2ØDÐDÐDÐDÐDÐDÐDÐDØ?Ð?Ð?Ð?Ð?Ð?Ð?Ð?Ø,Ð,Ð,Ð,Ð,Ð,Ø%Ð%Ð%Ð%Ð%Ð%Ø7Ð7Ð7Ð7Ð7Ð7ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð"  €JÐÐÐÑà
ZÐ
ZÐ
Z€à€GˆC�L„L€àI€Ð IÐ IÐ IÑ Ià�˜Ñ(Ô(€ðTNð TNð TNð TNð TNØ�-Ô Øˆ}ÔØˆ~ÔØÐ" M°>ÐAÔBñ	TNô TNð TNðnrEð rEð rEð rEð rEØÐ+Ô,ØÐ/°¸¸c¸Ô1BÐBÔCØÐ1Ô2Ø	ØÐ(Ð*:¸NÐJÔKØÐÐ4Ð6FÈÐVÔWñrEô rEð rEðjDð Dð Dð Dð DØÐ(Ð*:¸NÐJÔKØÐ"Ð$4°nÐDÔEñDô Dð Dð(F(ð F(ð F(ð F(ð F(ØØ�jÐ"2Ð4QÐQôð �z <Ð1NÐNÔOØØˆ\˜:Ð'7¸ÐFÔGñF(ô F(ð F(ð F(ð F(r_   