Ë
    7Ò^j‰7  ã            
      ó>  — 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jZ                  df   «      Z.y)é    )Ú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                  ó6  — e Zd Zej                  Zedd„«       Zedd„«       Ze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#d„Zd#d„Zd#d„Zed$d„«       Z	 	 	 	 	 	 	 	 d%d„Zd"d„Zd"d„Zd"d„Z	 d&	 	 	 	 	 	 	 d'd„Zd(d„Zd)d„Zy)*ÚArrowNamespacec                ó   — t         S ©Nr   ©Úselfs    úd/var/www/ramen.bs-engineer-server.com/venv/lib/python3.12/site-packages/narwhals/_arrow/namespace.pyÚ
_dataframezArrowNamespace._dataframe$   s   € äÐó    c                ó   — t         S r!   r
   r"   s    r$   Ú_exprzArrowNamespace._expr(   s   € äÐr&   c                ó   — t         S r!   r   r"   s    r$   Ú_serieszArrowNamespace._series,   s   € äÐr&   c               ó   — || _         y r!   )Ú_version)r#   Úversions     r$   Ú__init__zArrowNamespace.__init__0   s	   € Øˆ�r&   c                ó   — d„ |D «       S )Nc              3  ój   K  — | ]+  }|j                   r|j                  d    n|j                  –— Œ- y­w)r   N)Ú
