§
    cŠtj´8  ã                  óf  — d dl mZ d dlZd dlmZmZ d dlmZ d dlmZ d dl	m
Z
mZ d dlmZ d dlZd dlmZmZ d dlmZ d d	lmZ d d
l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$ e
r#d dl%m&Z&m'Z' d dl(mc m)Z* d dl!m+Z+ d dl,m-Z-m.Z.m/Z/m0Z0  G d„ deeeej1        f         eeef         ¦  «        Z2dS )é    )ÚannotationsN)ÚdateÚdatetime)Úreduce)Úchain)ÚTYPE_CHECKINGÚcast)ÚDepthTrackingNamespaceÚLazyNamespace©ÚDaskLazyFrame©ÚDaskExpr)ÚDaskSelectorNamespace)Úalign_series_full_broadcastÚnarwhals_to_native_dtypeÚvalidate_comparand)Úcombine_alias_output_namesÚcombine_evaluate_output_names)ÚImplementationÚis_nested_literalÚnot_implemented)ÚIterableÚIterator)ÚVersion)ÚConcatMethodÚCorrelationMethodÚ	IntoDTypeÚNonNestedLiteralc                  ó  — e Zd ZU ej        Zded<   ed6d„¦   «         Zed7d„¦   «         Z	ed8d	„¦   «         Z
d9d„Zd:d„Zd;d„Zd<d„Zd<d„Zd=d„Zd>d „Zd=d!„Zd=d"„Zd=d#„Zd?d&„Zd=d'„Z	 d@dAd-„ZdBd2„ZdCd5„Z e¦   «         Z e¦   «         Zd(S )DÚDaskNamespacer   Ú_implementationÚreturnr   c                ó*   — t          j        | ¦  «        S ©N)r   Úfrom_namespace©Úselfs    úV/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/narwhals/_dask/namespace.pyÚ	selectorszDaskNamespace.selectors/   s   € å$Ô3°DÑ9Ô9Ð9ó    útype[DaskExpr]c                ó   — t           S r%   r   r'   s    r)   Ú_exprzDaskNamespace._expr3   s   € åˆr+   útype[DaskLazyFrame]c                ó   — t           S r%   r   r'   s    r)   Ú
_lazyframezDaskNamespace._lazyframe7   s   € åÐr+   Úversionr   ÚNonec               ó   — || _         d S r%   )Ú_version)r(   r2   s     r)   Ú__init__zDaskNamespace.__init__;   s   € ØˆŒˆˆr+   Úvaluer   ÚdtypeúIntoDType | Noner   c                óÀ   ‡ ‡‡— t          ‰¦  «        r&dt          ‰¦  «        j        › �}t          |¦  «        ‚d	ˆˆ ˆfd„}‰                      |d„ d ‰ j        ¬¦  «        S )
Nz<Nested structures are not supported for Dask backend, found Údfr   r#   úlist[dx.Series]c                ó–  •— ‰�.t          ‰‰j        ¦  «        }t          j        ‰g|d¬¦  «        }n\t	          ‰t
          ¦  «        r0t	          ‰t          ¦  «        sd}t          j        ‰g|d¬¦  «        }nt          j        ‰gd¬¦  «        }| j        j        }t          j
        ||¬¦  «        }|d                              ¦   «         gS )NÚliteral)r8   Únamezdate32[pyarrow])r?   )Únpartitionsr   )r   r5   ÚpdÚSeriesÚ
isinstancer   r   Ú_native_framer@   ÚddÚfrom_pandasÚ	to_series)r;   Únative_dtypeÚnative_pd_seriesr@   Údask_seriesr8   r(   r7   s        €€€r)   ÚfunczDaskNamespace.lit.<locals>.funcC   sÓ   ø€ ØÐ Ý7¸¸t¼}ÑMÔM�Ý#%¤9¨e¨W¸LÈyÐ#YÑ#YÔ#YÐ Ð Ý˜E¥4Ñ(Ô(ð FµØ•xñ2ô 2ð Fð
  1�Ý#%¤9¨e¨W¸LÈyÐ#YÑ#YÔ#YÐ Ð å#%¤9¨e¨W¸9Ð#EÑ#EÔ#EÐ ØÔ*Ô6ˆKÝœ.Ð)9À{ÐSÑSÔSˆKØ ”N×,Ò,Ñ.Ô.Ð/Ð/r+   c                ó   — dgS ©Nr>   © ©Ú_dfs    r)   ú<lambda>z#DaskNamespace.lit.<locals>.<lambda>V   s   € ¨y¨k€ r+   ©Úevaluate_output_namesÚalias_output_namesr2   ©r;   r   r#   r<   )r   ÚtypeÚ__name__ÚNotImplementedErrorr.   r5   )r(   r7   r8   ÚmsgrK   s   ```  r)   ÚlitzDaskNamespace.lit>   s“   øøø€ Ý˜UÑ#Ô#ð 	+ØgÕQUÐV[ÑQ\ÔQ\ÔQeÐgÐgˆCÝ% cÑ*Ô*Ð*ð	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð" �zŠzØØ"9Ð"9Ø#Ø”Mð	 ñ 
