+ JV-j;_^RIHtHtHtHtHtHtHtHtH t H t H t H t H t HtHtHtHtHtHtHtHtHtHtHtHtHtHtHtHtHtHtH t H!t!H"t"H#t#H$t$H%t%H&t&H't'H(t(H)t)H*t*H+t+H,t,H-t-H.t.H/t/H0t0H1t1H2t2H3t3H4t4H5t5H6t6H7t7H8t8H9t9H:t:H;t;Ht>H?t?H@t@HAtAHBtBHCtCHDtDHEtEHFtFHGtGHHtHHItIHJtJHKtKHLtLHMtMHNtNHOtOHPtP^RIQHRtR^RIStS^RITHUtU^RIVtV^RIWtX^RIWHYtY^RIZH[t[Rt\]R!RR!4t]R t^R t_R t`R taR tbRtcRtdRte]e!4]f!4R,;tgthR"RltiR#RR/RlltjRRRR/RltkRtlR$RR/RlltmR$RR/RlltnRRRRRR/RltoRtpR tqR#)%)PFunctionFunctionOptionsFunctionRegistryHashAggregateFunctionHashAggregateKernelKernelScalarAggregateFunctionScalarAggregateKernelScalarFunction ScalarKernelVectorFunction VectorKernelArraySortOptionsAssumeTimezoneOptions CastOptions CountOptionsCumulativeOptionsCumulativeSumOptionsDayOfWeekOptionsDictionaryEncodeOptionsRunEndEncodeOptionsElementWiseAggregateOptionsExtractRegexOptionsExtractRegexSpanOptions FilterOptions IndexOptionsInversePermutationOptions JoinOptionsListSliceOptionsListFlattenOptionsMakeStructOptionsMapLookupOptionsMatchSubstringOptions ModeOptions NullOptions PadOptionsPairwiseOptionsPartitionNthOptionsPivotWiderOptionsQuantileOptions RandomOptions RankOptionsRankQuantileOptionsReplaceSliceOptionsReplaceSubstringOptionsRoundBinaryOptions RoundOptionsRoundTemporalOptionsRoundToMultipleOptionsScalarAggregateOptionsScatterOptionsSelectKOptionsSetLookupOptions SkewOptions SliceOptions SortOptions SplitOptionsSplitPatternOptionsStrftimeOptionsStrptimeOptionsStructFieldOptions TakeOptionsTDigestOptions TrimOptionsUtf8NormalizeOptionsVarianceOptions WeekOptionsWinsorizeOptionsZeroFillOptions call_functionfunction_registry get_functionlist_functionscall_tabular_functionregister_scalar_functionregister_tabular_functionregister_aggregate_functionregister_vector_function UdfContext Expression) namedtupleN)dedent)_compute_docstrings) docscrapec.VPP#N)_doc arg_names)funcs&`/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/pyarrow/compute.py_get_arg_namesr]ss 99  _OptionsClassDoccVP'gR#\P!VP4p\VR,4#)N Parameters)__doc__rVNumpyDocStringr_) options_classdocs& r\_scrape_options_class_docrfzs7    " "=#8#8 9C C - ..r^c $VPp\VPVPVPVP R7VnWnWn.pVPpV'g)VP^8dRMRpRVP: RV 2pVPV R24VPpV'dVPV R24\PPVP4p VP\R44\!V4p V FAp VP"R9dRp MR p VPV R V R 24VPR 4KC VEeE\%V4p V 'dhV P&FVpVPVP R VP( R 24VP*FpVPR V R 24K KX M\,P.!RVP R2\04\2P4!V4pVP6P94FEpVP\RVP RVP RVP R244KG VP\RVP R244VP\R44V e0\V 4P;R 4pVPR V R 24RP=V4VnV#))namearityrdoptions_required argumentsargumentzCall compute function z with the given z. z z. Parameters ---------- z Array-likezArray-like or scalar-likez :  z" Argument to compute function. z zOptions class z does not have a docstringz z. : optional Parameter for z7 constructor. Either `options` or `z@` can be passed, but not both at the same time. z& options : pyarrow.compute.zK, optional Alternative way of passing options. z memory_pool : pyarrow.MemoryPool, optional If not passed, will allocate memory from the default memory pool. )vectorscalar_aggregate) rYdictrhrirdrj__arrow_compute_function____name__ __qualname__summaryappend descriptionrUfunction_doc_additionsgetrTr]kindrfparamstypedescwarningswarnRuntimeWarninginspect signature parametersvaluesstripjoinrb)wrapper exposed_namer[rdcpp_doc doc_piecesruarg_strrw doc_additionrZarg_namearg_typeoptions_class_docps options_sigstrippeds&&&& r\_decorate_compute_functionrsiiG)- YYjj++ 11 *3G& $'JooG !%a+Z*499-7GyQ '(%%K[M./&==AA$))LLf   t$I 996 6#H2HXJc(267?@  5mD &--!!QVVHCxr":;A%%QCrl3 . MMN=+A+A*BC678F H!++M:K ++224!!&.##0#9#9":;!*#5 &&''4'='=&>? "  f   ,'--d3Bxj+,ggj)GO Nr^cVPPpV'gR#\4V,# \d$\P !RT R2\ 4R#i;i)NzPython binding for z not exposed)rYrdglobalsKeyErrorr~rr)r[ class_names& r\_get_options_classrsV((J y$$  +J<|D$ &s3*A! A!c V'g V'dVe\RV: R24hV!V/VB#VeP\V\4'd V!R/VB#\W!4'dV#\RV: RV R\V4 24hR#)Nz Function z@ called with both an 'options' argument and additional argumentsz expected a z parameter, got ) TypeError isinstancerqr|)rhrdoptionsargskwargss&&&&&r\_handle_optionsrs v  D8$+,- -d-f-- gt $ $ +7+ +  / /Nx|M?;=/ #$ $ r^cPaaaaSfRR/VVV3RllpV#RRRR/VVVV3RllpV#)N memory_poolc "<S\Jd.\V4S8wd\S RS R\V4 R24hV'd>\V^,\4'd!\P !S\ V44#SPVRV4#) takes  positional argument(s), but were givenN)EllipsislenrrrR_calllistcall)rrrir[ func_names$*r\r&_make_generic_wrapper..wrappersH$Te); k0t9+[2 47J77!'' 4:>>99T45 5r^rc X<S\Jd9\V4S8d\S RS R\V4 R24hVSRpVRSpMRp\SSVWC4pV'd?\ V^,\ 4'd"\ P !S\V4V4#SPW!V4#)rrrNr) rrrrrrRrrr) rrrr option_argsrir[rrds $$*, r\rrsH$t9u$#$+WUG4"4yk6#56l FU| %i&1;G 47J77!'' 4:wGG99TK8 8r^r)rr[rdrirsffff r\_make_generic_wrapperrs@ 6t 6 64 N! 9t 9T 9 9 Nr^c^RIHp.pVF$pVPV!WSP44K& VF$pVPV!WSP44K& Ve\P !V4pVP P4FapVPVPVP39gQhV'dVPVPR7pVPV4Kc VPV!RVPRR74VPV!RVPRR74\P!V4#)r) ParameterN)rzr)defaultr) rrrvPOSITIONAL_ONLYVAR_POSITIONALrrrrzPOSITIONAL_OR_KEYWORD KEYWORD_ONLYreplace Signature)rZ var_arg_namesrdrr{rhrrs&&& r\_make_signaturers! F i&?&?@A i&>&>?@ '' 6 ''..0A66i=='4466 66II9#9#9I: MM!  1  i 9+A+A(,. / MM)M9+A+A$(*+   V $$r^c0\V4p\V4pT;'dVR,PR4pV'd"VP4P R4.pM.p\ WW!P R7p\W5V4Vn\W`W4#)*)ri) rr] startswithpoplstriprrir __signature__r)rhr[rdrZ has_varargrrs&& r\_wrap_functionr*s&t,Mt$I<>> from datetime import datetime >>> import pyarrow as pa >>> arr = pa.array([datetime(2010, 1, 1), datetime(2015, 1, 1)]) >>> arr.type TimestampType(timestamp[us]) You can use ``pyarrow.DataType`` objects to specify the target type: >>> cast(arr, pa.timestamp('ms')) [ 2010-01-01 00:00:00.000, 2015-01-01 00:00:00.000 ] >>> cast(arr, pa.timestamp('ms')).type TimestampType(timestamp[ms]) Alternatively, it is also supported to use the string aliases for these types: >>> arr.cast('timestamp[ms]') [ 2010-01-01 00:00:00.000, 2015-01-01 00:00:00.000 ] >>> arr.cast('timestamp[ms]').type TimestampType(timestamp[ms]) Returns ------- casted : Array The cast result as a new Array NzRMust either pass values for 'target_type' and 'safe' or pass a value for 'options'Fcast) ValueErrorpatypeslib ensure_typerunsafesaferH)arr target_typerrrsafe_vars_passeds&&&&& r\rr\slD(FFk.EW0:; ;hhll..{; 5=!((5G!&&{3G # ==r^rcVe0VeVPW#V, 4pM(VPV4pMVeVP^V4p\V\P4'g#\P!WP R7pMKVP VP 8wd1\P!VP 4VP R7p\VR7p\RV.WT4pVeVVP 4^8dA\P!VP 4V,\P!4R7pV#)a Find the index of the first occurrence of a given value. Parameters ---------- data : Array-like value : Scalar-like object The value to search for. start : int, optional end : int, optional memory_pool : MemoryPool, optional If not passed, will allocate memory from the default memory pool. Returns ------- index : int the index, or -1 if not found Examples -------- >>> import pyarrow as pa >>> import pyarrow.compute as pc >>> arr = pa.array(["Lorem", "ipsum", "dolor", "sit", "Lorem", "ipsum"]) >>> pc.index(arr, "ipsum") >>> pc.index(arr, "ipsum", start=2) >>> pc.index(arr, "amet") r|valueindex) slicerrScalarscalarr|as_pyrrHint64)datarstartendrrresults&&&&$ r\rrs>  ?::e5[1D::e$D zz!S! eRYY ' ' %ii0 ejj  %++-dii8'G 7TFG AF V\\^q06<<>E1 C Mr^ boundscheckTc6\VR7p\RW.WC4#)a Select values (or records) from array- or table-like data given integer selection indices. The result will be of the same type(s) as the input, with elements taken from the input array (or record batch / table fields) at the given indices. If an index is null then the corresponding value in the output will be null. Parameters ---------- data : Array, ChunkedArray, RecordBatch, or Table indices : Array, ChunkedArray Must be of integer type boundscheck : boolean, default True Whether to boundscheck the indices. If False and there is an out of bounds index, will likely cause the process to crash. memory_pool : MemoryPool, optional If not passed, will allocate memory from the default memory pool. Returns ------- result : depends on inputs Selected values for the given indices Examples -------- >>> import pyarrow as pa >>> arr = pa.array(["a", "b", "c", None, "e", "f"]) >>> indices = pa.array([0, None, 4, 3]) >>> arr.take(indices) [ "a", null, "e", null ] )rtake)r@rH)rindicesrrrs&&$$ r\rrs Pk2G $' GGr^ct\V\P\P\P34'g#\P !WP R7pMKVP VP 8wd1\P !VP4VP R7p\RW.4#)aReplace each null element in values with a corresponding element from fill_value. If fill_value is scalar-like, then every null element in values will be replaced with fill_value. If fill_value is array-like, then the i-th element in values will be replaced with the i-th element in fill_value. The fill_value's type must be the same as that of values, or it must be able to be implicitly casted to the array's type. This is an alias for :func:`coalesce`. Parameters ---------- values : Array, ChunkedArray, or Scalar-like object Each null element is replaced with the corresponding value from fill_value. fill_value : Array, ChunkedArray, or Scalar-like object If not same type as values, will attempt to cast. Returns ------- result : depends on inputs Values with all null elements replaced Examples -------- >>> import pyarrow as pa >>> arr = pa.array([1, 2, None, 3], type=pa.int8()) >>> fill_value = pa.scalar(5, type=pa.int8()) >>> arr.fill_null(fill_value) [ 1, 2, 5, 3 ] >>> arr = pa.array([1, 2, None, 4, None]) >>> arr.fill_null(pa.array([10, 20, 30, 40, 50])) [ 1, 2, 30, 4, 50 ] rcoalesce) rrArray ChunkedArrayrrr|rrH)r fill_values&&r\ fill_nullrstf j288R__bii"H I IYYz <   'YYz//1 D f%9 ::r^cVf.p\V\P\P34'dVP R4M \ RV4p\ W4p\RV.WC4#)a< Select the indices of the top-k ordered elements from array- or table-like data. This is a specialization for :func:`select_k_unstable`. Output is not guaranteed to be stable. Parameters ---------- values : Array, ChunkedArray, RecordBatch, or Table Data to sort and get top indices from. k : int The number of `k` elements to keep. sort_keys : List-like Column key names to order by when input is table-like data. memory_pool : MemoryPool, optional If not passed, will allocate memory from the default memory pool. Returns ------- result : Array Indices of the top-k ordered elements Examples -------- >>> import pyarrow as pa >>> import pyarrow.compute as pc >>> arr = pa.array(["a", "b", "c", None, "e", "f"]) >>> pc.top_k_unstable(arr, k=3) [ 5, 4, 2 ] c VR3#) descendingrkey_names&r\ top_k_unstable..ds (L)Ar^select_k_unstable)dummyrrrrrrvmapr6rHrk sort_keysrrs&&&$ r\top_k_unstabler:sbJ &288R__56601A9M Q*G ,vh MMr^cVf.p\V\P\P34'dVP R4M \ RV4p\ W4p\RV.WC4#)aS Select the indices of the bottom-k ordered elements from array- or table-like data. This is a specialization for :func:`select_k_unstable`. Output is not guaranteed to be stable. Parameters ---------- values : Array, ChunkedArray, RecordBatch, or Table Data to sort and get bottom indices from. k : int The number of `k` elements to keep. sort_keys : List-like Column key names to order by when input is table-like data. memory_pool : MemoryPool, optional If not passed, will allocate memory from the default memory pool. Returns ------- result : Array of indices Indices of the bottom-k ordered elements Examples -------- >>> import pyarrow as pa >>> import pyarrow.compute as pc >>> arr = pa.array(["a", "b", "c", None, "e", "f"]) >>> pc.bottom_k_unstable(arr, k=3) [ 0, 1, 2 ] c VR3#) ascendingrrs&r\r#bottom_k_unstable..s (K)@r^r)rrrrs&&&$ r\bottom_k_unstabler isbJ &288R__566/0@)L Q*G ,vh MMr^ initializersystemrc8\VR7p\R.W#VR7#)a Generate numbers in the range [0, 1). Generated values are uniformly-distributed, double-precision in range [0, 1). Algorithm and seed can be changed via RandomOptions. Parameters ---------- n : int Number of values to generate, must be greater than or equal to 0 initializer : int or str How to initialize the underlying random generator. If an integer is given, it is used as a seed. If "system" is given, the random generator is initialized with a system-specific source of (hopefully true) randomness. Other values are invalid. options : pyarrow.compute.RandomOptions, optional Alternative way of passing options. memory_pool : pyarrow.MemoryPool, optional If not passed, will allocate memory from the default memory pool. )r random)length)r+rH)nr rrs&$$$r\rrs, 4G 2wA FFr^c\V4pV^8Xd\V^,\\34'd\P !V^,4#\V^,\ 4'd\P!V^,4#\R\V^,4 24h\P!V4#)aReference a column of the dataset. Stores only the field's name. Type and other information is known only when the expression is bound to a dataset having an explicit scheme. Nested references are allowed by passing multiple names or a tuple of names. For example ``('foo', 'bar')`` references the field named "bar" inside the field named "foo". Parameters ---------- *name_or_index : string, multiple strings, tuple or int The name or index of the (possibly nested) field the expression references to. Returns ------- field_expr : Expression Reference to the given field Examples -------- >>> import pyarrow.compute as pc >>> pc.field("a") >>> pc.field(1) >>> pc.field(("a", "b")) >> pc.field("a", "b") r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrR collectionsrSrtextwraprTr~pyarrowrrUpyarrow.vendoredrVr]r_rfrrrrrrrr utf8_zfillrrrrrrr rrrrr^r\r!sm$UUUUUUUUUUUUUUUUUUUUUn#'&0+>/Pf (>%. J ;:%i(899 ^B>J/D/d)Ht)H)HX8;v,NT,N^,N,N^GXGtGG4.7b%r^