_broadcastÚnative©Ú.0Úss     r$   ú	<genexpr>z0ArrowNamespace.extract_native.<locals>.<genexpr>6   s'   è ø€ ÒJ¸a˜qŸ|š|�—‘˜’°·±Ó9ÑJùs   ‚13© )r#   Úseriess     r$   Úextract_nativezArrowNamespace.extract_native3   s   € ñ KÀ6ÔJÐJr&   c                óJ   ‡ — ‰ j                  ˆ fd„d„ d ‰ j                  ¬«      S )Nc                ó^   •— t        j                  t        | j                  «      gd‰¬«      gS )NÚlen)ÚnameÚcontext)r   Úfrom_iterabler<   r2   )Údfr#   s    €r$   ú<lambda>z$ArrowNamespace.len.<locals>.<lambda>;   s(   ø€ Ü×)Ñ)¬3¨r¯y©y«>Ð*:ÀÐPTÔUð€ r&   c                ó   — dgS )Nr<   r7   ©Ú_dfs    r$   rA   z$ArrowNamespace.len.<locals>.<lambda>>   s   € ¨u¨g€ r&   ©Úevaluate_output_namesÚalias_output_namesr-   ©r(   r,   r"   s   `r$   r<   zArrowNamespace.len8   s-   ø€ à�z‰zóñ #6Ø#Ø—M‘Mð ó 
ð 	
r&   c                ó`   ‡ ‡‡‡— dˆˆ ˆfd„Š‰ j                  ˆfd„d„ d ‰ j                  ¬«      S )Nc                ó`   •— t        j                  ‰gd‰¬«      }‰r|j                  ‰«      S |S )NÚliteral©Údatar=   r>   )r   r?   Úcast)Ú_Úarrow_seriesÚdtyper#   Úvalues     €€€r$   Ú_lit_arrow_seriesz-ArrowNamespace.lit.<locals>._lit_arrow_seriesD   s8   ø€ Ü&×4Ñ4Ø�W 9°dôˆLñ Ø#×(Ñ(¨Ó/Ð/ØÐr&   c                ó   •—  ‰| «      gS r!   r7   )r@   rS   s    €r$   rA   z$ArrowNamespace.lit.<locals>.<lambda>M   s   ø€ Ñ)¨"Ó-Ð.€ r&   c                ó   — dgS )NrK   r7   rC   s    r$   rA   z$ArrowNamespace.lit.<locals>.<lambda>N   s   € ¨y¨k€ r&   rE   )rO   r	   Úreturnr   rH   )r#   rR   rQ   rS   s   ```@r$   ÚlitzArrowNamespace.litC   s0   û€ ÷	 ð �z‰zÛ.Ù"9Ø#Ø—M‘Mð	 ó 
ð 	
r&   c               ój   ‡‡— dˆˆfd„}| j                   j                  |t        ‰Ž t        ‰Ž | ¬«      S )Nc                óŽ   •‡ — t        j                  ˆ fd„‰D «       «      }‰r	d„ |D «       }t        t        j                  |«      gS )Nc              3  ó.   •K  — | ]  } |‰«      –— Œ y ­wr!   r7   ©r4   Úer@   s     €r$   r6   z>ArrowNamespace.all_horizontal.<locals>.func.<locals>.<genexpr>U   ó   øè ø€ Ò?UÈ!ÁÀ"ÇÑ?Uùó   ƒc              3  óB   K  — | ]  }|j                  d dd«      –— Œ y­w)TN©Ú	fill_nullr3   s     r$   r6   z>ArrowNamespace.all_horizontal.<locals>.func.<locals>.<genexpr>W   s   è ø€ ÒH¸A˜!Ÿ+™+ d¨D°$×7ÑHùó   ‚)r   r?   r   ÚoperatorÚand_©r@   r8   ÚexprsÚignore_nullss   ` €€r$   Úfuncz+ArrowNamespace.all_horizontal.<locals>.funcT   s:   ù€ Ü,1×,?Ñ,?Ó?UÈuÔ?UÓ,UˆFÙÙHÀÔH�Üœ8Ÿ=™=¨&Ó1Ð2Ð2r&   ©rh   rF   rG   r>   ©r@   r	   rV   zlist[ArrowSeries]©r(   Ú_from_callabler   r   ©r#   rg   rf   rh   s    `` r$   Úall_horizontalzArrowNamespace.all_horizontalS   s<   ù€ ö	3ð �z‰z×(Ñ(ØÜ"?ÀÐ"GÜ9¸5ÐAØð	 )ó 
ð 	
r&   c               ój   ‡‡— dˆˆfd„}| j                   j                  |t        ‰Ž t        ‰Ž | ¬«      S )Nc                óŽ   •‡ — t        j                  ˆ fd„‰D «       «      }‰r	d„ |D «       }t        t        j                  |«      gS )Nc              3  ó.   •K  — | ]  } |‰«      –— Œ y ­wr!   r7   r[   s     €r$   r6   z>ArrowNamespace.any_horizontal.<locals>.func.<locals>.<genexpr>c   r]   r^   c              3  óB   K  — | ]  }|j                  d dd«      –— Œ y­w)FNr`   r3   s     r$   r6   z>ArrowNamespace.any_horizontal.<locals>.func.<locals>.<genexpr>e   s   è ø€ ÒI¸Q˜!Ÿ+™+ e¨T°4×8ÑIùrb   )r   r?   r   rc   Úor_re   s   ` €€r$   rh   z+ArrowNamespace.any_horizontal.<locals>.funcb   s:   ù€ Ü,1×,?Ñ,?Ó?UÈuÔ?UÓ,UˆFÙÙIÀ&ÔI�Üœ8Ÿ<™<¨Ó0Ð1Ð1r&   ri   rj   rk   rm   s    `` r$   Úany_horizontalzArrowNamespace.any_horizontala   s<   ù€ ö	2ð �z‰z×(Ñ(ØÜ"?ÀÐ"GÜ9¸5ÐAØð	 )ó 
ð 	
r&   c                óf   ‡— dˆfd„}| j                   j                  |t        ‰Ž t        ‰Ž | ¬«      S )Nc                óŠ   •‡ — t        j                  ˆ fd„‰D «       «      }d„ |D «       }t        t        j                  |«      gS )Nc              3  ó.   •K  — | ]  } |‰«      –— Œ y ­wr!   r7   ©r4   Úexprr@   s     €r$   r6   z>ArrowNamespace.sum_horizontal.<locals>.func.<locals>.<genexpr>q   s   øè ø€ Ò$@°$¡T¨"§XÑ$@ùr^   c              3  óD   K  — | ]  }|j                  d dd¬«      –— Œ y­w)r   N©ÚstrategyÚlimitr`   r3   s     r$   r6   z>ArrowNamespace.sum_horizontal.<locals>.func.<locals>.<genexpr>r   s   è ø€ ÒLÀA�a—k‘k !¨d¸$�k×?ÑLùs   ‚ )r   r?   r   rc   Úadd)r@   Úitr8   rf   s   `  €r$   rh   z+ArrowNamespace.sum_horizontal.<locals>.funcp   s7   ù€ Ü×$Ñ$Ó$@¸%Ô$@Ó@ˆBÙLÈÔLˆFÜœ8Ÿ<™<¨Ó0Ð1Ð1r&   ri   rj   rk   ©r#   rf   rh   s    ` r$   Úsum_horizontalzArrowNamespace.sum_horizontalo   s<   ø€ õ	2ð
 �z‰z×(Ñ(ØÜ"?ÀÐ"GÜ9¸5ÐAØð	 )ó 
ð 	
r&   c                ó²   ‡‡— | j                   j                  j                  «       Šdˆˆfd„}| j                  j	                  |t        ‰Ž t        ‰Ž | ¬«      S )Nc                ót  •‡ — t        t        j                  ˆ fd„‰D «       «      «      }|D �cg c]  }|j                  dd d ¬«      ‘Œ }}|D �cg c]$  }d|j	                  «       j                  ‰«      z
  ‘Œ& }}t        t        j                  |«      t        t        j                  |«      z  gS c c}w c c}w )Nc              3  ó.   •K  — | ]  } |‰«      –— Œ y ­wr!   r7   rx   s     €r$   r6   z?ArrowNamespace.mean_horizontal.<locals>.func.<locals>.<genexpr>€   s   øè ø€ Ò4PÀ$±T¸"·XÑ4Pùr^   r   r{   é   )	Útupler   r?   ra   Úis_nullrN   r   rc   r~   )r@   Úexpr_resultsr5   r8   Únon_narf   Úint_64s   `    €€r$   rh   z,ArrowNamespace.mean_horizontal.<locals>.func   s–   ù€ Ü ¤×!4Ñ!4Ó4PÈ%Ô4PÓ!PÓQˆLØIUÖVÀA�a—k‘k !¨d¸$�kÕ?ÐVˆFÐVØ<HÖI°q�a˜!Ÿ)™)›+×*Ñ*¨6Ó2Ó2ÐIˆFÐIÜœ8Ÿ<™<¨Ó0´6¼(¿,¹,ÈÓ3OÑOÐPÐPùò WùÚIs   ®B0Á)B5ri   rj   )r,   ÚdtypesÚInt64r(   rl   r   r   )r#   rf   rh   rŠ   s    ` @r$   Úmean_horizontalzArrowNamespace.mean_horizontal|   sU   ù€ Ø—‘×%Ñ%×+Ñ+Ó-ˆö	Qð �z‰z×(Ñ(ØÜ"?ÀÐ"GÜ9¸5ÐAØð	 )ó 