ô 
ð 	
r+   c                óH   — dd„}|                       |d„ d | j        ¬¦  «        S )	Nr;   r   r#   r<   c                ób   — | j         | j        d                  j                             ¦   «         gS )Nr   )rD   ÚcolumnsÚsizerG   )r;   s    r)   rK   zDaskNamespace.len.<locals>.func\   s(   € àÔ$ R¤Z°¤]Ô3Ô8×BÒBÑDÔDÐEÐEr+   c                ó   — dgS )NÚlenrN   rO   s    r)   rQ   z#DaskNamespace.len.<locals>.<lambda>b   s   € ¨u¨g€ r+   rR   rU   )r.   r5   )r(   rK   s     r)   r`   zDaskNamespace.len[   sH   € ð	Fð 	Fð 	Fð 	Fð �zŠzØØ"5Ð"5Ø#Ø”Mð	 ñ 
ô 
ð 	
r+   ÚexprsÚignore_nullsÚboolc               ól   ‡‡— dˆˆfd„}|                       |t          ‰Ž t          ‰Ž | j        ¬¦  «        S )Nr;   r   r#   r<   c                ó®   •‡ — t          j        ˆ fd„‰D ¦   «         ¦  «        }‰rd„ |D ¦   «         }t          t          j        t          ‰ g|¢R Ž ¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r%   rN   ©Ú.0Úer;   s     €r)   ú	<genexpr>z=DaskNamespace.all_horizontal.<locals>.func.<locals>.<genexpr>i   ó+   øè è € Ð=SÐ=SÈ¸a¸aÀ¹e¼eÐ=SÐ=SÐ=SÐ=SÐ=SÐ=Sr+   c              3  óZ   K  — | ]&}|j         d k    r|n|                     d¦  «        V — Œ'dS )rc   TN©r8   Úfillna©rh   Úss     r)   rj   z=DaskNamespace.all_horizontal.<locals>.func.<locals>.<genexpr>n   s<   è è € ÐUÐUÈ˜qœw¨&Ò0Ð0˜!˜!°a·h²h¸t±n´nÐUÐUÐUÐUÐUÐUr+   )r   Úfrom_iterabler   ÚoperatorÚand_r   ©r;   Úseriesra   rb   s   ` €€r)   rK   z*DaskNamespace.all_horizontal.<locals>.funch   sm   øø€ Ý*/Ô*=Ð=SÐ=SÐ=SÐ=SÈUÐ=SÑ=SÔ=SÑ*SÔ*SˆFð ð VàUÐUÈfÐUÑUÔU�Ý�8œ=Õ*EÀbÐ*RÈ6Ð*RÐ*RÐ*RÑSÔSÐTÐTr+   ©ÚcallrS   rT   r2   rU   ©r.   r   r   r5   ©r(   rb   ra   rK   s    `` r)   Úall_horizontalzDaskNamespace.all_horizontalg   sc   øø€ ð	Uð 	Uð 	Uð 	Uð 	Uð 	Uð 	Uð �zŠzØÝ"?ÀÐ"GÝ9¸5ÐAØ”Mð	 ñ 
ô 
ð 	
r+   c               ól   ‡‡— dˆˆfd„}|                       |t          ‰Ž t          ‰Ž | j        ¬¦  «        S )Nr;   r   r#   r<   c                ó®   •‡ — t          j        ˆ fd„‰D ¦   «         ¦  «        }‰rd„ |D ¦   «         }t          t          j        t          ‰ g|¢R Ž ¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r%   rN   rg   s     €r)   rj   z=DaskNamespace.any_horizontal.<locals>.func.<locals>.<genexpr>z   rk   r+   c              3  óZ   K  — | ]&}|j         d k    r|n|                     d¦  «        V — Œ'dS )rc   FNrm   ro   s     r)   rj   z=DaskNamespace.any_horizontal.<locals>.func.<locals>.<genexpr>|   s<   è è € ÐVÐVÈ!˜qœw¨&Ò0Ð0˜!˜!°a·h²h¸u±o´oÐVÐVÐVÐVÐVÐVr+   )r   rq   r   rr   Úor_r   rt   s   ` €€r)   rK   z*DaskNamespace.any_horizontal.<locals>.funcy   sk   øø€ Ý*/Ô*=Ð=SÐ=SÐ=SÐ=SÈUÐ=SÑ=SÔ=SÑ*SÔ*SˆFØð WØVÐVÈvÐVÑVÔV�Ý�8œ<Õ)DÀRÐ)QÈ&Ð)QÐ)QÐ)QÑRÔRÐSÐSr+   rv   rU   rx   ry   s    `` r)   Úany_horizontalzDaskNamespace.any_horizontalx   sc   øø€ ð	Tð 	Tð 	Tð 	Tð 	Tð 	Tð 	Tð �zŠzØÝ"?ÀÐ"GÝ9¸5ÐAØ”Mð	 ñ 
ô 
ð 	
r+   c                óh   ‡— dˆfd„}|                       |t          ‰Ž t          ‰Ž | j        ¬¦  «        S )Nr;   r   r#   r<   c                óŽ   •‡ — t          ‰ gˆ fd„‰D ¦   «         ¢R Ž }t          j        |d¬¦  «                             d¬¦  «        gS )Nc              3  ó8   •K  — | ]} |‰¦  «        D ]}|V — ŒŒd S r%   rN   ©rh   r.   rp   r;   s      €r)   rj   z=DaskNamespace.sum_horizontal.<locals>.func.<locals>.<genexpr>‰   ó8   øè è € Ð>Ð>˜E°E°E¸"±I´IÐ>Ð>¨q�aÐ>Ð>Ð>Ð>Ð>Ð>Ð>r+   é   ©Úaxis)r   rE   ÚconcatÚsum©r;   ru   ra   s   ` €r)   rK   z*DaskNamespace.sum_horizontal.<locals>.func‡   sb   øø€ Ý0ØðØ>Ð>Ð>Ð> UÐ>Ñ>Ô>ðð ð ˆFõ ”I˜f¨1Ð-Ñ-Ô-×1Ò1°qÐ1Ñ9Ô9Ð:Ð:r+   rv   rU   rx   ©r(   ra   rK   s    ` r)   Úsum_horizontalzDaskNamespace.sum_horizontal†   sV   ø€ ð	;ð 	;ð 	;ð 	;ð 	;ð 	;ð �zŠzØÝ"?ÀÐ"GÝ9¸5ÐAØ”Mð	 ñ 
ô 
ð 	
r+   ÚitemsúIterable[DaskLazyFrame]Úhowr   r   c               óf  — |sd}t          |¦  «        ‚d„ |D ¦   «         }|d         j        }|dk    rÈt          |dd …         d¬¦  «        D ]ƒ\  }}|j        }t          |¦  «        t          |¦  «        k    r||k                         ¦   «         s?d|                     ¦   «         › d|› d	|                     ¦   «         › d
�}t          |¦  «        ‚Œ„t          t          j	        |dd¬¦  «        | j
        ¬¦  «        S |dk    r+t          t          j	        |dd¬¦  «        | j
        ¬¦  «        S t          ‚)NzNo items to concatenatec                ó   — g | ]	}|j         ‘Œ
