+ nDj=2^RIHtHtHt^RIHtHt^RIHtH t H t H t H t H t HtHtHt^RIHt^RIHtRR ltRRR R ]R3R ltR ]3RltRt]3RltRRltR# ]dt]!R]!]4 R24RhRtAii;i ]d!RR 4t]tL^i;i))Table RecordBatcharray) Expressionfield) DeclarationExecNodeOptionsTableSourceNodeOptionsFilterNodeOptionsProjectNodeOptionsAggregateNodeOptionsOrderByNodeOptionsHashJoinNodeOptionsAsofJoinNodeOptionsz@The pyarrow installation is not built with support for 'acero' ()N)ScanNodeOptionsc>]tRt^2t!RR4t!RR4tRtR#)DatasetModuleStubc]tRt^3tRtR#)DatasetModuleStub.DatasetN__name__ __module__ __qualname____firstlineno____static_attributes__rG/data/cameron/venvs/s3viz/lib/python3.14/site-packages/pyarrow/acero.pyDatasetr3 rr c]tRt^6tRtR#)!DatasetModuleStub.InMemoryDatasetrNrrrrInMemoryDatasetr#6r!rr$rN)rrrrr r$rrrrrr2s    rrTFc \R\WVR74pVPPUu.uFp\ V4NK pp\P !V\R\ V44.4pVPPR4pVe,\P !V\R\V44.4pV#uupi)scan use_threadsimplicit_orderingprojectfilter) rrschemanamesr from_sequencer _scan_optionsgetr )datasetr(r)declf projections filter_exprs&&& r_dataset_to_declr6;s v+ - .D &-^^%9%9:%958%9K:  $ $ {9&8&EFG D''++H5K(( ;x):;)GH I  K;sB=c b \V\\P34'g\ R\ V4 24h\V\\P34'g\ R\ V4 24h/p \V\ \34'gV.p\V4F wrWV &K /p\V\\ 34'gV.p\V4F wrWV &K VPPpVPPpVR8XgVR8Xd.pM[VR8XgVR8Xd.pMJVR8XgVR8XdVUu.uFpVV9gK VNK ppM!VR8XdVUu.uFpVV 9gK VNK pp/p\V4Fwp pVV9gKV VV&K /p\V4Fwp pVV9gKV VV&K \V\P4'd\WR 7pM\R \V44p\V\P4'd\W7R 7pM\R \V44pV'd'\YYOTT;'gR T;'gR V R 7pM$\YTT;'gR T;'gR V R 7p\R VVV.R7pV'EdVR8XEd\V4p\V4p\!V4p.p.p\VV,4EF"wp pV \!V48dVV9dVP#V4VWKV,,,pVP#\$P&!R\$P(!V 4\$P(!VV,4.44KV V8d VV9dKV'dV V8dVV9d VV, pV'dV V8dVV9d VV, pVP#V4VP#\$P(!V 44EK% \R\+VV44p\P,!VV.4pVP/VR 7p V \8XdV #V \P08Xd\P0!V 4#\ R4huupiuupi)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,r-r6rr rsetlenappendr_call_fieldr r.to_tabler$)! join_type left_operand left_keys right_operand right_keys left_suffix right_suffixr( coalesce_keys output_typer?left_keys_orderidxkeyright_keys_order left_columns right_columnscolleft_column_keys_indicescolnameright_column_keys_indices left_source right_source join_optsr2left_columns_setright_columns_setright_operand_indexprojected_col_namesr4right_key_index projection result_tables!&&&&&&&&&&& r _perform_joinrpRsT lUBJJ$7 8 89$|:L9MNOO meRZZ%8 9 99$}:M9NOPPO i% / /K i(") j4- 0 0 \ j) #* &&,,L!((..MK9 #; l "i<&? g l!:( (CC7G,GCC=   m #' 'C3o+ECC<  "!,/ W i 03 $W -0!#!-0 W j 14 %g .1 , ++&|M !.2H2VW -,,' O " 2=A ' *M#.#4#4"$0$6$6B/  ( *#.#4#4"$0$6$6B/  I{L.I D}l2|, .!,/  !,">?HCS&&32J+J#**3/ #<s34#6""$$Z"))#. 0A0A/?1A2 ++7P0P  C*=$=00;&C S,?%?//<'C#**3/""%%c*E@J! )+7JK (($ );<==[=9Le ** *!!,//122Y  s R'R'/ R,=R,c b\V\\P34'g\ R\ V4 24h\V\\P34'g\ R\ V4 24h\V\ \34'gV.p\V\ \34'gV.pVPPU u.uFp W.V,9gKV NK p p \VPP4\V 4,p V 'd\RV R24h\V\P4'd\VVRR7p M\R\V44p \V\P4'd\W7RR7p M\R\V44p \WWEV4p\RWV .R7pVP!VR 7pV\8XdV#V\P"8Xd\P"!V4#\ R 4huup i) 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 r8zColumns zE present in both tables. AsofJoin does not support column collisions.Tr'r;asofjoinrAr:rE)rFrrGr rHrIrJrKr,r-rM ValueErrorr6rr rrRr$)rTleft_onleft_byrVright_onright_by tolerancer(r[rbracolumns_collisionsrfrgrhr2ros&&&&&&&&& r_perform_join_asofrzsB 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 H,&H,c 8Rp\V\4'd\P!V.4pRp\P !\ R\ V4R7\ R\V4R7.4pVPRR7pV'dVP^8d(VP4P4^,pV#VPUu.uFp\.VPR7NK pp\P!WdPR7pV#uupi) 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;)rBr+r:)rI)r,)rFrr from_batchesrr.r r rRnum_rowscombine_chunks to_batchesr,rrI from_arrays)table expressionis_batchr2resultrarrayss&& r _filter_tablerbs"H%%%""E7+  $ $N,B5,IJH&7 &CD& D]]t] ,F ??Q **,779!rs221-   "  02#"%#t r3n/3#(X3v!H;@3,2i   J3s8*TUV   Bs(A BA=%A88A=BB