ð 	
r&   c                ój   ‡ ‡— dˆˆ fd„}‰ j                   j                  |t        ‰Ž t        ‰Ž ‰ ¬«      S )Nc                ó"  •‡ — t        t        j                  ˆ fd„‰D «       «      «      ^}}t        t        j
                  |D �cg c]  }|j                  ‘Œ c}|j                  «      }t        ||j                  ‰j                  ¬«      gS c c}w )Nc              3  ó.   •K  — | ]  } |‰«      –— Œ y ­wr!   r7   rx   s     €r$   r6   z>ArrowNamespace.min_horizontal.<locals>.func.<locals>.<genexpr>Ž   ó   øè ø€ Ò<XÈ$¹TÀ"¿XÑ<Xùr^   ©r=   r-   )
r†   r   r?   r   ÚpcÚmin_element_wiser2   r   r=   r,   ©r@   Úinit_seriesr8   r5   Únative_seriesrf   r#   s   `    €€r$   rh   z+ArrowNamespace.min_horizontal.<locals>.func�   óx   ù€ Ü#(¬×)<Ñ)<Ó<XÐRWÔ<XÓ)XÓ#YÐ ˆK˜&Ü"Ü×#Ñ#¸Ö%?°1 a§h£hÒ%?À×ASÑASóˆMô ˜M°×0@Ñ0@È$Ï-É-ÔXðð ùò &@ó   ÁB
ri   rj   rk   r€   s   `` r$   Úmin_horizontalzArrowNamespace.min_horizontalŒ   ó<   ù€ ö	ð �z‰z×(Ñ(ØÜ"?ÀÐ"GÜ9¸5ÐAØð	 )ó 
ð 	
r&   c                ój   ‡ ‡— dˆˆ fd„}‰ j                   j                  |t        ‰Ž t        ‰Ž ‰ ¬«      S )Nc                ó"  •‡ — t        t        j                  ˆ fd„‰D «       «      «      ^}}t        t        j
                  |D �cg c]  }|j                  ‘Œ c}|j                  «      }t        ||j                  ‰j                  ¬«      gS c c}w )Nc              3  ó.   •K  — | ]  } |‰«      –— Œ y ­wr!   r7   rx   s     €r$   r6   z>ArrowNamespace.max_horizontal.<locals>.func.<locals>.<genexpr>Ÿ   r‘   r^   r’   )
