Lg;&SSKJrJr SSKJrJr SSKJrJrJ r J r J r J r J r JrJr SSKJr SSKJr SS jrSSS S \4S jrS \4SjrSr\4SjrSSjrg!\ar\"S\"\5S35SeSrCff=f!\a "SS 5r\rNZf=f))Table RecordBatch) 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-lib/python3.12/site-packages/pyarrow/acero.pyDatasetr3 rr!c\rSrSrSrg)!DatasetModuleStub.InMemoryDataset6rNrrrr InMemoryDatasetr$6r"rr&rN)rrrrr!r&rrrr rr2s    rrTFc ~[S[XUS95nURRVs/sHn[ U5PM nn[R "U[S[ U55/5nURRS5nUb+[R "U[S[U55/5nU$s snf)Nscan use_threadsrequire_sequenced_outputprojectfilter) rrschemanamesr from_sequencer _scan_optionsgetr )datasetr*r+declf projections filter_exprs r _dataset_to_declr8;s v!9 ; ?HCS&&32J+J#**3/ #<s34#6""$$Z"))#. 0A0A/?1A2 ++7P0P  C*=$=00;&C S,?%?//<'C#**3/""%%c*E@J! )+7JK (($ );<==[=9Le ** *!!,//122U  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[SRU 55e[U[R5(a [UUSS9n O[S[U55n [U[R5(a [X7SS9n O[S[U55n [!XXEU5n[SXU /S9nUR#US9nU[: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:zOColumns {} present in both tables. AsofJoin does not support column collisions.Tr)r=asofjoinrBr<rF)rGrrHr!rIrJrKrLr.r/rN ValueErrorformatr8rr rrSr&)rUleft_onleft_byrWright_onright_by tolerancer*r\rcrbcolumns_collisionsrgrhrir4rps 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 HSn[U[5(a[R"U/5nSn[R "[ S[ U5S9[ S[U5S9/5nURSS9nU(a!UR5R5SnU$)aMFilter 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 FTr=)rCr-r<r) rGrr from_batchesrr0r r rScombine_chunks to_batches)table expressionis_batchr4results r _filter_tabler^s"H%%%""E7+  $ $N,B5,IJH&7 &CD& D]]t] ,F&&(335a8 Mrc z[U[R5(a [USS9nO[ S[ U55n[ S[ U40UD65n[R"XE/5nURSS9nU[:XaU$U[R:Xa[R"U5$[S5e)NTr<r=order_byrF) rGrHr!r8rr r r0rSrr&rI)table_or_dataset sort_keysr\kwargs data_sourcerr4rps r _sort_sourcer~s"BJJ//&'7TJ ! 23CD :'9)'Nv'NOH  $ $k%< =D==T=2Le ** *!!,//122rc [R"[S[U55[S[XS95/5nUR US9$)Nr= aggregate)keysr<)rr0r r rS)r aggregatesrr*r4s r _group_byrsJ  $ $N$:5$ABK!5j!LM& D ==[= 11r)TF)T) pyarrow.librrpyarrow.computerrpyarrow._acerorrr r r r r rr ImportErrorexcstrpyarrow.datasetr3rHpyarrow._datasetrrr8rqr|rrrrrr rs2+-   "  02#"%# n3f/3#(X3v@;@3,2Y   J3s8*TUV   Bs(A A;A8 A33A8;BB