S rN   )rD   )rh   Úis     r)   ú
<listcomp>z(DaskNamespace.concat.<locals>.<listcomp>š   s   € Ð.Ð.Ð. 1ˆqŒÐ.Ð.Ð.r+   r   Úverticalr†   )Ústartz>unable to vstack, column names don't match:
   - dataframe 0: z
   - dataframe z: ú
Úinner)rˆ   Újoin)r2   ÚdiagonalÚouter)ÚAssertionErrorr]   Ú	enumerater`   ÚallÚto_listÚ	TypeErrorr   rE   r‰   r5   rX   )	r(   rŽ   r�   rY   ÚdfsÚcols_0r“   r;   Úcols_currents	            r)   r‰   zDaskNamespace.concat”   s‚  € ð ð 	&Ø+ˆCÝ  Ñ%Ô%Ð%Ø.Ð.¨Ð.Ñ.Ô.ˆØ�Q””ˆØ�*ÒÐÝ" 3 q r r¤7°!Ð4Ñ4Ô4ð 
)ð 
)‘��2Ø!œz�å˜Ñ&Ô&­#¨f©+¬+Ò5Ð5¸LÈFÒ<R×;WÒ;WÑ;YÔ;YÐ5ðJØ-3¯^ª^Ñ-=Ô-=ðJð Jà*+ðJð Jà/;×/CÒ/CÑ/EÔ/EðJð Jð Jð õ
 $ C™.œ.Ð(ð 6õ !Ý”	˜# A¨GÐ4Ñ4Ô4¸d¼mðñ ô ð ð �*ÒÐÝ Ý”	˜# A¨GÐ4Ñ4Ô4¸d¼mðñ ô ð õ "Ð!r+   c                óh   ‡— dˆfd„}|                       |t          ‰Ž t          ‰Ž | j        ¬¦  «        S )Nr;   r   r#   r<   c                óê   •‡ — ˆ fd„‰D ¦   «         }t          ‰ gd„ |D ¦   «         ¢R Ž }t          ‰ gd„ |D ¦   «         ¢R Ž }t          d„ |¦  «        }t          d„ |¦  «        }t          d||z  ¦  «        gS )Nc                ó0   •— g | ]} |‰¦  «        D ]}|‘ŒŒS rN   rN   r„   s      €r)   r”   z?DaskNamespace.mean_horizontal.<locals>.func.<locals>.<listcomp>´   ó.   ø€ ÐDÐDÐD %¸%¸%À¹)¼)ÐDÐD°Q˜AÐDÐDÐDÐDr+   c              3  ó@   K  — | ]}|                      d ¦  «        V — ŒdS )r   N©rn   ro   s     r)   rj   z>DaskNamespace.mean_horizontal.<locals>.func.<locals>.<genexpr>µ   s,   è è € Ð6YÐ6YÀq°q·x²xÀ±{´{Ð6YÐ6YÐ6YÐ6YÐ6YÐ6Yr+   c              3  óD   K  — | ]}d |                      ¦   «         z
  V — ŒdS )r†   N©Úisnaro   s     r)   rj   z>DaskNamespace.mean_horizontal.<locals>.func.<locals>.<genexpr>·   s.   è è € Ð9Ð9 q�a˜!Ÿ&š&™(œ(‘lÐ9Ð9Ð9Ð9Ð9Ð9r+   c                ó   — | |z   S r%   rN   ©ÚxÚys     r)   rQ   z=DaskNamespace.mean_horizontal.<locals>.func.<locals>.<lambda>¹   ó
   €  a¨!¡e€ r+   c                ó   — | |z   S r%   rN   r®   s     r)   rQ   z=DaskNamespace.mean_horizontal.<locals>.func.<locals>.<lambda>º   r±   r+   z	dx.Series)r   r   r	   )r;   Úexpr_resultsru   Únon_naÚnumÚdenra   s   `     €r)   rK   z+DaskNamespace.mean_horizontal.<locals>.func³   s­   øø€ ØDÐDÐDÐD¨5ÐDÑDÔDˆLÝ0°ÐZÐ6YÐ6YÈLÐ6YÑ6YÔ6YÐZÐZÐZˆFÝ0ØðØ9Ð9¨LÐ9Ñ9Ô9ðð ð ˆFõ Ð+Ð+¨VÑ4Ô4ˆCÝÐ+Ð+¨VÑ4Ô4ˆCÝ˜ c¨C¡iÑ0Ô0Ð1Ð1r+   rv   rU   rx   rŒ   s    ` r)   Úmean_horizontalzDaskNamespace.mean_horizontal²   sV   ø€ ð	2ð 	2ð 	2ð 	2ð 	2ð 	2ð �zŠzØÝ"?ÀÐ"GÝ9¸5ÐAØ”Mð	 ñ 
ô 
ð 	
r+   c                óh   ‡— dˆfd„}|                       |t          ‰Ž t          ‰Ž | j        ¬¦  «        S )Nr;   r   r#   r<   c                óŽ   •‡ — t          ‰ gˆ fd„‰D ¦   «         ¢R Ž }t          j        |d¬¦  «                             d¬¦  «        gS )Nc              3  ó8   •K  — | ]} |‰¦  «        D ]}|V — ŒŒd S r%   rN   r„   s      €r)   rj   z=DaskNamespace.min_horizontal.<locals>.func.<locals>.<genexpr>Ç   r…   r+   r†   r‡   )r   rE   r‰   Úminr‹   s   ` €r)   rK   z*DaskNamespace.min_horizontal.<locals>.funcÅ   ób   øø€ Ý0ØðØ>Ð>Ð>Ð> UÐ>Ñ>Ô>ðð ð ˆFõ ”I˜f¨1Ð-Ñ-Ô-×1Ò1°qÐ1Ñ9Ô9Ð:Ð:r+   rv   rU   rx   rŒ   s    ` r)   Úmin_horizontalzDaskNamespace.min_horizontalÄ   óV   ø€ ð	;ð 	;ð 	;ð 	;ð 	;ð 	;ð �zŠzØÝ"?ÀÐ"GÝ9¸5ÐAØ”Mð	 ñ 
ô 
ð 	
r+   c                óh   ‡— dˆfd„}|                       |t          ‰Ž t          ‰Ž | j        ¬¦  «        S )Nr;   r   r#   r<   c                óŽ   •‡ — t          ‰ gˆ fd„‰D ¦   «         ¢R Ž }t          j        |d¬¦  «                             d¬¦  «        gS )Nc              3  ó8   •K  — | ]} |‰¦  «        D ]}|V — ŒŒd S r%   rN   r„   s      €r)   rj   z=DaskNamespace.max_horizontal.<locals>.func.<locals>.<genexpr>Ö   r…   r+   r†   r‡   )r   rE   r‰   Úmaxr‹   s   ` €r)   rK   z*DaskNamespace.max_horizontal.<locals>.funcÔ   r¼   r+   rv   rU   rx   rŒ   s    ` r)   Úmax_horizontalzDaskNamespace.max_horizontalÓ   r¾   r+   Ú	separatorÚstrc          	     óª   ‡‡‡— dˆˆˆfd„}|                       |t          ‰d         dd„ ¦  «        t          ‰d         d	d ¦  «        | j        ¬
¦  «        S )Nr;   r   r#   r<   c           	     óà  •‡ — ˆ fd„‰	D ¦   «         }d„ t          ‰ g|¢R Ž D ¦   «         }d„ t          ‰ g|¢R Ž D ¦   «         }‰
sCt          t          j        |¦  «        }t          ˆfd„|¦  «                             | d ¦  «        }nid„ t          ||d¬¦  «        D ¦   «         ^}}ˆfd„|d d	…         D ¦   «         }t          t          j        d
„ t          ||d¬¦  «        D ¦   «         |¦  «        }|gS )Nc                ó0   •— g | ]} |‰¦  «        D ]}|‘ŒŒS rN   rN   r„   s      €r)   r”   z:DaskNamespace.concat_str.<locals>.func.<locals>.<listcomp>æ   r§   r+   c              3  óJ   K  — | ]}|                      t          ¦  «        V — Œd S r%   )ÚastyperÅ   ro   s     r)   rj   z9DaskNamespace.concat_str.<locals>.func.<locals>.<genexpr>ç   s=   è è € ð ð Ø"#�—’�‘”ðð ð ð ð ð r+   c                ó6   — g | ]}|                      ¦   «         ‘ŒS rN   r«   ro   s     r)   r”   z:DaskNamespace.concat_str.<locals>.func.<locals>.<listcomp>ê   s    € ÐZÐZÐZ a˜Ÿš™œÐZÐZÐZr+   c                ó   •— | ‰z   |z   S r%   rN   )r¯   r°   rÄ   s     €r)   rQ   z8DaskNamespace.concat_str.<locals>.func.<locals>.<lambda>î   s   ø€ ¨Q°©]¸QÑ->€ r+   c                óB   — g | ]\  }}|                      | d ¦  «        ‘ŒS )Ú )Úwhere)rh   rp   Únms      r)   r”   z:DaskNamespace.concat_str.<locals>.func.<locals>.<listcomp>ò   s9   € ð 'ð 'ð 'Ù).¨¨B�A—G’G˜R˜C Ñ$Ô$ð'ð 'ð 'r+   T)Ústrictc              3  óV   •K  — | ]#}|                      d ‰dœt          ¬¦  «        V — Œ$dS )rÎ   )TF)ÚmetaN)ÚmaprÅ   )rh   rÐ   rÄ   s     €r)   rj   z9DaskNamespace.concat_str.<locals>.func.<locals>.<genexpr>ö   sO   øè è € ð ð àð —F’F "¨YÐ7Ð7½c�FÑBÔBðð ð ð ð ð r+   éÿÿÿÿc              3  ó&   K  — | ]\  }}||z   V — Œd S r%   rN   )rh   rp   Úvs      r)   rj   z9DaskNamespace.concat_str.<locals>.func.<locals>.<genexpr>ü   s*   è è € ÐLÐL™t˜q !�Q˜‘UÐLÐLÐLÐLÐLÐLr+   )r   r   rr   r   rÏ   ÚzipÚadd)r;   r³   ru   Ú	null_maskÚnull_mask_resultÚresultÚ
init_valueÚvaluesÚ
separatorsra   rb   rÄ   s   `        €€€r)   rK   z&DaskNamespace.concat_str.<locals>.funcå   sd  øø€ ØDÐDÐDÐD¨5ÐDÑDÔDˆLðð Ý'BÀ2Ð'UÈÐ'UÐ'UÐ'Uðñ ô ˆFð [ÐZÕ+FÀrÐ+YÈLÐ+YÐ+YÐ+YÐZÑZÔZˆIàð Ý#)­(¬,¸	Ñ#BÔ#BÐ ÝÐ >Ð >Ð >Ð >ÀÑGÔG×MÒMØ%Ð% tñô ��ð'ð 'Ý25°f¸iÐPTÐ2UÑ2UÔ2Uð'ñ 'ô 'Ð#�
˜Vðð ð ð à'¨¨¨œnðñ ô �
õ  Ý”LØLÐL¥s¨:°vÀdÐ'KÑ'KÔ'KÐLÑLÔLØñô �ð �8ˆOr+   r   Ú_evaluate_output_namesc                ó   — dgS rM   rN   rO   s    r)   rQ   z*DaskNamespace.concat_str.<locals>.<lambda>  s   € ÀÀ€ r+   Ú_alias_output_namesrv   rU   ©r.   Úgetattrr5   )r(   rÄ   rb   ra   rK   s    ``` r)   Ú
concat_strzDaskNamespace.concat_strâ   s…   øøø€ ð	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð: �zŠzØÝ")Ø�a”Ð2Ð4KÐ4Kñ#ô #õ  ' u¨Q¤xÐ1FÈÑMÔMØ”Mð ñ 
ô 
ð 	
r+   c                óh   ‡— dˆfd„}|                       |t          ‰Ž t          ‰Ž | j        ¬¦  «        S )Nr;   r   r#   r<   c                ó\   •‡ — t          ‰ gˆ fd„‰D ¦   «         ¢R Ž }t          d„ |¦  «        gS )Nc              3  ó8   •K  — | ]} |‰¦  «        D ]}|V — ŒŒd S r%   rN   r„   s      €r)   rj   z7DaskNamespace.coalesce.<locals>.func.<locals>.<genexpr>  r…   r+   c                ó,   — |                       |¦  «        S r%   r©   r®   s     r)   rQ   z6DaskNamespace.coalesce.<locals>.func.<locals>.<lambda>  s   € ¨¯ª°©¬€ r+   )r   r   r‹   s   ` €r)   rK   z$DaskNamespace.coalesce.<locals>.func  sP   øø€ Ý0ØðØ>Ð>Ð>Ð> UÐ>Ñ>Ô>ðð ð ˆFõ Ð3Ð3°VÑ<Ô<Ð=Ð=r+   rv   rU   rx   rŒ   s    ` r)   ÚcoalescezDaskNamespace.coalesce  sV   ø€ ð	>ð 	>ð 	>ð 	>ð 	>ð 	>ð �zŠzØÝ"?ÀÐ"GÝ9¸5ÐAØ”Mð	 ñ 
ô 
ð 	
r+   NÚ	predicateÚthenÚ	otherwiseúDaskExpr | Nonec           	     ó’   ‡‡‡— d
ˆˆˆfd„}|                       |t          ‰dd„ ¦  «        t          ‰dd ¦  «        | j        ¬	¦  «        S )Nr;   r   r#   r<   c                ó€  •— |                       ‰	¦  «        }‰�|                       ‰¦  «        n‰}|                       ‰¦  «        }t          d„ ‰€‰‰	fn‰‰	‰fD ¦   «         ¦  «        rP|                      |                     ¦   «         ¦  «        }|                       ‰                     ¦   «         ¦  «        }|} ‰€:t          | ||¦  «        \  }}t          ||¦  «         |                     |¦  «        gS t          | |||¦  «        \  }}}t          ||¦  «         t          ||¦  «         |                     ||¦  «        gS )Nc              3  ó.   K  — | ]}|j         j        V — Œd S r%   )Ú	_metadataÚis_scalar_like)rh   r¯   s     r)   rj   z8DaskNamespace.when_then.<locals>.func.<locals>.<genexpr>'  s;   è è € ð ð àð ”Ô*ðð ð ð ð ð r+   )Ú_evaluate_single_output_exprrž   Ú_with_nativeÚto_frameÚ	broadcastr   r   rÏ   )
r;   Ú
then_valueÚotherwise_valueÚ	conditionÚnew_dfÚthen_seriesÚotherwise_seriesrí   rë   rì   s
          €€€r)   rK   z%DaskNamespace.when_then.<locals>.func  s‡  ø€ Ø×8Ò8¸Ñ>Ô>ˆJð Ð(ð ×/Ò/°	Ñ:Ô:Ð:àð ð ×7Ò7¸	ÑBÔBˆIõ ð ð ð !Ð(ð  Ð%Ð%à# T¨9Ð5ðñ ô ñ ô ð 
ð Ÿš¨×);Ò);Ñ)=Ô)=Ñ>Ô>�Ø×;Ò;¸I×<OÒ<OÑ<QÔ<QÑRÔR�	Ø�àÐ Ý)DØ˜	 :ñ*ô *Ñ&�	˜;õ # 9¨kÑ:Ô:Ð:Ø#×)Ò)¨)Ñ4Ô4Ð5Ð5Ý7RØ�I˜z¨?ñ8ô 8Ñ4ˆI�{Ð$4õ ˜y¨+Ñ6Ô6Ð6Ý˜yÐ*:Ñ;Ô;Ð;Ø×%Ò% iÐ1AÑBÔBÐCÐCr+   rà   c                ó   — dgS rM   rN   rO   s    r)   rQ   z)DaskNamespace.when_then.<locals>.<lambda>C  s   € ¸Y¸K€ r+   râ   rv   rU   rã   )r(   rë   rì   rí   rK   s    ``` r)   Ú	when_thenzDaskNamespace.when_then  s†   øøø€ ð"	Dð "	Dð "	Dð "	Dð "	Dð "	Dð "	Dð "	DðH �zŠzØÝ")ØÐ.Ð0GÐ0Gñ#ô #õ  ' tÐ-BÀDÑIÔIØ”Mð ñ 
ô 
ð 	
r+   ÚaÚbÚmethodr   c               óŒ   ‡‡‡— dˆˆˆfd„}|                       |t          ‰‰¦  «        t          ‰‰¦  «        | j        ¬¦  «        S )Nr;   r   r#   r<   c                ó¬   •— |                       ‰¦  «        }|                       ‰¦  «        }|                     |‰¬¦  «                             ¦   «         gS )N)r  )rô   ÚcorrrG   )r;   Úa_Úb_r   r  r  s      €€€r)   rK   z DaskNamespace.corr.<locals>.funcJ  sN   ø€ Ø×0Ò0°Ñ3Ô3ˆBØ×0Ò0°Ñ3Ô3ˆBØ—G’G˜B v�GÑ.Ô.×8Ò8Ñ:Ô:Ð;Ð;r+   rv   rU   rx   )r(   r   r  r  rK   s    ``` r)   r  zDaskNamespace.corrI  sl   øøø€ ð	<ð 	<ð 	<ð 	<ð 	<ð 	<ð 	<ð 	<ð
 �zŠzØÝ"?ÀÀ1Ñ"EÔ"EÝ9¸!¸QÑ?Ô?Ø”Mð	 ñ 