r†   r   r?   r   r“   Úmax_element_wiser2   r   r=   r,   r•   s   `    €€r$   rh   z+ArrowNamespace.max_horizontal.<locals>.funcž   r˜   r™   ri   rj   rk   r€   s   `` r$   Úmax_horizontalzArrowNamespace.max_horizontal�   r›   r&   c               ó|   — | j                   dk\  rt        j                  |d¬«      S t        j                  |d¬«      S )N)é   Údefault)Úpromote_optionsT)Úpromote)Ú_backend_versionÚpaÚconcat_tables)r#   Údfss     r$   Ú_concat_diagonalzArrowNamespace._concat_diagonal®   s6   € Ø× Ñ  EÒ)Ü×#Ñ# C¸ÔCÐCÜ×Ñ ¨TÔ2Ð2r&   c               óØ   — t        t        j                  d„ |D «       «      «      }t        t        j                  d„ |D «       «      «      }t        j
                  j                  ||¬«      S )Nc              3  ó4   K  — | ]  }|j                   –— Œ y ­wr!   )Úcolumn_names©r4   r@   s     r$   r6   z4ArrowNamespace._concat_horizontal.<locals>.<genexpr>´   s   è ø€ Ò(G¸R¨¯­Ñ(Gùó   ‚c              3  ó<   K  — | ]  }|j                  «       –— Œ y ­wr!   )Úitercolumnsr®   s     r$   r6   z4ArrowNamespace._concat_horizontal.<locals>.<genexpr>µ   s   è ø€ Ò*JÀ¨2¯>©>×+;Ñ*Jùs   ‚)Únames)Úlistr   r?   r†   r§   ÚTableÚfrom_arrays)r#   r©   r²   Úarrayss       r$   Ú_concat_horizontalz!ArrowNamespace._concat_horizontal³   sR   € Ü”U×(Ñ(Ñ(GÀ3Ô(GÓGÓHˆÜ”u×*Ñ*Ñ*JÀcÔ*JÓJÓKˆÜ�x‰x×#Ñ# F°%Ð#Ó8Ð8r&   c               óÊ   — |d   j                   }t        |dd  d¬«      D ]-  \  }}|j                   x}|k7  sŒ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Úir@   Úcols_currentÚmsgs          r$   Ú_concat_verticalzArrowNamespace._concat_vertical¸   s‡   € Ø�Q‘×$Ñ$ˆÜ˜s 1 2˜w¨aÔ0ò 	%‰EˆAˆrØ "§¡Ð/�°FÓ:ð)Ø)/¨ð 1&Ø&' S¨¨<¨.¸ð<ð ô
   “nÐ$ð	%ô ×Ñ Ó$Ð$r&   c                ó,   — t        j                  | «      S r!   )r   Úfrom_namespacer"   s    r$   Ú	selectorszArrowNamespace.selectorsÄ   s   € ä%×4Ñ4°TÓ:Ð:r&   c               ór   ‡ ‡‡‡— dˆˆˆ ˆfd„}‰ j                   j                  |t        ‰Ž t        ‰Ž ‰ ¬«      S )Nc                ó,  •‡ — t        t        j                  ˆ fd„‰D «       «      «      }|d   j                  }‰	rdnd}t	         ‰
j
                  |Ž d‰iŽ\  }}t        j                  }‰
j                   |g |¢|‘­d|iŽ|‰
j                  ¬«      }|gS )Nc              3  ó.   •K  — | ]  } |‰«      –— Œ y ­wr!   r7   rx   s     €r$   r6   z:ArrowNamespace.concat_str.<locals>.func.<locals>.<genexpr>Ì   s   øè ø€ Ò-I¸4©d°2¯hÑ-Iùr^   r   ÚskipÚ	emit_nullÚ	separatorÚnull_handlingr’   )
r³   r   r?   r=   r   r9   r“   Úbinary_join_element_wiser*   r,   )r@   r8   r=   rË   r   Úseparator_scalarÚ
concat_strÚ	compliantrf   rg   r#   rÊ   s   `       €€€€r$   rh   z'ArrowNamespace.concat_str.<locals>.funcË   s¬   ù€ Üœ%×-Ñ-Ó-IÀ5Ô-IÓIÓJˆFØ˜!‘9—>‘>ˆDá&‘¨Kð ô $CØ$�×$Ñ$ fÐ-ð$Ø9Bñ$Ñ ˆBÐ ô
 &(×%@Ñ%@ˆJØŸ™ÙÐN˜BÐNÐ 0ÒNÀÑNØØŸ™ð %ó ˆIð
 �;Ðr&   ri   rj   rk   )r#   rÊ   rg   rf   rh   s   ```` r$   rÎ   zArrowNamespace.concat_strÈ   sA   û€ ÷	ð 	ð& �z‰z×(Ñ(ØÜ"?ÀÐ"GÜ9¸5ÐAØð	 )ó 
