§
    cŠtj‰7  ã            
      óB  — d dl mZ d dlZd dlmZ d dlmZ d dlmZm	Z	 d dl
Zd dlmZ d dlmZ d dl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mZmZ d dlm Z  er"d dl!m"Z"m#Z# d dl$m%Z%m&Z&m'Z' d dlm(Z( d dl)m*Z*m+Z+m,Z,  G d„ deeeeej-        df         ¦  «        Z.dS )é    )ÚannotationsN)Úreduce)Úchain)ÚTYPE_CHECKINGÚLiteral©ÚArrowDataFrame©Ú	ArrowExpr)ÚArrowSelectorNamespace©ÚArrowSeries)Úbuild_list_arrayÚcast_to_comparable_string_types)ÚEagerNamespace)Úcombine_alias_output_namesÚcombine_evaluate_output_names)ÚImplementation)ÚIteratorÚSequence)ÚChunkedArrayAnyÚ
IncompleteÚ	ScalarAny)ÚVersion)ÚCorrelationMethodÚ	IntoDTypeÚPythonLiteralc                  ó   — e Zd Zej        Zed=d„¦   «         Zed>d„¦   «         Zed?d„¦   «         Z	d@d„Z
dAd„ZdBd„ZdCd„ZdDd„ZdDd„ZdEd„ZdEd„ZdEd„ZdEd„ZdFd#„ZdFd$„ZdFd%„ZedGd'„¦   «         ZdHd*„ZdEd+„ZdEd,„ZdEd-„Z	 dIdJd4„ZdKd9„ZdLd<„Zd.S )MÚArrowNamespaceÚreturnútype[ArrowDataFrame]c                ó   — t           S ©Nr   ©Úselfs    úW/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/narwhals/_arrow/namespace.pyÚ
_dataframezArrowNamespace._dataframe$   s   € åÐó    útype[ArrowExpr]c                ó   — t           S r#   r
   r$   s    r&   Ú_exprzArrowNamespace._expr(   s   € åÐr(   útype[ArrowSeries]c                ó   — t           S r#   r   r$   s    r&   Ú_serieszArrowNamespace._series,   s   € åÐr(   Úversionr   ÚNonec               ó   — || _         d S r#   )Ú_version)r%   r/   s     r&   Ú__init__zArrowNamespace.__init__0   s   € ØˆŒˆˆr(   Úseriesr   ú%Iterator[ChunkedArrayAny | ScalarAny]c                ó   — d„ |D ¦   «         S )Nc              3  óL   K  — | ]}|j         r|j        d          n|j        V — Œ dS )r   N)Ú
_broadcastÚnative©Ú.0Úss     r&   ú	<genexpr>z0ArrowNamespace.extract_native.<locals>.<genexpr>6   s5   è è € ÐJÐJ¸a˜qœ|Ð9�”˜”�°´ÐJÐJÐJÐJÐJÐJr(   © )r%   r4   s     r&   Úextract_nativezArrowNamespace.extract_native3   s   € ð KÐJÀ6ÐJÑJÔJÐJr(   r   c                óH   ‡ — ‰                       ˆ fd„d„ d ‰ j        ¬¦  «        S )Nc                óZ   •— t          j        t          | j        ¦  «        gd‰¬¦  «        gS )NÚlen)ÚnameÚcontext)r   Úfrom_iterablerB   r9   )Údfr%   s    €r&   ú<lambda>z$ArrowNamespace.len.<locals>.<lambda>;   s+   ø€ ÝÔ)­3¨r¬y©>¬>Ð*:ÀÐPTÐUÑUÔUð€ r(   c                ó   — dgS )NrB   r>   ©Ú_dfs    r&   rG   z$ArrowNamespace.len.<locals>.<lambda>>   s   € ¨u¨g€ r(   ©Úevaluate_output_namesÚalias_output_namesr/   ©r+   r2   r$   s   `r&   rB   zArrowNamespace.len8   sB   ø€ à�zŠzðð ð ð ð #6Ð"5Ø#Ø”Mð ñ 
ô 
ð 	
r(   Úvaluer   ÚdtypeúIntoDType | Nonec                ó^   ‡ ‡‡‡— d	ˆˆ ˆfd„Š‰                       ˆfd„d„ d ‰ j        ¬¦  «        S )
NÚ_r	   r    r   c                óf   •— t          j        ‰gd‰¬¦  «        }‰r|                     ‰¦  «        S |S )NÚliteral©ÚdatarC   rD   )r   rE   Úcast)rS   Úarrow_seriesrP   r%   rO   s     €€€r&   Ú_lit_arrow_seriesz-ArrowNamespace.lit.<locals>._lit_arrow_seriesD   sG   ø€ Ý&Ô4Ø�W 9°dðñ ô ˆLð ð 0Ø#×(Ò(¨Ñ/Ô/Ð/ØÐr(   c                ó   •—  ‰| ¦  «        gS r#   r>   )rF   rZ   s    €r&   rG   z$ArrowNamespace.lit.<locals>.<lambda>M   s   ø€ Ð)Ð)¨"Ñ-Ô-Ð.€ r(   c                ó   — dgS )NrU   r>   rI   s    r&   rG   z$ArrowNamespace.lit.<locals>.<lambda>N   s   € ¨y¨k€ r(   rK   )rS   r	   r    r   rN   )r%   rO   rP   rZ   s   ```@r&   ÚlitzArrowNamespace.litC   se   øøøø€ ð	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð �zŠzØ.Ð.Ð.Ð.Ø"9Ð"9Ø#Ø”Mð	 ñ 
ô 
ð 	
r(   ÚexprsÚignore_nullsÚboolc               ól   ‡‡— dˆˆfd„}| j                              |t          ‰Ž t          ‰Ž | ¬¦  «        S )NrF   r	   r    úlist[ArrowSeries]c                ó˜   •‡ — t          j        ˆ fd„‰D ¦   «         ¦  «        }‰rd„ |D ¦   «         }t          t          j        |¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   ©r;   ÚerF   s     €r&   r=   z>ArrowNamespace.all_horizontal.<locals>.func.<locals>.<genexpr>U   ó+   øè è € Ð?UÐ?UÈ!ÀÀÀ"ÁÄÐ?UÐ?UÐ?UÐ?UÐ?UÐ?Ur(   c              3  óD   K  — | ]}|                      d dd¦  «        V — ŒdS )TN©Ú	fill_nullr:   s     r&   r=   z>ArrowNamespace.all_horizontal.<locals>.func.<locals>.<genexpr>W   s2   è è € ÐHÐH¸A˜!Ÿ+š+ d¨D°$Ñ7Ô7ÐHÐHÐHÐHÐHÐHr(   )r   rE   r   ÚoperatorÚand_©rF   r4   r^   r_   s   ` €€r&   Úfuncz+ArrowNamespace.all_horizontal.<locals>.funcT   sZ   øø€ Ý,1Ô,?Ð?UÐ?UÐ?UÐ?UÈuÐ?UÑ?UÔ?UÑ,UÔ,UˆFØð IØHÐHÀÐHÑHÔH�Ý�8œ=¨&Ñ1Ô1Ð2Ð2r(   ©rn   rL   rM   rD   ©rF   r	   r    rb   ©r+   Ú_from_callabler   r   ©r%   r_   r^   rn   s    `` r&   Úall_horizontalzArrowNamespace.all_horizontalS   s^   øø€ ð	3ð 	3ð 	3ð 	3ð 	3ð 	3ð 	3ð Œz×(Ò(ØÝ"?ÀÐ"GÝ9¸5ÐAØð	 )ñ 
ô 
ð 	
r(   c               ól   ‡‡— dˆˆfd„}| j                              |t          ‰Ž t          ‰Ž | ¬¦  «        S )NrF   r	   r    rb   c                ó˜   •‡ — t          j        ˆ fd„‰D ¦   «         ¦  «        }‰rd„ |D ¦   «         }t          t          j        |¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   re   s     €r&   r=   z>ArrowNamespace.any_horizontal.<locals>.func.<locals>.<genexpr>c   rg   r(   c              3  óD   K  — | ]}|                      d dd¦  «        V — ŒdS )FNri   r:   s     r&   r=   z>ArrowNamespace.any_horizontal.<locals>.func.<locals>.<genexpr>e   s2   è è € ÐIÐI¸Q˜!Ÿ+š+ e¨T°4Ñ8Ô8ÐIÐIÐIÐIÐIÐIr(   )r   rE   r   rk   Úor_rm   s   ` €€r&   rn   z+ArrowNamespace.any_horizontal.<locals>.funcb   sZ   øø€ Ý,1Ô,?Ð?UÐ?UÐ?UÐ?UÈuÐ?UÑ?UÔ?UÑ,UÔ,UˆFØð JØIÐIÀ&ÐIÑIÔI�Ý�8œ<¨Ñ0Ô0Ð1Ð1r(   ro   rp   rq   rs   s    `` r&   Úany_horizontalzArrowNamespace.any_horizontala   s^   øø€ ð	2ð 	2ð 	2ð 	2ð 	2ð 	2ð 	2ð Œz×(Ò(ØÝ"?ÀÐ"GÝ9¸5ÐAØð	 )ñ 
ô 
ð 	
r(   c                óh   ‡— dˆfd„}| j                              |t          ‰Ž t          ‰Ž | ¬¦  «        S )NrF   r	   r    rb   c                ó”   •‡ — t          j        ˆ fd„‰D ¦   «         ¦  «        }d„ |D ¦   «         }t          t          j        |¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   ©r;   ÚexprrF   s     €r&   r=   z>ArrowNamespace.sum_horizontal.<locals>.func.<locals>.<genexpr>q   s+   øè è € Ð$@Ð$@°$ T T¨"¡X¤XÐ$@Ð$@Ð$@Ð$@Ð$@Ð$@r(   c              3  óF   K  — | ]}|                      d dd¬¦  «        V — ŒdS ©r   N)ÚstrategyÚlimitri   r:   s     r&   r=   z>ArrowNamespace.sum_horizontal.<locals>.func.<locals>.<genexpr>r   s4   è è € ÐLÐLÀA�a—k’k !¨d¸$�kÑ?Ô?ÐLÐLÐLÐLÐLÐLr(   )r   rE   r   rk   Úadd)rF   Úitr4   r^   s   `  €r&   rn   z+ArrowNamespace.sum_horizontal.<locals>.funcp   sQ   øø€ ÝÔ$Ð$@Ð$@Ð$@Ð$@¸%Ð$@Ñ$@Ô$@Ñ@Ô@ˆBØLÐLÈÐLÑLÔLˆFÝ�8œ<¨Ñ0Ô0Ð1Ð1r(   ro   rp   rq   ©r%   r^   rn   s    ` r&   Úsum_horizontalzArrowNamespace.sum_horizontalo   sX   ø€ ð	2ð 	2ð 	2ð 	2ð 	2ð 	2ð
 Œz×(Ò(ØÝ"?ÀÐ"GÝ9¸5ÐAØð	 )ñ 
ô 
ð 	
r(   c                ó¨   ‡‡— | j         j                             ¦   «         Šdˆˆfd„}| j                             |t          ‰Ž t          ‰Ž | ¬¦  «        S )NrF   r	   r    rb   c                ó   •‡ — t          t          j        ˆ fd„‰D ¦   «         ¦  «        ¦  «        }d„ |D ¦   «         }ˆfd„|D ¦   «         }t          t          j        |¦  «        t          t          j        |¦  «        z  gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   r~   s     €r&   r=   z?ArrowNamespace.mean_horizontal.<locals>.func.<locals>.<genexpr>€   s+   øè è € Ð4PÐ4PÀ$°T°T¸"±X´XÐ4PÐ4PÐ4PÐ4PÐ4PÐ4Pr(   c                ó>   — g | ]}|                      d dd¬¦  «        ‘ŒS r�   ri   r:   s     r&   ú
<listcomp>z@ArrowNamespace.mean_horizontal.<locals>.func.<locals>.<listcomp>�   s*   € ÐVÐVÐVÀA�a—k’k !¨d¸$�kÑ?Ô?ÐVÐVÐVr(   c                ód   •— g | ],}d |                      ¦   «                              ‰¦  «        z
  ‘Œ-S )é   )Úis_nullrX   )r;   r<   Úint_64s     €r&   rŒ   z@ArrowNamespace.mean_horizontal.<locals>.func.<locals>.<listcomp>‚   s4   ø€ ÐIÐIÐI°q�a˜!Ÿ)š)™+œ+×*Ò*¨6Ñ2Ô2Ñ2ÐIÐIÐIr(   )Útupler   rE   r   rk   r„   )rF   Úexpr_resultsr4   Únon_nar^   r�   s   `   €€r&   rn   z,ArrowNamespace.mean_horizontal.<locals>.func   sƒ   øø€ Ý ¥Ô!4Ð4PÐ4PÐ4PÐ4PÈ%Ð4PÑ4PÔ4PÑ!PÔ!PÑQÔQˆLØVÐVÈÐVÑVÔVˆFØIÐIÐIÐI¸LÐIÑIÔIˆFÝ�8œ<¨Ñ0Ô0µ6½(¼,ÈÑ3OÔ3OÑOÐPÐPr(   ro   rp   )r2   ÚdtypesÚInt64r+   rr   r   r   )r%   r^   rn   r�   s    ` @r&   Úmean_horizontalzArrowNamespace.mean_horizontal|   s{   øø€ Ø”Ô%×+Ò+Ñ-Ô-ˆð	Qð 	Qð 	Qð 	Qð 	Qð 	Qð 	Qð Œz×(Ò(ØÝ"?ÀÐ"GÝ9¸5ÐAØð	 )ñ 
ô 
ð 	
r(   c                ól   ‡ ‡— dˆˆ fd„}‰ j                              |t          ‰Ž t          ‰Ž ‰ ¬¦  «        S )NrF   r	   r    rb   c                óò   •‡ — t          t          j        ˆ fd„‰D ¦   «         ¦  «        ¦  «        ^}}t          t          j        d„ |D ¦   «         |j        ¦  «        }t          ||j        ‰j	        ¬¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   r~   s     €r&   r=   z>ArrowNamespace.min_horizontal.<locals>.func.<locals>.<genexpr>Ž   ó+   øè è € Ð<XÐ<XÈ$¸T¸TÀ"¹X¼XÐ<XÐ<XÐ<XÐ<XÐ<XÐ<Xr(   c                ó   — g | ]	}|j         ‘Œ
S r>   ©r9   r:   s     r&   rŒ   z?ArrowNamespace.min_horizontal.<locals>.func.<locals>.<listcomp>�   ó   € Ð%?Ð%?Ð%?°1 a¤hÐ%?Ð%?Ð%?r(   ©rC   r/   )
r‘   r   rE   r   ÚpcÚmin_element_wiser9   r   rC   r2   ©rF   Úinit_seriesr4   Únative_seriesr^   r%   s   `   €€r&   rn   z+ArrowNamespace.min_horizontal.<locals>.func�   ó…   øø€ Ý#(­Ô)<Ð<XÐ<XÐ<XÐ<XÐRWÐ<XÑ<XÔ<XÑ)XÔ)XÑ#YÔ#YÐ ˆK˜&Ý"ÝÔ#Ð%?Ð%?¸Ð%?Ñ%?Ô%?ÀÔASñô ˆMõ ˜M°Ô0@È$Ì-ÐXÑXÔXðð r(   ro   rp   rq   r†   s   `` r&   Úmin_horizontalzArrowNamespace.min_horizontalŒ   ó^   øø€ ð	ð 	ð 	ð 	ð 	ð 	ð 	ð Œz×(Ò(ØÝ"?ÀÐ"GÝ9¸5ÐAØð	 )ñ 
ô 
ð 	
r(   c                ól   ‡ ‡— dˆˆ fd„}‰ j                              |t          ‰Ž t          ‰Ž ‰ ¬¦  «        S )NrF   r	   r    rb   c                óò   •‡ — t          t          j        ˆ fd„‰D ¦   «         ¦  «        ¦  «        ^}}t          t          j        d„ |D ¦   «         |j        ¦  «        }t          ||j        ‰j	        ¬¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   r~   s     €r&   r=   z>ArrowNamespace.max_horizontal.<locals>.func.<locals>.<genexpr>Ÿ   rš   r(   c                ó   — g | ]	}|j         ‘Œ
S r>   rœ   r:   s     r&   rŒ   z?ArrowNamespace.max_horizontal.<locals>.func.<locals>.<listcomp>¡   r�   r(   rž   )
r‘   r   rE   r   rŸ   Úmax_element_wiser9   r   rC   r2   r¡   s   `   €€r&   rn   z+ArrowNamespace.max_horizontal.<locals>.funcž   r¤   r(   ro   rp   rq   r†   s   `` r&   Úmax_horizontalzArrowNamespace.max_horizontal�   r¦   r(   ÚdfsúSequence[pa.Table]úpa.Tablec               óp   — | j         dk    rt          j        |d¬¦  «        S t          j        |d¬¦  «        S )N)é   Údefault)Úpromote_optionsT)Úpromote)Ú_backend_versionÚpaÚconcat_tables)r%   r­   s     r&   Ú_concat_diagonalzArrowNamespace._concat_diagonal®   s<   € ØÔ  EÒ)Ð)ÝÔ# C¸ÐCÑCÔCÐCÝÔ ¨TÐ2Ñ2Ô2Ð2r(   c               óð   — t          t          j        d„ |D ¦   «         ¦  «        ¦  «        }t          t          j        d„ |D ¦   «         ¦  «        ¦  «        }t          j                             ||¬¦  «        S )Nc              3  ó$   K  — | ]}|j         V — Œd S r#   )Úcolumn_names©r;   rF   s     r&   r=   z4ArrowNamespace._concat_horizontal.<locals>.<genexpr>´   s$   è è € Ð(GÐ(G¸R¨¬Ð(GÐ(GÐ(GÐ(GÐ(GÐ(Gr(   c              3  ó>   K  — | ]}|                      ¦   «         V — Œd S r#   )Úitercolumnsr¼   s     r&   r=   z4ArrowNamespace._concat_horizontal.<locals>.<genexpr>µ   s,   è è € Ð*JÐ*JÀ¨2¯>ª>Ñ+;Ô+;Ð*JÐ*JÐ*JÐ*JÐ*JÐ*Jr(   )Únames)Úlistr   rE   r‘   r¶   ÚTableÚfrom_arrays)r%   r­   r¿   Úarrayss       r&   Ú_concat_horizontalz!ArrowNamespace._concat_horizontal³   sk   € Ý•UÔ(Ð(GÐ(GÀ3Ð(GÑ(GÔ(GÑGÔGÑHÔHˆÝ•uÔ*Ð*JÐ*JÀcÐ*JÑ*JÔ*JÑJÔJÑKÔKˆÝŒx×#Ò# F°%Ð#Ñ8Ô8Ð8r(   c               óÒ   — |d         j         }t          |dd …         d¬¦  «        D ]-\  }}|j         x}|k    rd|› d|› d|› d�}t          |¦  «        ‚Œ.t          j        |¦  «        S )Nr   rŽ   )Ústartz>unable to vstack, column names don't match:
   - dataframe 0: z
   - dataframe z: ú
)r»   Ú	enumerateÚ	TypeErrorr¶   r·   )r%   r­   Úcols_0ÚirF   Úcols_currentÚmsgs          r&   Ú_concat_verticalzArrowNamespace._concat_vertical¸   s¤   € Ø�Q”Ô$ˆÝ˜s 1 2 2œw¨aÐ0Ñ0Ô0ð 	%ð 	%‰EˆAˆrØ "¤Ð/�°FÒ:Ð:ð<Ø)/ð<ð <à&'ð<ð <à+7ð<ð <ð <ð õ
   ‘n”nÐ$ð ;õ Ô Ñ$Ô$Ð$r(   r   c                ó*   — t          j        | ¦  «        S r#   )r   Úfrom_namespacer$   s    r&   Ú	selectorszArrowNamespace.selectorsÄ   s   € å%Ô4°TÑ:Ô:Ð:r(   Ú	separatorÚstrc               ót   ‡ ‡‡‡— dˆˆˆ ˆfd„}‰ j                              |t          ‰Ž t          ‰Ž ‰ ¬¦  «        S )NrF   r	   r    rb   c                ó"  •‡ — t          t          j        ˆ fd„‰D ¦   «         ¦  «        ¦  «        }|d         j        }‰	rdnd}t	           ‰
j        |Ž d‰iŽ\  }}t          j        }‰
                      |g |¢|‘R d|iŽ|‰
j	        ¬¦  «        }|gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   r~   s     €r&   r=   z:ArrowNamespace.concat_str.<locals>.func.<locals>.<genexpr>Ì   s+   øè è € Ð-IÐ-I¸4¨d¨d°2©h¬hÐ-IÐ-IÐ-IÐ-IÐ-IÐ-Ir(   r   ÚskipÚ	emit_nullrÒ   Únull_handlingrž   )
rÀ   r   rE   rC   r   r?   rŸ   Úbinary_join_element_wiser.   r2   )rF   r4   rC   rÙ   r…   Úseparator_scalarÚ
concat_strÚ	compliantr^   r_   r%   rÒ   s   `       €€€€r&   rn   z'ArrowNamespace.concat_str.<locals>.funcË   sÏ   øø€ Ý�%Ô-Ð-IÐ-IÐ-IÐ-IÀ5Ð-IÑ-IÔ-IÑIÔIÑJÔJˆFØ˜!”9”>ˆDà&Ð7��¨Kð õ $CØ$�Ô$ fÐ-ð$Ø9Bð$ð $Ñ ˆBÐ õ
 &(Ô%@ˆJØŸšØ�
ÐN˜BÐNÐ 0ÐNÐNÐNÀÐNÐNØØœð %ñ ô ˆIð
 �;Ðr(   ro   rp   rq   )r%   rÒ   r_   r^   rn   s   ```` r&   rÜ   zArrowNamespace.concat_strÈ   sj   øøøø€ ð	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð& Œz×(Ò(ØÝ"?ÀÐ"GÝ9¸5ÐAØð	 )ñ 
ô 
ð 	
r(   c                ól   ‡ ‡— dˆˆ fd„}‰ j                              |t          ‰Ž t          ‰Ž ‰ ¬¦  «        S )NrF   r	   r    rb   c                óà   •‡ — ‰j         j        } |t          j        ˆ fd„‰D ¦   «         ¦  «        Ž ^}}t	          t          j        |j        gd„ |D ¦   «         ¢R Ž |j        ‰j	        ¬¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   r~   s     €r&   r=   z8ArrowNamespace.coalesce.<locals>.func.<locals>.<genexpr>è   s+   øè è € Ð=YÐ=YÈ4¸d¸dÀ2¹h¼hÐ=YÐ=YÐ=YÐ=YÐ=YÐ=Yr(   c              3  ó$   K  — | ]}|j         V — Œd S r#   rœ   r:   s     r&   r=   z8ArrowNamespace.coalesce.<locals>.func.<locals>.<genexpr>ë   s$   è è € Ð5OÐ5OÀ1°a´hÐ5OÐ5OÐ5OÐ5OÐ5OÐ5Or(   rž   )
r.   Ú_align_full_broadcastr   rE   r   rŸ   Úcoalescer9   rC   r2   )rF   Úalignr¢   r4   r^   r%   s   `   €€r&   rn   z%ArrowNamespace.coalesce.<locals>.funcæ   sŽ   øø€ Ø”LÔ6ˆEØ#( 5­%Ô*=Ð=YÐ=YÐ=YÐ=YÐSXÐ=YÑ=YÔ=YÑ*YÔ*YÐ#ZÐ ˆK˜&åÝ”K Ô 2ÐPÐ5OÐ5OÈÐ5OÑ5OÔ5OÐPÐPÐPØ$Ô)Ø œMðñ ô ðð r(   ro   rp   rq   r†   s   `` r&   rã   zArrowNamespace.coalesceå   s^   øø€ ð		ð 		ð 		ð 		ð 		ð 		ð 		ð Œz×(Ò(ØÝ"?ÀÐ"GÝ9¸5ÐAØð	 )ñ 
ô 
ð 	
r(   c                ól   ‡ ‡— dˆˆ fd„}‰ j                              |t          ‰Ž t          ‰Ž ‰ ¬¦  «        S )NrF   r	   r    rb   c                ó8  •‡ — t          t          j        ˆ fd„‰D ¦   «         ¦  «        ¦  «        }|d         j        }t	          j        d„ |D ¦   «         dt          d„ |D ¦   «         ¦  «        iŽ}t          j        |g¦  «        }t          ||‰j	        ¬¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   r~   s     €r&   r=   z6ArrowNamespace.struct.<locals>.func.<locals>.<genexpr>ú   ó+   øè è € Ð.JÐ.J¸D¨t¨t°B©x¬xÐ.JÐ.JÐ.JÐ.JÐ.JÐ.Jr(   r   c              3  ód   K  — | ]+}t          |¦  «        d k    r|j        n|j        d         V — Œ,dS )rŽ   r   N)rB   r9   r:   s     r&   r=   z6ArrowNamespace.struct.<locals>.func.<locals>.<genexpr>þ   s<   è è € ÐJÐJ¸a�c !™fœf qšj˜j�!”(�(¨a¬h°q¬kÐJÐJÐJÐJÐJÐJr(   Úfield_namesc              3  ó$   K  — | ]}|j         V — Œd S r#   )rC   r:   s     r&   r=   z6ArrowNamespace.struct.<locals>.func.<locals>.<genexpr>ÿ   s$   è è € Ð!9Ð!9¨Q !¤&Ð!9Ð!9Ð!9Ð!9Ð!9Ð!9r(   rž   )
r‘   r   rE   rC   rŸ   Úmake_structr¶   Úchunked_arrayr   r2   )rF   r4   rC   Ústruct_arrayÚresultr^   r%   s   `    €€r&   rn   z#ArrowNamespace.struct.<locals>.funcù   s«   øø€ Ý�5Ô.Ð.JÐ.JÐ.JÐ.JÀEÐ.JÑ.JÔ.JÑJÔJÑKÔKˆFØ˜!”9”>ˆDåœ>ØJÐJÀ6ÐJÑJÔJðå!Ð!9Ð!9°&Ð!9Ñ!9Ô!9Ñ9Ô9ðð ˆLõ Ô% | nÑ5Ô5ˆFÝ ¨T¸4¼=ÐIÑIÔIÐJÐJr(   ro   rp   rq   r†   s   `` r&   ÚstructzArrowNamespace.structø   se   øø€ ð		Kð 		Kð 		Kð 		Kð 		Kð 		Kð 		Kð Œz×(Ò(ØÝ"?ÀÐ"GÝ9¸5ÐAØð	 )ñ 
ô 
ð 	
r(   c                ól   ‡ ‡— dˆˆ fd„}‰ j                              |t          ‰Ž t          ‰Ž ‰ ¬¦  «        S )NrF   r	   r    rb   c                óØ   •‡ — t          t          j        ˆ fd„‰D ¦   «         ¦  «        ¦  «        }t          d„ |D ¦   «         ¦  «        }t	          ||d         j        ‰j        ¬¦  «        gS )Nc              3  ó.   •K  — | ]} |‰¦  «        V — Œd S r#   r>   r~   s     €r&   r=   z4ArrowNamespace.list.<locals>.func.<locals>.<genexpr>  rè   r(   c                ó@   — g | ]}|j                              ¦   «         ‘ŒS r>   )r9   Úcombine_chunksr:   s     r&   rŒ   z5ArrowNamespace.list.<locals>.func.<locals>.<listcomp>  s&   € Ð&QÐ&QÐ&QÀQ q¤x×'>Ò'>Ñ'@Ô'@Ð&QÐ&QÐ&Qr(   r   rž   )r‘   r   rE   r   r   rC   r2   )rF   r4   rï   r^   r%   s   `  €€r&   rn   z!ArrowNamespace.list.<locals>.func  sm   øø€ Ý�5Ô.Ð.JÐ.JÐ.JÐ.JÀEÐ.JÑ.JÔ.JÑJÔJÑKÔKˆFå%Ð&QÐ&QÈ&Ð&QÑ&QÔ&QÑRÔRˆFÝ ¨V°A¬Y¬^ÀTÄ]ÐSÑSÔSÐTÐTr(   ro   rp   rq   r†   s   `` r&   rÀ   zArrowNamespace.list  se   øø€ ð	Uð 	Uð 	Uð 	Uð 	Uð 	Uð 	Uð Œz×(Ò(ØÝ"?ÀÐ"GÝ9¸5ÐAØð	 )ñ 
ô 
ð 	
r(   NÚwhenr   ÚthenÚ	otherwiseúChunkedArrayAny | Nonec                óÎ   — |€'t          j        t          |¦  «        |j        ¦  «        n|}t	          j        |                     t          j        d¦  «        ¦  «        ||¦  «        S )NF)r¶   ÚnullsrB   ÚtyperŸ   Úif_elserj   Úscalar)r%   rö   r÷   rø   s       r&   Ú_if_then_elsezArrowNamespace._if_then_else  sR   € ð 7@Ð6G•B”H�S ™YœY¨¬	Ñ2Ô2Ð2ÈYˆ	ÝŒz˜$Ÿ.š.­¬°5Ñ)9Ô)9Ñ:Ô:¸DÀ)ÑLÔLÐLr(   ÚaÚbÚmethodr   c               óº   ‡ ‡‡— |dk    rd}t          |¦  «        ‚d	ˆˆˆ fd„}‰ j                             |t          ‰‰¦  «        t	          ‰‰¦  «        ‰ ¬¦  «        S )
NÚpearsonz4Only 'pearson' correlation is supported for Pyarrow.rF   r	   r    rb   c                óü  •— |                       ‰¦  «        }|j        }|                       ‰¦  «        j        }t          j        t          j        |¦  «        t          j        |¦  «        ¦  «        }t          j        ||¦  «        }t          j        ||¦  «        }t          j        |t          j        |¦  «        ¦  «        }t          j        |t          j        |¦  «        ¦  «        }t          j        t          j        ||¦  «        ¦  «        }t          j	        |¦  «        }t          j	        |¦  «        }	t          j
        |t          j        ||	¦  «        ¦  «        }