ô 
ð 	
r+   ÚddofÚintc               óŒ   ‡‡‡— dˆˆˆfd„}|                       |t          ‰‰¦  «        t          ‰‰¦  «        | j        ¬¦  «        S )Nr;   r   r#   r<   c                ó  •— |                       ‰¦  «        }|                       ‰¦  «        }|                     |¦  «                             ¦   «         }‰	dk    r|gS |                     ¦   «          |                     ¦   «          z                       ¦   «                              ¦   «         }|‰	z
  }||dz
  z  |                     |dk    ¦  «        z  }‰	dk    r|                     |dk    d¦  «        }|                     |j        ¦  «        gS )Nr†   r   g        )rô   ÚcovrG   r¬   rŠ   rÏ   Úrenamer?   )
r;   r  r  Úcov_sampÚ	n_samplesÚdenominatorrÜ   r   r  r  s
          €€€r)   rK   zDaskNamespace.cov.<locals>.funcW  sô   ø€ Ø×0Ò0°Ñ3Ô3ˆBØ×0Ò0°Ñ3Ô3ˆBð —v’v˜b‘z”z×+Ò+Ñ-Ô-ˆHØ�qŠyˆyØ �zÐ!àŸ'š'™)œ)˜ r§w¢w¡y¤y jÑ0×5Ò5Ñ7Ô7×AÒAÑCÔCˆIØ# dÑ*ˆKØ ¨Q¡Ñ/°+×2CÒ2CÀKÐRSÂOÑ2TÔ2TÑTˆFØ�qŠyˆyØŸš i°1¢n°cÑ:Ô:�Ø—M’M "¤'Ñ*Ô*Ð+Ð+r+   rv   rU   rx   )r(   r   r  r  rK   s    ``` r)   r  zDaskNamespace.covV  sl   øøø€ ð	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð  �zŠzØÝ"?ÀÀ1Ñ"EÔ"EÝ9¸!¸QÑ?Ô?Ø”Mð	 ñ 