ð 	
r&   c                ój   ‡ ‡— dˆˆ fd„}‰ j                   j                  |t        ‰Ž t        ‰Ž ‰ ¬«      S )Nc                ó  •‡ — ‰j                   j                  } |t        j                  ˆ fd„‰D «       «      Ž ^}}t	        t        j                  |j                  gd„ |D «       ¢­Ž |j                  ‰j                  ¬«      gS )Nc              3  ó.   •K  — | ]  } |‰«      –— Œ y ­wr!   r7   rx   s     €r$   r6   z8ArrowNamespace.coalesce.<locals>.func.<locals>.<genexpr>è   s   øè ø€ Ò=YÈ4¹dÀ2¿hÑ=Yùr^   c              3  ó4   K  — | ]  }|j                   –— Œ y ­wr!   )r2   r3   s     r$   r6   z8ArrowNamespace.coalesce.<locals>.func.<locals>.<genexpr>ë   s   è ø€ Ò5OÀ1°a·hµhÑ5Oùr¯   r’   )
r*   Ú_align_full_broadcastr   r?   r   r“   Úcoalescer2   r=   r,   )r@   Úalignr–   r8   rf   r#   s   `   €€r$   rh   z%ArrowNamespace.coalesce.<locals>.funcæ   sr   ù€ Ø—L‘L×6Ñ6ˆEÙ#(¬%×*=Ñ*=Ó=YÐSXÔ=YÓ*YÐ#ZÐ ˆK˜&äÜ—K‘K × 2Ñ 2ÐPÑ5OÈÔ5OÒPØ$×)Ñ)Ø ŸM™Môðð r&   ri   rj   rk   r€   s   `` r$   rÕ   zArrowNamespace.coalesceå   s<   ù€ ö		ð �z‰z×(Ñ(ØÜ"?ÀÐ"GÜ9¸5ÐAØð	 )ó 
ð 	
r&   c                ój   ‡ ‡— dˆˆ fd„}‰ j                   j                  |t        ‰Ž t        ‰Ž ‰ ¬«      S )Nc                ó(  •‡ — 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  — | ]  } |‰«      –— Œ y ­wr!   r7   rx   s     €r$   r6   z6ArrowNamespace.struct.<locals>.func.<locals>.<genexpr>ú   ó   øè ø€ Ò.J¸D©t°B¯xÑ.Jùr^   r   c              3  ón   K  — | ]-  }t        |«      d kD  r|j                  n|j                  d   –— Œ/ y­w)r…   r   N)r<   r2   r3   s     r$   r6   z6ArrowNamespace.struct.<locals>.func.<locals>.<genexpr>þ   s+   è ø€ ÒJ¸aœc !›f qšj�!—(’(¨a¯h©h°q©kÓ9ÑJùs   ‚35Úfield_namesc              3  ó4   K  — | ]  }|j                   –— Œ y ­wr!   )r=   r3   s     r$   r6   z6ArrowNamespace.struct.<locals>.func.<locals>.<genexpr>ÿ   s   è ø€ Ò!9¨Q !§&¥&Ñ!9ùr¯   r’   )
r†   r   r?   r=   r“   Úmake_structr§   Úchunked_arrayr   r,   )r@   r8   r=   Ústruct_arrayÚresultrf   r#   s   `    €€r$   rh   z#ArrowNamespace.struct.<locals>.funcù   s~   ù€ Üœ5×.Ñ.Ó.JÀEÔ.JÓJÓKˆFØ˜!‘9—>‘>ˆDäŸ>™>ÙJÀ6ÔJðä!Ñ!9°&Ô!9Ó9ñˆLô ×%Ñ% | nÓ5ˆFÜ ¨T¸4¿=¹=ÔIÐJÐJr&   ri   rj   rk   r€   s   `` r$   ÚstructzArrowNamespace.structø   s=   ù€ ö		Kð �z‰z×(Ñ(ØÜ"?ÀÐ"GÜ9¸5ÐAØð	 )ó 
ð 	
r&   c                ój   ‡ ‡— dˆˆ fd„}‰ j                   j                  |t        ‰Ž t        ‰Ž ‰ ¬«      S )Nc                ó  •‡ — t        t        j                  ˆ fd„‰D «       «      «      }t        |D �cg c]  }|j                  j                  «       ‘Œ c}«      }t        ||d   j                  ‰j                  ¬«      gS c c}w )Nc              3  ó.   •K  — | ]  } |‰«      –— Œ y ­wr!   r7   rx   s     €r$   r6   z4ArrowNamespace.list.<locals>.func.<locals>.<genexpr>  rÚ   r^   r   r’   )	r†   r   r?   r   r2   Úcombine_chunksr   r=   r,   )r@   r8   r5   rá   rf   r#   s   `   €€r$   rh   z!ArrowNamespace.list.<locals>.func  sd   ù€ Üœ5×.Ñ.Ó.JÀEÔ.JÓJÓKˆFä%È&Ö&QÀQ q§x¡x×'>Ñ'>Õ'@Ò&QÓRˆFÜ ¨V°A©Y¯^©^ÀTÇ]Á]ÔSÐTÐTùò 'Rs   ³!Bri   rj   rk   r€   s   `` r$   r³   zArrowNamespace.list  s=   ù€ ö	Uð �z‰z×(Ñ(ØÜ"?ÀÐ"GÜ9¸5ÐAØð	 )ó 
ð 	
r&   Nc                óÎ   — |€)t        j                  t        |«      |j                  «      n|}t	        j
                  |j                  t        j                  d«      «      ||«      S )NF)r§   Únullsr<   Útyper“   Úif_elsera   Úscalar)r#   ÚwhenÚthenÚ	otherwises       r$   Ú_if_then_elsezArrowNamespace._if_then_else  sI   € ð 7@Ð6G”B—H‘HœS ›Y¨¯	©	Ô2ÈYˆ	Ü�z‰z˜$Ÿ.™.¬¯©°5Ó)9Ó:¸DÀ)ÓLÐLr&   c               ó¢   ‡ ‡‡— |dk7  rd}t        |«      ‚dˆˆˆ fd„}‰ j                  j                  |t        ‰‰«      t	        ‰‰«      ‰ ¬«      S )NÚpearsonz4Only 'pearson' correlation is supported for Pyarrow.c                ó*  •— | j                  ‰«      }|j                  }| 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 )NrL   )Ú_evaluate_single_output_exprr2   r“   rd   Úis_validÚfilterÚsubtractÚmeanÚmultiplyÚstddevÚdivider   r?   r=   )r@   Úa_seriesÚarr1Úarr2ÚvalidÚdev1Údev2Ú
