}imUddlmZddlmZmZddlmZmZmZm Z m Z ddl m Z ddl mZddlmZmZmZere/j?e3j@e/jAe3jBe/jCe3j7i ZDd-eEd.<e/j4e3jFe/j8e3jGe/jHe3jIe/jJe3jKe/jLe3jMe/jNe3jOe/jPe3jQe/jRe3jSiZTd/eEd0<d[d6ZUd\d;ZVdd?d]dFZWd^dKZXd_dMZYd`dOZZdadQZ[dbdTZ\d=S)c) annotations)Enumauto) TYPE_CHECKINGAnyCallableLiteralcast) zip_strict)is_numpy_array_1d)InvalidIntoExprErrorInvalidOperationErrorMultiOutputExpressionError)IteratorSequence)NeverTypeIs) CompliantExprCompliantFrameT) AliasNamesCompliantExprAnyCompliantFrameAnyCompliantNamespaceAny EvalNamesExprSeries)IntoExprNonNestedLiteral_1DArrayobjrreturn TypeIs[Expr]c.ddlm}t||S)'Check whether `obj` is a Narwhals Expr.rr) narwhals.exprr isinstance)r"rs P/home/jrussi/.local/lib/python3.11/site-packages/narwhals/_expression_parsing.pyis_exprr*$s$"""""" c4  TypeIs[Series[Any]]c.ddlm}t||S)r&rr)narwhals.seriesrr()r"rs r) is_seriesr/+s$&&&&&& c6 " ""r+exprs#CompliantExpr[CompliantFrameT, Any]EvalNames[CompliantFrameT]cdfd }|S)Ndfrr# Sequence[str]cJd|ddSNr)_evaluate_output_names)r4r0s r)evaluate_output_namesz.evaluate_output_names7s$Qx..r222A266r+)r4rr#r5)r0r:s` r)combine_evaluate_output_namesr<2s) 777777 ! r+rAliasNames | Nonec2djdSdfd }|S)Nrnamesr5r#cJd|ddSr7_alias_output_names)r?r0s r)alias_output_namesz6combine_alias_output_names..alias_output_namesCs$Qx++E222A266r+)r?r5r#r5rA)r0rCs` r)combine_alias_output_namesrD=s= Qx#+t777777 r+exprr4rexcluder5#tuple[Sequence[str], Sequence[str]]c||}|jx} ||n|}rD|jjr&t fdt ||D\}}||fS)Nc&g|] \}}|v ||fSr;r;).0xaliasrFs r) z5evaluate_output_names_and_aliases..Ts6AuG##E ###r+)r9rB _metadataexpansion_kindis_multi_unnamedr )rEr4rF output_namesalias_fnaliasess ` r)!evaluate_output_names_and_aliasesrTIs..r22L0 0H =    4>0AACC * *< A A!  g   r+ceZdZdZeZ eZ eZ eZ eZ eZ eZ eZ eZ eZ eZ eZ eZ eZ eZ eZ ed dZed dZed dZed dZdS) ExprKindz6Describe which kind of expression we are dealing with.r#boolcb|tjtjtjtjhvSN)rVORDERABLE_WINDOWWINDOWORDERABLE_AGGREGATIONORDERABLE_FILTRATIONselfs r) is_orderablezExprKind.is_orderables-  % O  *  )    r+c |tjtjtjtjtjtjtjtjtj h vSrY) rVALLCOL ELEMENTWISEEXCLUDELITERALNTHSELECTORSERIES WHEN_THENr^s r)is_elementwisezExprKind.is_elementwisesH L L      L   O     r+cD|jp|tjtjhvSrY)rkrVr[rZr^s r)preserves_lengthzExprKind.preserves_lengths"Zdx@Y.Z&ZZr+cL|tjtjtjhvSrY)rV AGGREGATIONrfr\r^s r)is_scalar_likezExprKind.is_scalar_likes&     *   r+Nr#rW)__name__ __module__ __qualname____doc__rrfror\rdrZr[ FILTRATIONr]OVERrcrgrerbrhrjripropertyr`rkrmrpr;r+r)rVrV]s@@dffG$&&KY DFFX$&&KgtvvH TVVFNJG466= 466D5 $&&C( $&&C(dffG, $&&C(tvvH>IP TVVF3    X     X  [[[X[   X   r+rVrWc|jjSrY)rNrp)r"s r)rprps = ''r+cleZdZdZeZ eZ eZ d dZd dZ d dZ d S) ExpansionKindz8Describe what kind of expansion the expression performs.r#rWc|tjuSrYr{ MULTI_UNNAMEDr^s r)rPzExpansionKind.is_multi_unnameds}222r+c6|tjtjhvSrY)r{ MULTI_NAMEDr~r^s r)is_multi_outputzExpansionKind.is_multi_outputs 1=3NOOOr+other$Literal[ExpansionKind.MULTI_UNNAMED]c|tjur|tjur tjSd|d|d}t|)Nz+Unsupported ExpansionKind combination, got z and z, please report a bug.)r{r~AssertionError)r_rmsgs r)__and__zExpansionKind.__and__sL =. . .5Mz$ExprNode.__repr__..s(CCc!ffCCCCCCr+r?zcol()c34K|]}t|VdSrYrrs r)rz$ExprNode.__repr__..s(99c!ff999999r+c3*K|]\}}|d|VdS)=Nr;)rJkeyvalues r)rz$ExprNode.__repr__..s4WWZS%3 0 0 0 0WWWWWWr+()rjoinrr0itemsappend)r_r?arg_str expr_repr kwargs_reprs r)__repr__zExprNode.__repr__s 9  IICCdk'.BCCCCCE"%??? "II99dj99999 iiWW4;CTCTCVCVWWWWW : & NN9 % % % ; ( NN; ' ' ')33dii003333r+dict[str, Any]cP|j|j|j|j|j|jdS)Nrrr0rrrrr^s r)as_dictzExprNode.as_dicts2IIZk/"&"9    r+c N|j|j|jf|j|jd|S)N)r0r) __class__rrr0r)r_rs r) _with_kwargszExprNode._with_kwargss<t~ Ity (, t  RX   r+ over_nodeover_node_without_order_bycg}|jd}|jd}|jD]}t|s||'|rGt d|jDr)|||p|rGtd|jDs)|||||||_dS)Norder_by partition_byc3>K|]}|VdSrYr`rJ expr_nodes r)rz9ExprNode._push_down_over_node_in_place.."s?,,-6 &&((,,,,,,r+c3>K|]}|VdSrYrkrs r)rz9ExprNode._push_down_over_node_in_place..&s?44/8 ((**444444r+)rr0r*rany_nodes_with_over_nodeall)r_rrr0over_node_order_byover_node_partition_byrEs r)_push_down_over_node_in_placez&ExprNode._push_down_over_node_in_places646'-j9!*!1.!AJ # #D4== # T""""# #,,:>+,,,)) # T11)<<====' #44<@K44411 # T112LMMNNNN T"""" r+c|jA|jjrd|_n-td|jDrd|_nd|_|jS)NTc3pK|]1}t|td|jDV2dS)c3>K|]}|VdSrYrrJnodes r)rz2ExprNode.is_orderable...6s.@@DD%%''@@@@@@r+Nr*rrrJrEs r)rz(ExprNode.is_orderable..5s[4==@@DK@@@@@r+F)rrr`rr0r^s r)r`zExprNode.is_orderable/ss  $ ,y% 2,0)) J 2 -1)),1)((r+c|jA|jjsd|_n-td|jDrd|_nd|_|jS)NFc3pK|]1}t|td|jDV2dS)c3@K|]}| VdSrYrrs r)rz4ExprNode.is_elementwise...Fs1FF$++---FFFFFFr+Nrrs r)rz*ExprNode.is_elementwise..Es[4==FF$+FFFFFr+T)rrrkrr0r^s r)rkzExprNode.is_elementwise?ss  & .9+ 3.3++ J 3 /4++.2+**r+N)rrVrrr0rrrWrrWrrr#rr#r)r#r)rrr#r)rrrrr#rrq) rrrsrtrurrrrrr`rkr;r+r)rrs  $8: #(888888, 4 4 4 4         0)))) ++++++r+rceZdZdZdZddddddddd>dZd?dZd@dZdAd!Ze dBd%Z dCd(Z e dBd)Z e dDd*Z e dDd+Ze dDd,Ze dDd-Ze dDd.Ze dDd/Ze dBd0ZedEd1ZdFd3ZdFd4ZdCd5ZdFd6ZdFd7ZdFd8ZdFd9ZdFd:ZdBd;ZdFd<ZdAd=Z dS)G ExprMetadataaIExpression metadata. Parameters: expansion_kind: What kind of expansion the expression performs. has_windows: Whether it already contains window functions. is_elementwise: Whether it can operate row-by-row without context of the other rows around it. is_literal: Whether it is just a literal wrapped in an expression. is_scalar_like: Whether it is a literal or an aggregation. n_orderable_ops: The number of order-dependent operations. In the lazy case, this number must be `0` by the time the expression is evaluated. preserves_length: Whether the expression preserves the input length. current_node: The current ExprNode in the linked list. prev: Reference to the previous ExprMetadata in the linked list (None for root). ) current_noderO has_windowsrk is_literalrpn_orderable_opsrmprevFrTN)rrrmrkrprrrOr{rrWrintrmrkrprrrrExprMetadata | Noner#rc|r|sJ||_||_||_||_||_||_||_||_| |_dSrY) rOrrrkrmrprrr) r_rOrrrmrkrprrrs r)rzExprMetadata.__init__nsb  "! ! ! !-;!,$3$2&6$2 *&2)- r+argsrkwdsrc4d|j}t|)NzCannot subclass )rr TypeError)clsrrrs r)__init_subclass__zExprMetadata.__init_subclass__s111nnr+rcttt|}d|jd|jd|jd|jd|jd|jd|j d|d S) Nz ExprMetadata( expansion_kind: z, has_windows: z, n_orderable_ops: z, is_elementwise: z, preserves_length: z, is_scalar_like: z, is_literal: z , nodes: z, )) tuplereversediter_nodes_reversedrOrrrkrmrpr)r_nodess r)rzExprMetadata.__repr__shuT%=%=%?%?@@AABB !%!4  ".  #'"6  "&!4   $(#8   "&!4  "_      r+Iterator[ExprNode]c#:K|}||jV|j}|dSdS)z/Iterate through all nodes from current to root.Nrr)r_currents r)rz ExprMetadata.iter_nodes_reverseds;'+!& & & &lG!!!!!r+rcompliant_exprsrc2t|j|g|RSrY)KIND_TO_METADATA_CONSTRUCTORrrrrs r) from_nodezExprMetadata.from_nodes!,DI6tNoNNNNr+compliant_exprcompliant_expr_argsc6t|j|||g|RSrY)KIND_TO_METADATA_UPDATERrr_rrrs r) with_nodezExprMetadata.with_nodes1 ( 2 $ )<    r+ct|d|ddSNTto_single_outputrrcombine_metadatars r)from_aggregationzExprMetadata.from_aggregation$ t$T    r+c :|tjdddd|dS)NTF)rkrmrrprrr{rrrs r) from_literalzExprMetadata.from_literals3s  "    r+c2|tj|dSNrrrs r) from_serieszExprMetadata.from_seriesss='dFFFFr+ct|jddkr|tj|dn||S)Nr?r8rlenrr{rfrom_selector_multi_namedrs r)from_colzExprMetadata.from_colsP 4;w'((A-- C $4d C C C C..t44 r+ct|jddkr|tj|dn||S)Nindicesr8rrrs r)from_nthzExprMetadata.from_nthsP4;y)**a// C $4d C C C C..t44 r+c2|tj|dSr)r{rrs r)rz&ExprMetadata.from_selector_multi_namedss=,4dKKKKr+c2|tj|dSrr}rs r)from_selector_multi_unnamedz(ExprMetadata.from_selector_multi_unnamedss=.TMMMMr+ct|d|ddSrrrs r)from_elementwisezExprMetadata.from_elementwiserr+c"|j o|j SrY)rmrpr^s r) is_filtrationzExprMetadata.is_filtrations((D1D-DDr+_cec |jrd}t|t|j|j|jdddd|| S)N4Can't apply aggregations to scalar-like expressions.FTrrrmrkrprrrrprrrOrrr_rrrs r)with_aggregationzExprMetadata.with_aggregations[   -HC',, ,  ( 0"     r+c |jrd}t|t|j|j|jdzdddd|| S)Nrr8FTrrrs r)with_orderable_aggregationz'ExprMetadata.with_orderable_aggregationsb   -HC',, ,  ( 014"     r+c0t|g|Rd||jdS)NFr)rrNrs r)with_elementwisezExprMetadata.with_elementwises>     #)     r+c |jrd}t|t|j|j|j|jddd|| S)Nz;Can't apply window (e.g. `rank`) to scalar-like expression.FrrprrrOrrrmrs r) with_windowzExprMetadata.with_window!s`   -OC',, ,  (!0!2      r+c |jrd}t|t|j|j|jdz|jddd|| S)NzNCan't apply orderable window (e.g. `diff`, `shift`) to scalar-like expression.r8Frrrs r)with_orderable_windowz"ExprMetadata.with_orderable_window4se   -bC',, ,  ( 014!2      r+c |jrd}t||js|jrd}t||j}|sCt |jtj urd}t|t |jj r |dkr|dz}t|j d|dddd|| S) NCannot nest `over` statements.oCannot use `over` on expressions which are elementwise (e.g. `abs`) or which change length (e.g. `drop_nulls`).aPCannot use `order_by` in `over` on expression which isn't orderable. If your expression is orderable, then make sure that `over(order_by=...)` comes immediately after the order-dependent expression. Hint: instead of - `(nw.col('price').diff() + 1).over(order_by='date')` write: + `nw.col('price').diff().over(order_by='date') + 1` rr8TFr) rrrkrrnextop_nodes_reversedrrVr[r`rrO)r_rrrrs r)with_ordered_overzExprMetadata.with_ordered_overGs    -2C',, ,   -$"4 -K (,, ,. -T++--..38?JJK (,, , &&(( ) ) . ; !RS@S@S q O  +!      r+c |jrd}t||js|jrd}t|t |jd|jdddd|| S)Nr"r#TFr)rrrkrrrOrrs r)with_partitioned_overz"ExprMetadata.with_partitioned_overns   -2C',, ,   -$"4 -K (,, ,   0!      r+c|jdr|||S|jdsd}t||||S)Nrrz?At least one of `partition_by` or `order_by` must be specified.)rr&rr(rs r) with_overzExprMetadata.with_overs_ ;z " 5))$44 4{>* -SC',, ,))$444r+c |jrd}t|td|D}td|D}t |j||dddd|| S)NECan't apply filtration (e.g. `drop_nulls`) to scalar-like expression.c3.K|]}|jjVdSrY)rNrrs r)rz/ExprMetadata.with_filtration..s' R RQ!8 R R R R R Rr+c3.K|]}|jjVdSrY)rNrrs r)rz/ExprMetadata.with_filtration..s'$Z$ZQQ[%@$Z$Z$Z$Z$Z$Zr+Fr)rprrsumrrO)r_rrrresult_has_windowsresult_n_orderable_opss r)with_filtrationzExprMetadata.with_filtrations   -YC',, , R R/ R R RRR!$$Z$Z/$Z$Z$Z!Z!Z  *2"      r+c |jrd}t|t|j|j|jdzdddd|| S)Nr,r8Frrrs r)with_orderable_filtrationz&ExprMetadata.with_orderable_filtrationsb   -YC',, ,  ( 014"      r+c#vK|D]!}|jdr|V"dS)N)zname.rL)rr startswith)r_rs r)r%zExprMetadata.op_nodes_reversedsR,,..  Dy##$677 JJJJ   r+)rOr{rrWrrrmrWrkrWrprWrrWrrrrr#r)rrrrr#rr)r#r)rrrrr#r)rrrrrrr#r)rrr#rrq)rrrrr#r)!rrrsrtru __slots__rrrr classmethodrrrrrrr rr rrxrrrrrr r&r(r*r2r4r%r;r+r)rrPs" I " !%#$ $(......2     ####OOO[O        [     [  GGG[G   [    [ LLL[LNNN[N   [ EEEXE        &         &    &% % % % N    05555    (    $r+rz2dict[ExprKind, Callable[[ExprNode], ExprMetadata]]rz+dict[ExprKind, Callable[..., ExprMetadata]]rrrrrrc d}d}tj}d}d}|jj} d} t |D]\} } | j} | J| jr| j}|s | dkr||zn|}|| jz}|| j z }| | jz} | | j z} |t| j z }|t| j z }|jj p|t|k}|jjo|dko| }|r-|dks||zt|krd}t!|t#||||| || || S)aICombine metadata from `args`. Arguments: compliant_exprs: Expression arguments. to_single_output: Whether the result is always single-output, regardless of the inputs (e.g. `nw.sum_horizontal`). current_node: The current node being added. prev: ExprMetadata of previous node. rFTNr8zXLength-changing expressions can only be used in isolation, or followed by an aggregationr)r{rrrk enumeraterNrOrrrrrrrprrmrr)rrrr n_filtrations n_scalar_likeresult_expansion_kindr0r1result_is_elementwiseresult_is_literalicemetadatarOresult_is_scalar_likeresult_preserves_lengthrs r)rrsMM)0(-<?++662<###  " 2 2 4 4 %4N# >?!ee)N::& h22("::!88X00X3444 X4555 )-<_--- * & Q  &% % )    =O@T@T T Th#C((( &.0,,$!     r+r function_namerrcbtd|Dsd|d}t|dS)Nc3.K|]}|jjVdSrY)rNrmrs r)rz4check_expressions_preserve_length..&s'::q{+::::::r+zBExpressions which aggregate or change length cannot be passed to 'z'.)rr)rErrs r)!check_expressions_preserve_lengthrHsL ::T::: : :)dS`ddd#C((())r+FNT)rbackend allow_literalarg&IntoExpr | NonNestedLiteral | _1DArrayrrIrJrc|ddlm}m}m}t |t r |s ||St |r |d||St|r|St|r|S|s!tj t|||S)Nr)rlit new_series)rI) narwhals.functionsrrNrOr(rr _to_exprr/r*r from_invalid_typetype)rKrrIrJrrNrOs r)_parse_into_exprrU+s8777777777#sJs3xx?z"c7333<<>>>~~||~~s|| @"4T#YY??? 3s88Or+nsrrIterator[CompliantExprAny]c'K|D]a}t|||j|}|s/|jjrd}t ||VbdS)N)rrIz9Multi-output expressions are not allowed in this context.)rU_implementation_to_compliant_exprrNrOrr)rVrrr0rEretrs r)evaluate_into_exprsr\As  Z1C    R  " 2cm&B&R&R&T&T 2MC,S11 1 r+list[CompliantExprAny]ctd|D}g}|D]^}|rEt|r6|}|j|_||I||_|S)Nc36K|]}t| VdSrY)rp)rJrAs r)rz&maybe_broadcast_ces..Rs-EErr***EEEEEEr+)rrp broadcastrN _opt_metadatar)rr`resultsr_compliant_exprs r)maybe_broadcast_cesrdQsEE_EEEEEI&(G)++  +77 +0>0H0H0J0JO,:,DO ) NN? + + + + NN> * * * * Nr+rc |jdvr&t||j|jd}g}nd|jvr<|jd\}}tt|||}nt||j}t t |j||j|jd}td||i|j}tj |g|R}||_ |S)N>rrFr?.rVrrr) rgetattrrsplitrdr\r0rrr rrra)rrVrAcesmodulemethodfuncmds r)evaluate_root_nodero_s y&&&$WR # #T[%9 : $)  !Y__S11NFF72v..77DD2ty))D! ?#'#:  $ddC&?4;&?&? @ @   +s + + +BB Ir+rc ~|j}t|gt|j||j|jdR^}}|j||g|R}d|jvr<|jd\}}tt|||}nt||j}td||i|j }||_ |S)Nrgrfr) rNrdr\r0rrrrrirhr rra) rrrVrnraccessorrlrmr[s r) evaluate_noderrys&/B+>,  Z#6    ,,,(N( dN A-@ A A AB di9??3//&w~x88&AA~ty11 !44)<#L #L#L M MCC Jr+rSequence[ExprNode]cnt|d|}|ddD]}t|||}|Sr7)rorr)rrVrArs r)evaluate_nodesrusF E!Hb ) )Babb )) 2tR ( ( Ir+)r"rr#r$)r"rr#r,)r0r1r#r2)r0rr#r=)rErr4rrFr5r#rG)r"rr#rW) rrrrWrrrrr#r)rrrErr#r) rKrLrrWrIrrJrWr#r) r0rLrVrrrWrrWr#rW)rrr#r])rrrVrr#r)rrrrrVrr#r)rrsrVrr#r)] __future__renumrrtypingrrrr r narwhals._utilsr narwhals.dependenciesr narwhals.exceptionsr rrcollections.abcrrtyping_extensionsrrnarwhals._compliantrrnarwhals._compliant.typingrrrrrr'rr.rnarwhals.typingrr r!r*r/r<rDrTrVrpr{rrrorrbr rdrrerirrcrrfrrgr rhr__annotations__rrrvr2r\rr]r4rwr*rZr r[rrrrHrUr\rdrorrrur;r+r)rs #"""""">>>>>>>>>>>>>>&&&&&&333333 E22222222////////BBBBBBBB#"""""&&&&&&DDDDDDDDDD!!!!####!!!!    !!!!(X X X X X tX X X v(((("""""D"""6v+v+v+v+v+v+v+v+riiiiiiiiZ  ,7 L,: ,7 l> O\- L,' l/ L,' |? T     ,7 ,7 5 "L$K !<#I M<) |A O\- I    HHHHV ) ) ) ) ,        40r+