ch!?,SSKJrJrJr SSKJrJr SSKJrJ r J r J r J r J r JrJrJr SSKJr SSKJr SS jrSSS S \S4S jrS \4SjrSr\4SjrSSjrg!\ar\"S\"\5S35SeSrCff=f!\a "SS 5r\rN[f=f))Table RecordBatcharray) Expressionfield) DeclarationExecNodeOptionsTableSourceNodeOptionsFilterNodeOptionsProjectNodeOptionsAggregateNodeOptionsOrderByNodeOptionsHashJoinNodeOptionsAsofJoinNodeOptionsz@The pyarrow installation is not built with support for 'acero' ()N)ScanNodeOptionsc<\rSrSr"SS5r"SS5rSrg)DatasetModuleStub2c\rSrSrSrg)DatasetModuleStub.Dataset3N__name__ __module__ __qualname____firstlineno____static_attributes__r`C:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\pyarrow/acero.pyDatasetr3 r r"c\rSrSrSrg)!DatasetModuleStub.InMemoryDataset6rNrrr r!InMemoryDatasetr%6r#r r'rN)rrrrr"r'rrr r!rr2s    r rTFc ~[S[XUS95nURRVs/sHn[ U5PM nn[R "U[S[ U55/5nURRS5nUb+[R "U[S[U55/5nU$s snf)Nscan use_threadsimplicit_orderingprojectfilter) rrschemanamesr from_sequencer _scan_optionsgetr )datasetr+r,declf projections filter_exprs r!_dataset_to_declr9;s v+ - .D &-^^%9%9:%958%9K:  $ $ {9&8&EFG D''++H5K(( ;x):;)GH I  K;sB:c [U[[R45(d[ S[ U535e[U[[R45(d[ S[ U535e0n [U[ [45(dU/n[U5H upXU 'M 0n[U[[ 45(dU/n[U5H upXU 'M URRnURRnUS:XdUS:Xa/nOVUS:XdUS:Xa/nOGUS:XdUS:XaUVs/sH nUU;dM UPM nnO US:XaUVs/sH nUU ;dM UPM nn0n[U5Hun nUU;dMU UU'M 0n[U5Hun nUU;dMU UU'M [U[R5(a [XS 9nO[S [U55n[U[R5(a [X7S 9nO[S [U55nU(a![XXOUU=(d S U=(d S U S 9nO[XUU=(d S U=(d S U S 9n[S UUU/S9nU(GamUS:XGaf[U5n[U5n[!U5n/n/n[UU-5GHun nU [!U5:avUU;apUR#U5 UXKUnUR#[$R&"S[$R("U 5[$R("UU-5/55 MU U:aUU;aMU(aU U:a UU;aUU- nU(aU U:a UU;aUU- nUR#U5 UR#[$R("U 55 GM [S[+UU55n[R,"UU/5nUR/US 9n U [:XaU $U [R0:Xa[R0"U 5$[ S5es snfs snf)aE Perform join of two tables or datasets. The result will be an output table with the result of the join operation Parameters ---------- join_type : str One of supported join types. left_operand : Table or Dataset The left operand for the join operation. left_keys : str or list[str] The left key (or keys) on which the join operation should be performed. right_operand : Table or Dataset The right operand for the join operation. right_keys : str or list[str] The right key (or keys) on which the join operation should be performed. left_suffix : str, default None Which suffix to add to left column names. This prevents confusion when the columns in left and right operands have colliding names. right_suffix : str, default None Which suffix to add to the right column names. This prevents confusion when the columns in left and right operands have colliding names. use_threads : bool, default True Whether to use multithreading or not. coalesce_keys : bool, default False If the duplicated keys should be omitted from one of the sides in the join result. output_type: Table or InMemoryDataset The output type for the exec plan result. filter_expression : pyarrow.compute.Expression Residual filter which is applied to matching row. Returns ------- result_table : Table or InMemoryDataset Expected Table or Dataset, got z left semiz left antiz right semiz right antiinnerz left outerz right outerr+ table_source)output_suffix_for_leftoutput_suffix_for_rightfilter_expressionhashjoinoptionsinputsz full outercoalescer-Unsupported output type) isinstancerdsr" TypeErrortypetuplelist enumerater/r0r9rr rsetlenappendr_call_fieldr r1to_tabler')! join_type left_operand left_keys right_operand right_keys left_suffix right_suffixr+ coalesce_keys output_typerBleft_keys_orderidxkeyright_keys_order left_columns right_columnscolleft_column_keys_indicescolnameright_column_keys_indices left_source right_source join_optsr5left_columns_setright_columns_setright_operand_indexprojected_col_namesr7right_key_index projection result_tables! r! _perform_joinrsRs}T lUBJJ$7 8 89$|:L9MNOO meRZZ%8 9 99$}:M9NOPPO i% / /K i(") j4- 0 0 \ j) #* &&,,L!((..MK9 #; l "i<&? g l!:( (CC7G,GC=   m #' 'C3o+EC<  "!,/ W i 03 $W -0!#!-0 W j 14 %g .1 , ++&|M !.2H2VW -,,' O " 2=A ' *M#.#4"$0$6B/  ( *#.#4"$0$6B/  I{L.I Dl2|, .!,/  !,">?HCS&&32J+J#**3/ #<s34#6""$$Z"))#. 0A0A/?1A2 ++7P0P  C*=$=00;&C S,?%?//<'C#**3/""%%c*E@J! )+7JK (($ );<==[=9Le ** *!!,//122Y  s QQ$ Q2Qc ([U[[R45(d[ S[ U535e[U[[R45(d[ S[ U535e[U[ [45(dU/n[U[ [45(dU/nURRV s/sHn X/U-;dMU PM n n [URR5[U 5-n U (a[SU S35e[U[R5(a [UUSS9n O[S[U55n [U[R5(a [X7SS9n O[S[U55n [XXEU5n[SXU /S9nUR!US 9nU[:XaU$U[R":Xa[R""U5$[ S 5es sn f) a Perform asof join of two tables or datasets. The result will be an output table with the result of the join operation Parameters ---------- left_operand : Table or Dataset The left operand for the join operation. left_on : str The left key (or keys) on which the join operation should be performed. left_by: str or list[str] The left key (or keys) on which the join operation should be performed. right_operand : Table or Dataset The right operand for the join operation. right_on : str or list[str] The right key (or keys) on which the join operation should be performed. right_by: str or list[str] The right key (or keys) on which the join operation should be performed. tolerance : int The tolerance to use for the asof join. The tolerance is interpreted in the same units as the "on" key. output_type: Table or InMemoryDataset The output type for the exec plan result. Returns ------- result_table : Table or InMemoryDataset r;zColumns zE present in both tables. AsofJoin does not support column collisions.Tr*r>asofjoinrDr=rH)rIrrJr"rKrLrMrNr/r0rP ValueErrorr9rr rrUr')rWleft_onleft_byrYright_onright_by tolerancer+r^rerdcolumns_collisionsrirjrkr5rrs r!_perform_join_asofr}sB lUBJJ$7 8 89$|:L9MNOO meRZZ%8 9 99$}:M9NOPP gt} - -) h . .:%++111 j8+ + 1\00667#m:LL)*+; ;  , ++& #"$ " 2<@ -,,' "$ # 2=A $(iI IL.I D==[=9Le ** *!!,//122Ys HHc Sn[U[5(a[R"U/5nSn[R "[ S[ U5S9[ S[U5S9/5nURSS9nU(aURS:a#UR5R5SnU$URVs/sHn[/URS9PM nn[R"XdRS 9nU$s snf) a\Filter rows of a table based on the provided expression. The result will be an output table with only the rows matching the provided expression. Parameters ---------- table : Table or RecordBatch Table that should be filtered. expression : Expression The expression on which rows should be filtered. Returns ------- Table or RecordBatch FTr>)rEr.r=r)rL)r/)rIrr from_batchesrr1r r rUnum_rowscombine_chunks to_batchesr/rrL from_arrays)table expressionis_batchr5resultrarrayss r! _filter_tablerbs"H%%%""E7+  $ $N,B5,IJH&7 &CD& D]]t] ,F ??Q **,779!order_byrH) rIrJr"r9rr rr1rUrr'rK)table_or_dataset sort_keysr^kwargs data_sourcerr5rrs r! _sort_sourcers"BJJ//&'7TJ ! 23CD :'9)'Nv'NOH  $ $k%< =D==T=2Le ** *!!,//122r c [R"[S[U55[S[XS95/5nUR US9$)Nr> aggregate)keysr=)rr1r r rU)r aggregatesrr+r5s r! _group_byrsJ  $ $N$:5$ABK!5j!LM& D ==[= 11r )TF)T) pyarrow.librrrpyarrow.computerrpyarrow._acerorr r r r r rrr ImportErrorexcstrpyarrow.datasetr4rJpyarrow._datasetrrr9rsr}rrrrr r!rs221-   "  02#"%#t r3n/3#(X3v!H;@3,2i   J3s8*TUV   Bs(A A>A;#A66A;>BB