t          j        |
g|j        ‰¬¦  «        gS )NrV   )Ú_evaluate_single_output_exprr9   rŸ   rl   Úis_validÚfilterÚsubtractÚmeanÚmultiplyÚstddevÚdivider   rE   rC   )rF   Úa_seriesÚarr1Úarr2ÚvalidÚdev1Údev2Ú
covarianceÚstd1Ústd2Úcorrelationr   r  r%   s              €€€r&   rn   z!ArrowNamespace.corr.<locals>.func'  s(  ø€ Ø×6Ò6°qÑ9Ô9ˆHØ”?ˆDØ×2Ò2°1Ñ5Ô5Ô<ˆDÝ”G�BœK¨Ñ-Ô-­r¬{¸4Ñ/@Ô/@ÑAÔAˆEÝ”9˜T 5Ñ)Ô)ˆDÝ”9˜T 5Ñ)Ô)ˆDå”;˜t¥R¤W¨T¡]¤]Ñ3Ô3ˆDÝ”;˜t¥R¤W¨T¡]¤]Ñ3Ô3ˆDåœ¥¤¨T°4Ñ!8Ô!8Ñ9Ô9ˆJå”9˜T‘?”?ˆDÝ”9˜T‘?”?ˆDåœ) Jµ´¸DÀ$Ñ0GÔ0GÑHÔHˆKåÔ)Ø%˜¨X¬]ÀDðñ ô ðð r(   ro   rp   )ÚNotImplementedErrorr+   rr   r   r   )r%   r   r  r  rÍ   rn   s   ```   r&   ÚcorrzArrowNamespace.corr"  sŒ   øøø€ Ø�YÒÐØHˆCÝ% cÑ*Ô*Ð*ð	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð. Œz×(Ò(ØÝ"?ÀÀ1Ñ"EÔ"EÝ9¸!¸QÑ?Ô?Øð	 )ñ 
ô 
ð 	
r(   ÚddofÚintc               ó�   ‡ ‡‡‡— dˆˆˆˆ fd„}‰ j                              |t          ‰‰¦  «        t          ‰‰¦  «        ‰ ¬¦  «        S )NrF   r	   r    rb   c                ó0  •— |                       ‰
¦  «        }|j        }|                       ‰¦  «        j        }t          j        t          j        |¦  «        t          j        |¦  «        ¦  «        }t          j        ||¦  «        }t          j        ||¦  «        }t          |¦  «        }|‰z
  dk    r(t          j        d t          j	        ¦   «         ¬¦  «        }nŸt          j
        |t          j        |¦  «        ¦  «        }t          j
        |t          j        |¦  «        ¦  «        }t          j        t          j        ||¦  «        ¦  «        }	t          j        |	t          j        |‰z
  ¦  «        ¦  «        }t          j        |g|j        ‰¬¦  «        gS )Nr   )rü   rV   )r  r9   rŸ   rl   r  r  rB   r¶   rþ   Úfloat64r	  r
  Úsumr  r  r   rE   rC   )rF   r  r  r  r  Únr  r  r  Ú	numeratorr   r  r  r%   s             €€€€r&   rn   z ArrowNamespace.cov.<locals>.funcF  sF  ø€ Ø×6Ò6°qÑ9Ô9ˆHØ”?ˆDØ×2Ò2°1Ñ5Ô5Ô<ˆDÝ”G�BœK¨Ñ-Ô-­r¬{¸4Ñ/@Ô/@ÑAÔAˆEÝ”9˜T 5Ñ)Ô)ˆDÝ”9˜T 5Ñ)Ô)ˆDÝ�D‘	”	ˆAØ�4‰x˜1Š}ˆ}õ  œY tµ"´*±,´,Ð?Ñ?Ô?�
