<>iYF SSKrSSKrSSKJr SSKJr SSKJrJ r J r J r J r J r JrJr SSKJr SSKJr \R*R,r\R0S5rSrSrSrS rS r\R*R?S \R@"S /S Q05\RB"S /S Q05/5S5r"Sr#Sr$Sr%Sr&Sr'Sr(Sr)\R*R$S5r*g!\a Nf=f!\a SrNf=f)N)field) DeclarationTableSourceNodeOptionsFilterNodeOptionsProjectNodeOptionsAggregateNodeOptionsOrderByNodeOptionsHashJoinNodeOptionsAsofJoinNodeOptions)ScanNodeOptionscj[R"/SQ/SQS.5n[U5n[SUS9nU$)Nab table_sourceoptions)patablerr)r table_optsrs W/var/www/html/land-tabula/venv/lib/python3.13/site-packages/pyarrow/tests/test_acero.pyrr/s1 HH995 6E'.J~zBL c[R"/SQ/SQS.5n[U5n[[ S5S:5n[ R "[ SUS9[ SUS9/5nUR5nURURSS 55(de[ SUS9n[ SX%/S 9nUR5nURURSS 55(deg) Nrrrrrrrfilterrrinputs) rrrrrr from_sequenceto_tableequalsslice)rr filter_optsdeclresultrfiltereds rtest_declarationr-7s HH995 6E'.J#E#JN3K  $ $NJ7Hk2& D]]_F ==Q* + ++ +~zBL8[PH    F ==Q* + ++ +r cHS[U5;deS[U5;deg)NTableSourceNode)strrepr)rs rtest_declaration_reprr2Ls( L 1 11 1 \ 2 22 2r cUR5nUR[R"S[R"54S[R"54/5:XdeUR 5nSSS5 [R "/SQ/SQS.5nWR U5(deg!,(df  ND=f)Nrrrrr) to_readerschemarint64read_allrr')rreaderr+expecteds rtest_declaration_to_readerr:Rs    !V}} C+O*P QQQQ" "xxii89H == " "" " " !s A#B22 Cc [R"[5 [[R "[R "/SQ5/S/55 SSS5 [S5n[SU5n[R"[SS9 UR5nSSS5 g!,(df  NX=f!,(df  g=f)Nrrrz0TableSourceNode requires table which is not nullmatch) pytestraises TypeErrorrr record_batcharrayr ValueErrorr&rr*_s rtest_table_sourcerFZs y !r0C/DseLM "*$/L ~| 4D L  MMO   " !   s9B& B7& B47 Cc [R"U[S[[S5S:5S9/5n[R "[ SS9 UR5nSSS5 [R "[5 [[R"/SQ55 SSS5 [R "[5 [S5 SSS5 g!,(df  N=f!,(df  NN=f!,(df  g=f)Nr"crrzNo match for FieldRef.Name\(c\)r<)TFT) rr%rrr>r?rCr&r@rrBrDs r test_filterrIfs  $ $H&7c Q&GH& D z)K L MMO M y !"((#678 " y !$ " ! M L " ! ! !s$C"C, C= C), C:= D sourcenumberrcUR[R"S5S:5nURS:Xde[ U5[ U5LdeUR R UR 5(deUR[R"/SQ55nURS:Xde[ U5[ U5LdeUR R UR 5(deg)NrKr)FFF) r"pcrnum_rowstyper5r'rrB)rJ result_expr result_masks rtest_filter_all_rowsrRvs -- 2Q 67K   1 $$ $  V ,, ,    $ $V]] 3 33 3--)> ?@K   1 $$ $  V ,, ,    $ $V]] 3 33 3r c *[R"U[S[[R"[ S5S5/55/5nUR 5nURRS/:XdeUSR5/SQ:Xde[R"U[S[[R"[ S5S5/S/55/5nUR 5nURRS/:XdeUSR5/SQ:Xde[R"[5 [[R"[ S5S5/SS/5 SSS5 [R"U[S[[R"[ S55/55/5n[R"[S S 9 UR 5nSSS5 g!,(df  N=f!,(df  g=f) Nprojectrrzmultiply(a, 2)r)rrra2b2z$cannot Execute non-scalar expressionr<)rr%rrMmultiplyrr&r5names to_pylistr>r?rCsum)rr*r+rEs r test_projectr[s  $ $I12;;uSz13M2NOP& D]]_F ==  #3"4 44 4 !9   I -- -  $ $I12;;uSz13M2NQUPVWX& D]]_F ==  4& (( ( $< ! ! #y 00 0 z "BKKc A67$F #  $ $I1266%*3E2FGH& D z)O P MMO Q P # " Q Ps.G3H3 H Hc x[R"U[S[S/55/5nUR5nURR S/:XdeUSR 5S/:Xde[R"S/SQ05n[SS[R"SS 9S4/5n[R"[S [U55[SU5/5nUR5nURR S/:XdeUSR 5S/:XdeS[S5S [S 5S/[S5/S /4H|n[USSS4/5n[R"U[SU5/5nUR5nURR S/:XdeUSR 5S/:XaM|e [SS /SSS4/5n[R"U[SU5/5n[R"[S S9 UR5nSSS5 [S/5n[R"U[SU5/5n[R"[SS9 UR5nSSS5 g!,(df  No=f!,(df  g=f)N aggregaterrZNa_sumr_rrrrNrZF) skip_nullsrrrz/Function 'sum' accepts 1 arguments but 2 passedr<)rhash_sumNr_zis a hash aggregate function)rr%rr&r5rXrYrrrMScalarAggregateOptionsrrr>r?rC)rr*r+r aggr_optstargetrEs rtest_aggregate_scalarrfs  $ $K!57R6S!TU& D]]_F ==  7) ++ + '? $ $ &1# -- - HHc<( )E$ ub//5A7 KLI  $ $N$:5$ABK+& D]]_F ==  7) ++ + '? $ $ &4& 00 0c AuQx#s qcJ(65$*H)IJ (( ;{I> ? }}""wi///g((*qc111K%Sz5$&H%IJI  $ $ {; :; D K  MMO  %&F%GHI  $ $ {; :; D z)G H MMO I H   I Hs JJ+ J(+ J9c[R"/SQ/SQS.5n[U5n[SUS9n[ S/S/S9n[R "U[S U5/5nUR 5n[R"S S /S S /S .5nURU5(de[ SS[R"S5S4/S/S9n[R "U[S U5/5nUR 5n[R"S S /SS /S .5nURU5(de[ S/[S5/S9n[R "U[S U5/5nUR 5nURU5(de[ S/S/S9n[R "U[S U5/5n[R"[5 UR 5nSSS5 g!,(df  g=f)Nr`)foobarrhrrr)r hash_countNcount(a)r)keysr]rhrir)rrkrrjallrkrr^)rrrrrr%r&r'rM CountOptionsrr>r?rC) rrrrdr*r+r9 expected_allrEs rtest_aggregate_hashrps HH<.CD EE'.J~zBL% ./se=I  $ $k+y9& D]]_Fxxuen1a&ABH == " "" "% |R__U3Z @AI  $ $k+y9& D]]_F885%.q!fEFL == & && &% ./uSzlI  $ $k+y9& D]]_F == " "" "%&A%B#OI  $ $k+y9& D z " MMO # " "s G22 Hc[R"/SQ/SQS.5n[S[U55n[ S/5n[R "U[SU5/5nUR 5n[R"/SQ/SQS.5nURU5(de[ [S 5S 4/5n[R "U[SU5/5nUR 5n[R"/S Q/S QS.5nURU5(de[ S /SS9n[R "U[SU5/5nUR 5n[R"/SQ/SQS.5nURU5(de[ /5n[R "U[SU5/5n[R"[SS9 UR 5nSSS5 [R"[SS9 [ S/5nSSS5 [R"[SS9 [ S/SS9nSSS5 g!,(df  Nj=f!,(df  NM=f!,(df  g=f)N)rrrr)rrNrrr)r ascendingorder_by)rrrr)rrrNr descending)rrrr)rrrN)rrtat_start)null_placement)rrrr)Nrrrz1`ordering` must be an explicit non-empty orderingr<z&"decreasing" is not a valid sort order)r decreasingz%"start" is not a valid null placementstart) rrrrr r%r&r'rr>r?rC)rrord_optsr*r+r9rEs r test_order_byrz s HH ?E~/Ee/LML!#5"67H  $ $lK H4U%V WD ]]_FxxlABH == " "" "!E#J #=">?H  $ $lK H4U%V WD ]]_FxxlABH == " "" "!#4"5jQH  $ $lK H4U%V WD ]]_FxxlABH == " "" """%H  $ $lK H4U%V WD M  MMO  z)S T  34 5 U z)R S  23G L T S   U T T Ss$I I"< I3 I" I03 Jc [R"/SQ/SQS.5n[S[U5S9n[R"/SQ/SQS.5n[S[U5S9n[ SS S S 9n[S XAU/S 9nUR 5n[R"S S/SS/S S/SS///SQS9nUR U5(de[S 5S /[S 5/4HAn[ SXS 9n[S XAU/S 9nUR 5nUR U5(aMAe [ SS S S 9n[S XAU/S 9nUR 5n[R"/SQ/SQ/SQ/SQ//SQS9nURS5R U5(de[ SS S SSS9n[S XAU/S 9nUR 5n[R"/SQ/SQ/SQ/SQ//SQS9nURS5R U5(de[ SS S S S/[S5/S9n[S XAU/S 9nUR 5n[R"/SQ/SQ/SQ//SQS9nURS5R U5(deg)Nrrkeyrrrrrrr}rinnerr}) left_keys right_keyshashjoinr#rrrrrr}rr}rrX left outer)Nrr)Nrrr_left_right)rroutput_suffix_for_leftoutput_suffix_for_right)key_leftr key_rightrr)rr left_output right_output)r}rr) rrrrr r&r'rsort_by) left left_sourceright right_source join_optsjoinedr+r9rls rtest_hash_joinr/s 88II6 7Dn6LT6RSK HHYY7 8E~7Me7TUL$GuOI IL.IKF __ Fxx Q!Q!Q!Q(&(H == " "" "uwu7'4Q   2MO"}}X&&&& 8$%9I IL.IKF __ Fxx I|\:&H >>#  % %h / // /$%&JIIL.IKF __ Fxx I|\:1H >>#  % %h / // /$%CLc |=IIL.IKF __ Fxx I|,H >>#  % %h / // /r c H[R"/SQ/SQS.5n[S[U5S9n[R"/SQ/SQS.5n[S[U5S9n[ SS S [ R "[ R"S 5S 5S 9n[S XAU/S9nUR5n[R"S/S /S/S///SQS9nURU5(de[ SS S [ R "[ R"S 5S 5[ R "[ R"S5S5-S 9n[S XAU/S9nUR5n[R"/SQ/SQ/SQ/SQ//SQS9nURU5(de[ R"S5n[ SS S US 9n[S XAU/S9nUR5n[R"SS/S S/SS/SS ///SQS9nURU5(de[ R"S5n [ SS S U S 9n[S XAU/S9nUR5n[R"[R"/[R"5S9[R"/[R"5S9[R"/[R"5S9[R"/[R"5S9//SQS9nURU5(deg)Nrrr|rrr~rrr}rr)rrfilter_expressionrr#rrrrrr )rrr)rrr)rNN)rNNTrrF)rO) rrrrr rMequalrr&r'scalarrBr6) rrrrrrr+r9 always_true always_falses r#test_hash_join_with_residual_filterrms 88II6 7Dn6LT6RSK HHYY7 8E~7Me7TUL#5U((288C=!46IIL.IKF __ Fxx qcA3&(H == " "" "$%((288C=!4rxx r7RRIIL.IKF __ Fxx I@&(H == " "" "))D/K#5U%'IIL.IKF __ Fxx Q!Q!Q!Q(&H == " "" "99U#L#5U&(IIL.IKF __ Fxx HHRbhhj ) HHRbhhj ) HHRbhhj ) HHRbhhj )  'H == " "" "r c >[R"/SQ/SQ/SQS.5n[S[U5S9n[R"/SQ/SQ/SQS .5n[S[U5S9n[ S S /S S /S S 9n[SXAU/S9nUR 5n[R"/SQ/SQ/SQ/SQ//SQS9nXg:Xde[ S 5S /[ S 5/4HEn[ S 5S 4H1n [ XXS S 9n[SXAU/S9nUR 5nXg:XaM1e MG g)Nr)rrrr)r}tsrrrr~)rrr)r}rrrr}r)left_onleft_byright_onright_by toleranceasofjoinr#)NrN)r}rrrr)rrrrr r&r) rrrrrrr+r9byons rtest_asof_joinrs. 88IYYG HDn6LT6RSK HHYiiH IE~7Me7TUL$ugI IL.IF__ Fxx Iy/:%'H   U|eWuU|n5;%B+I !IL6QSF__&F% %%&6r c [R"/SQ/SQS.5n[R"XS- SS9 [R"US- SS9n[ S[ U55nUR5nURR/SQ:XdeURS S /5RU5(de[ U[S 5S :S 9n[ SU5nUR5RS :Xde[ U[S 5S:S 9n[ SU5nUR5RS:Xde[ US[R"[S 5S50S9n[ SU5nUR5nUS R!5/SQ:Xde[R""US R%55R'5(deg)Nrrrdatasetparquet)formatscan)rr__fragment_index __batch_index__last_in_fragment __filenamerrr)r"rrrrUr)columns)rrds write_datasetrrr r&r5rXselectr'rrNrMrWrYrmis_nullas_py)tempdirrrr*r+ scan_optss r test_scanrs HH995 6EUi/ Bjj9,Y?G vw7 8D ]]_F ==  #   ==#s $ + +E 2 22 2 c Q?I vy )D ==? # #q (( (c Q?I vy )D ==? # #q (( ( $ E#JPQ8R1STI vy )D ]]_F #; "i // / 66&+%%' ( . . 0 00 0r )+r>pyarrowrpyarrow.computecomputerMr pyarrow.acerorrrrrr r r ImportErrorpyarrow.datasetrrr markacero pytestmarkfixturerr-r2r:rFrI parametrizerArrRr[rfrprzrrrrr rrs3$!      -[[   ,*3 #   OOXy)*HHh "#$ 4  4@0f+\"MJ;0|=#@&D 1 1[    Bs"C, C8,C54C58DD