covarianceÚstd1Ústd2ÚcorrelationÚaÚbr#   s              €€€r$   rh   z!ArrowNamespace.corr.<locals>.func'  s  ø€ Ø×6Ñ6°qÓ9ˆHØ—?‘?ˆDØ×2Ñ2°1Ó5×<Ñ<ˆDÜ—G‘GœBŸK™K¨Ó-¬r¯{©{¸4Ó/@ÓAˆEÜ—9‘9˜T 5Ó)ˆDÜ—9‘9˜T 5Ó)ˆDä—;‘;˜t¤R§W¡W¨T£]Ó3ˆDÜ—;‘;˜t¤R§W¡W¨T£]Ó3ˆDäŸ™¤§¡¨T°4Ó!8Ó9ˆJä—9‘9˜T“?ˆDÜ—9‘9˜T“?ˆDäŸ)™) J´·±¸DÀ$Ó0GÓHˆKä×)Ñ)Ø%˜¨X¯]©]ÀDôðð r&   ri   rj   )ÚNotImplementedErrorr(   rl   r   r   )r#   r  r  ÚmethodrÀ   rh   s   ```   r$   ÚcorrzArrowNamespace.corr"  sX   ú€ Ø�YÒØHˆCÜ% cÓ*Ð*÷	ð. �z‰z×(Ñ(ØÜ"?ÀÀ1Ó"EÜ9¸!¸QÓ?Øð	 )ó 
ð 	
r&   c               ó‚   ‡ ‡‡‡— dˆˆˆˆ fd„}‰ j                   j                  |t        ‰‰«      t        ‰‰«      ‰ ¬«      S )Nc                óT  •— | j                  ‰
«      }|j                  }| 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é   rL   )ró   r2   r“   rd   rô   rõ   r<   r§   rë   Úfloat64rö   r÷   Úsumrø   rú   r   r?   r=   )r@   rû   rü   rý   rþ   Únr  rÿ   r   Ú	numeratorr  r  Úddofr#   s             €€€€r$   rh   z ArrowNamespace.cov.<locals>.funcF  s+  ø€ Ø×6Ñ6°qÓ9ˆHØ—?‘?ˆDØ×2Ñ2°1Ó5×<Ñ<ˆDÜ—G‘GœBŸK™K¨Ó-¬r¯{©{¸4Ó/@ÓAˆEÜ—9‘9˜T 5Ó)ˆDÜ—9‘9˜T 5Ó)ˆDÜ�D“	ˆAØ�4‰x˜1Š}ô  ŸY™Y t´"·*±*³,Ô?‘
ä—{‘{ 4¬¯©°«Ó7�Ü—{‘{ 4¬¯©°«Ó7�ÜŸF™F¤2§;¡;¨t°TÓ#:Ó;�	ÜŸY™Y y´"·)±)¸AÀ¹HÓ2EÓF�
ä×)Ñ)Ø$˜¨H¯M©MÀ4ôðð r&   ri   rj   rk   )r#   r  r  r  rh   s   ```` r$   ÚcovzArrowNamespace.covE  sE   û€ ÷	ð 	ð. �z‰z×(Ñ(ØÜ"?ÀÀ1Ó"EÜ9¸!¸QÓ?Øð	 )ó 
ð 	
r&   )rV   ztype[ArrowDataFrame])rV   ztype[ArrowExpr])rV   ztype[ArrowSeries])r-   r   rV   ÚNone)r8   r   rV   z%Iterator[ChunkedArrayAny | ScalarAny])rV   r   )rR   r   rQ   zIntoDType | NonerV   r   )rf   r   rg   ÚboolrV   r   )rf   r   rV   r   )r©   zSequence[pa.Table]rV   zpa.Table)rV   r   )rf   r   rÊ   Ústrrg   r  rV   r   r!   )rì   r   rí   r   rî   zChunkedArrayAny | NonerV   r   )r  r   r  r   r  r   rV   r   )r  r   r  r   r  ÚintrV   r   )Ú__name__Ú
__module__Ú__qualname__r   ÚPYARROWÚ_implementationÚpropertyr%   r(   r*   r.   r9   r<   rW   rn   rt   r�   r�   rš   r    rª   r·   rÁ   rÄ   rÎ   rÕ   râ   r³   rï   r	  r  r7   r&   r$   r   r      s%  „ ð %×,Ñ,€Oàòó ðð òó ðð òó ðó ðKØ"ðKà	.óKó
	
ó
ó 
ó
ó
ó
ó 
ó"
ó"3ó
9ó

%ð ò;ó ð;ð
Øð
Ø,/ð
Ø?Cð
à	ó
ó:
ó&
ó&
ð$ -1ð	MàðMð ðMð *ð	Mð
 
óMó!
ôF
r&   r   r   )/Ú
__future__r   rc   Ú	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   r7   r&   r$   ú<module>r.     so   ðÝ "ã Ý Ý ß )ã Ý å 4Ý *Ý <Ý .ß SÝ .÷õ +áß2çMÑMÝ'ßKÑKôC
Ø�> ;°	¸2¿8¹8ÐEVÐVÑWõC
r&   