�
å”{ 4­¬°©¬Ñ7Ô7�Ý”{ 4­¬°©¬Ñ7Ô7�ÝœF¥2¤;¨t°TÑ#:Ô#:Ñ;Ô;�	ÝœY yµ"´)¸AÀ¹HÑ2EÔ2EÑFÔF�
åÔ)Ø$˜¨H¬MÀ4ðñ ô ðð r(   ro   rp   rq   )r%   r   r  r  rn   s   ```` r&   ÚcovzArrowNamespace.covE  st   øøøø€ ð	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð. Œz×(Ò(ØÝ"?ÀÀ1Ñ"EÔ"EÝ9¸!¸QÑ?Ô?Øð	 )ñ 
ô 
ð 	
r(   )r    r!   )r    r)   )r    r,   )r/   r   r    r0   )r4   r   r    r5   )r    r   )rO   r   rP   rQ   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   rø   rù   r    r   )r   r   r  r   r  r   r    r   )r   r   r  r   r  r  r    r   )Ú__name__Ú
__module__Ú__qualname__r   ÚPYARROWÚ_implementationÚpropertyr'   r+   r.   r3   r?   rB   r]   rt   rz   r‡   r–   r¥   r¬   r¸   rÄ   rÎ   rÑ   rÜ   rã   rð   rÀ   rÿ   r  r"  r>   r(   r&   r   r      s@  € € € € € ð %Ô,€Oàðð ð ñ „Xðð ðð ð ñ „Xðð ðð ð ñ „Xðð ð  ð  ð  ðKð Kð Kð Kð
	