ô 
ð 	
r+   )r#   r   )r#   r,   )r#   r/   )r2   r   r#   r3   )r7   r   r8   r9   r#   r   )r#   r   )ra   r   rb   rc   r#   r   )ra   r   r#   r   )rŽ   r�   r�   r   r#   r   )ra   r   rÄ   rÅ   rb   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   )rW   Ú
__module__Ú__qualname__r   ÚDASKr"   Ú__annotations__Úpropertyr*   r.   r1   r6   rZ   r`   rz   r€   r�   r‰   r·   r½   rÃ   rå   rê   rÿ   r  r  r   ÚstructÚlistrN   r+   r)   r!   r!   )   sÚ  € € € € € € ð '5Ô&9€OÐ9Ð9Ð9Ñ9àð:ð :ð :ñ „Xð:ð ðð ð ñ „Xðð ðð ð ñ „Xðð ð  ð  ð  ð
ð 
ð 
ð 
ð:

ð 

ð 

ð 

ð
ð 
ð 
ð 
ð"
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð"ð "ð "ð "ð<
ð 
ð 
ð 
ð$
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð'
ð '
ð '
ð '
ðR
ð 
ð 
ð 
ð QUð.
ð .
ð .
ð .
ð .
ð`
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð0 ˆ_ÑÔ€FØˆ?ÑÔ€D€D€Dr+   r!   )3Ú
__future__r   rr   r   r   Ú	functoolsr   Ú	itertoolsr   Útypingr   r	   Údask.dataframeÚ	dataframerE   ÚpandasrA   Únarwhals._compliantr
   r   Únarwhals._dask.dataframer   Únarwhals._dask.exprr   Únarwhals._dask.selectorsr   Únarwhals._dask.utilsr   r   r   Únarwhals._expression_parsingr   r   Únarwhals._utilsr   r   r   Úcollections.abcr   r   Údask.dataframe.dask_exprÚ	dask_exprÚdxr   Únarwhals.typingr   r   r   r   Ú	DataFramer!   rN   r+   r)   ú<module>r,     s>  ðØ "Ð "Ð "Ð "Ð "Ð "à €€€Ø #Ð #Ð #Ð #Ð #Ð #Ð #Ð #Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð Ø &Ð &Ð &Ð &Ð &Ð &Ð &Ð &à Ð Ð Ð Ð Ð Ø Ð Ð Ð à EÐ EÐ EÐ EÐ EÐ EÐ EÐ EØ 2Ð 2Ð 2Ð 2Ð 2Ð 2Ø (Ð (Ð (Ð (Ð (Ð (Ø :Ð :Ð :Ð :Ð :Ð :ðð ð ð ð ð ð ð ð ð ð
ð ð ð ð ð ð ð ð OÐ NÐ NÐ NÐ NÐ NÐ NÐ NÐ NÐ Nàð Ø2Ð2Ð2Ð2Ð2Ð2Ð2Ð2à)Ð)Ð)Ð)Ð)Ð)Ð)Ð)Ð)à'Ð'Ð'Ð'Ð'Ð'ðð ð ð ð ð ð ð ð ð ð ð ðFð Fð Fð Fð FØ�- ¨2¬<Ð7Ô8Ø˜=¨(Ð2Ô3ñFô Fð Fð Fð Fr+   