ð 	
ð 	
ð 	
ð
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð"
ð 
ð 
ð 
ð"3ð 3ð 3ð 3ð
9ð 9ð 9ð 9ð

%ð 
%ð 
%ð 
%ð ð;ð ;ð ;ñ „Xð;ð
ð 
ð 
ð 
ð:
ð 
ð 
ð 
ð&
ð 
ð 
ð 
ð&
ð 
ð 
ð 
ð$ -1ð	Mð Mð Mð Mð Mð!
ð !
ð !
ð !
ðF
ð 
ð 
ð 
ð 
ð 
r(   r   r   )/Ú
__future__r   rk   Ú	functoolsr   Ú	itertoolsr   Útypingr   r   Úpyarrowr¶   Úpyarrow.computeÚcomputerŸ   Únarwhals._arrow.dataframer	   Únarwhals._arrow.exprr   Únarwhals._arrow.selectorsr   Únarwhals._arrow.seriesr   Únarwhals._arrow.utilsr   r   Únarwhals._compliantr   Únarwhals._expression_parsingr   r   Únarwhals._utilsr   Úcollections.abcr   r   Únarwhals._arrow.typingr   r   r   r   Únarwhals.typingr   r   r   rÁ   r   r>   r(   r&   ú<module>r;     sé  ðØ "Ð "Ð "Ð "Ð "Ð "à €€€Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð Ø )Ð )Ð )Ð )Ð )Ð )Ð )Ð )à Ð Ð Ð Ø Ð Ð Ð Ð Ð à 4Ð 4Ð 4Ð 4Ð 4Ð 4Ø *Ð *Ð *Ð *Ð *Ð *Ø <Ð <Ð <Ð <Ð <Ð <Ø .Ð .Ð .Ð .Ð .Ð .Ø SÐ SÐ SÐ SÐ SÐ SÐ SÐ SØ .Ð .Ð .Ð .Ð .Ð .ðð ð ð ð ð ð ð ð +Ð *Ð *Ð *Ð *Ð *àð LØ2Ð2Ð2Ð2Ð2Ð2Ð2Ð2àMÐMÐMÐMÐMÐMÐMÐMÐMÐMØ'Ð'Ð'Ð'Ð'Ð'ØKÐKÐKÐKÐKÐKÐKÐKÐKÐKðC
ð C
ð C
ð C
ð C
Ø�> ;°	¸2¼8ÐEVÐVÔWñC
ô C
ð C
ð C
ð C
r(   