MCPcopy Create free account

hub / github.com/dask/dask / functions

Functions9,157 in github.com/dask/dask

↓ 932 callersFunctionassert_eq
( a, b, check_names=True, check_dtype=True, check_divisions=True, check_index=True,
dask/dataframe/utils.py:532
↓ 695 callersFunctionassert_eq
( a, b, check_shape=True, check_graph=True, check_meta=True, check_chunks=True, ch
dask/array/utils.py:299
↓ 432 callersMethodarange
Create an ascending or descending array Returns evenly spaced values within the half-open interval ``[start, stop)`` as a one-dimensi
dask/array/backends.py:397
↓ 384 callersMethodcompute
(self, **kwargs)
dask/dataframe/dask_expr/_groupby.py:1618
↓ 354 callersFunctionfrom_pandas
Construct a Dask DataFrame from a Pandas DataFrame This splits an in-memory Pandas dataframe into several parts and constructs a dask.da
dask/dataframe/dask_expr/_collection.py:4870
↓ 339 callersMethodones
Create an array of ones Returns a new array having a specified shape and filled with ones.
dask/array/backends.py:362
↓ 268 callersFunctionassert_eq
(a, b, *args, serialize_graph=True, **kwargs)
dask/dataframe/dask_expr/tests/_util.py:26
↓ 239 callersMethodgroupby
(self, by, **kwargs)
dask/dataframe/dask_expr/_collection.py:4476
↓ 221 callersMethodcompute
(self, **kwargs)
dask/array/_array_expr/_collection.py:80
↓ 215 callersMethodreshape
Reshape array to new shape Refer to :func:`dask.array.reshape` for full documentation. See Also -------- dask.array.
dask/array/core.py:2255
↓ 205 callersFunctionall
(a, axis=None, keepdims=False, split_every=None, out=None)
dask/array/reductions.py:167
↓ 204 callersFunctionnew_collection
Create a new collection from an expr
dask/_collections.py:6
↓ 199 callersMethodoperand
(self, key)
dask/_expr.py:221
↓ 192 callersMethodset_index
Set the DataFrame index (row labels) using an existing column. If ``sort=False``, this function operates exactly like ``pandas.set_index``
dask/dataframe/dask_expr/_collection.py:3342
↓ 177 callersMethodrandom
(self, size=None, dtype=np.float64, out=None, chunks="auto", **kwargs)
dask/array/_array_expr/random.py:314
↓ 176 callersMethodcompute
(self, **kwargs)
dask/tests/test_typing.py:76
↓ 173 callersMethodget
(self, key, default=None)
dask/bag/tests/test_bag.py:1119
↓ 171 callersMethodto_parquet
(self, path, **kwargs)
dask/dataframe/dask_expr/_collection.py:3324
↓ 160 callersFunctionmax
(a, axis=None, keepdims=False, split_every=None, out=None)
dask/array/reductions.py:130
↓ 158 callersMethodastype
(self, dtypes)
dask/dataframe/dask_expr/_expr.py:360
↓ 152 callersMethodread_parquet
Read Parquet files into a DataFrame collection Parameters ---------- path : str or list Source path(s). *
dask/dataframe/backends.py:86
↓ 148 callersMethodset
(self, key, value)
dask/bag/tests/test_bag.py:1122
↓ 147 callersMethodjoin
( self, other, on=None, how="left", lsuffix="", rsuffix="",
dask/dataframe/dask_expr/_collection.py:2983
↓ 142 callersMethodpop
(self, item)
dask/dataframe/dask_expr/_collection.py:3960
↓ 137 callersFunctionany
(a, axis=None, keepdims=False, split_every=None, out=None)
dask/array/reductions.py:153
↓ 137 callersMethoditems
(self)
dask/dataframe/dask_expr/_collection.py:2720
↓ 129 callersMethodoptimize
(self, **kwargs)
dask/dataframe/dask_expr/_expr.py:96
↓ 116 callersFunctiondelayed
Wraps a function or object to produce a ``Delayed``. ``Delayed`` objects act as proxies for the object they wrap, but all operations on them
dask/delayed.py:414
↓ 109 callersMethodjoin
Joins collection with another collection. Other collection must be one of the following: 1. An iterable. We recommend tuples over
dask/bag/core.py:1151
↓ 102 callersMethodsum
(self, skipna=True, numeric_only=False, split_every=False, axis=0)
dask/dataframe/dask_expr/_expr.py:283
↓ 101 callersFunctiontokenize
Mapping function from task -> consistent name. Parameters ---------- args : object Python objects that summarize the task. pu
dask/delayed.py:392
↓ 100 callersMethodsplit
Known inconsistencies: ``expand=True`` with unknown ``n`` will raise a ``NotImplementedError``.
dask/dataframe/dask_expr/_str_accessor.py:99
↓ 91 callersMethodgroupby
( self, by, group_keys=True, sort=None, observed=None, dropna=None, **kwargs )
dask/dataframe/dask_expr/_collection.py:3031
↓ 91 callersMethodrepartition
Repartition a collection Exactly one of `divisions`, `npartitions` or `partition_size` should be specified. A ``ValueError`` will be
dask/dataframe/dask_expr/_collection.py:1294
↓ 90 callersMethodcopy
Make a copy of the dataframe This is strictly a shallow copy of the underlying computational graph. It does not affect the underlying
dask/dataframe/dask_expr/_collection.py:711
↓ 89 callersMethodfrom_collections
Construct a HighLevelGraph from a new layer and a set of collections This constructs a HighLevelGraph in the common case where we have a sing
dask/highlevelgraph.py:470
↓ 87 callersMethodzeros
Create an array of zeros Returns a new array having a specified shape and filled with zeros.
dask/array/backends.py:371
↓ 86 callersMethodvalues
Return a dask.array of the values of this dataframe Warning: This creates a dask.array without precise shape information. Operations
dask/dataframe/dask_expr/_collection.py:1433
↓ 82 callersMethodmerge
Merge the DataFrame with another DataFrame This will merge the two datasets, either on the indices, a certain column in each dataset
dask/dataframe/dask_expr/_collection.py:2859
↓ 82 callersMethodrechunk
( self, chunks="auto", threshold=None, block_size_limit=None, balance=
dask/array/_array_expr/_expr.py:113
↓ 81 callersMethodmap_partitions
Apply a Python function to each partition Parameters ---------- func : function Function applied to each partitio
dask/dataframe/dask_expr/_collection.py:993
↓ 80 callersFunctioncheck_tokenize
(*args, **kwargs)
dask/tests/test_tokenize.py:51
↓ 73 callersFunction_wrap_func
Wrap numpy random function to produce dask.array random function extra_chunks should be a chunks tuple to append to the end of chunks
dask/array/random.py:898
↓ 73 callersFunction_wrap_func
( rng, funcname, *args, size=None, chunks="auto", extra_chunks=(), **kwargs )
dask/array/_array_expr/random.py:873
↓ 73 callersFunctionmin
(a, axis=None, keepdims=False, split_every=None, out=None)
dask/array/reductions.py:106
↓ 71 callersMethoditems
(self)
dask/highlevelgraph.py:603
↓ 69 callersMethodsort_values
Sort the dataset by a single column. Sorting a parallel dataset requires expensive shuffles and is generally not recommended. See ``s
dask/dataframe/dask_expr/_collection.py:3534
↓ 68 callersMethodread_csv
Read CSV files into a DataFrame collection Parameters ---------- urlpath : str or list Source path(s). **
dask/dataframe/backends.py:137
↓ 66 callersMethodastype
Copy of the array, cast to a specified type. Parameters ---------- dtype : str or dtype Typecode or data-type to
dask/array/_array_expr/_collection.py:532
↓ 66 callersMethodmap_blocks
(self, func, *args, **kwargs)
dask/array/_array_expr/_collection.py:579
↓ 65 callersFunctionis_series_like
Looks like a Pandas Series
dask/utils.py:1529
↓ 63 callersMethodsum
Return the sum of the array elements over the given axis. Refer to :func:`dask.array.sum` for full documentation. See Also
dask/array/_array_expr/_collection.py:342
↓ 62 callersMethodintegers
( self, low, high=None, size=None, dtype=np.int64, endpoint=Fa
dask/array/_array_expr/random.py:186
↓ 62 callersFunctionsum
(a, axis=None, dtype=None, keepdims=False, split_every=None, out=None)
dask/array/reductions.py:70
↓ 61 callersMethodreset_index
Reset the index to the default index. Note that unlike in ``pandas``, the reset index for a Dask DataFrame will not be monotonically
dask/dataframe/dask_expr/_collection.py:659
↓ 61 callersMethodsimplify
(self)
dask/dataframe/dask_expr/_collection.py:556
↓ 61 callersFunctionsum
extra docstring
dask/tests/test_utils.py:634
↓ 61 callersFunctiontmpdir
Function to create and return a unique temporary directory. Parameters ---------- dir : str If ``dir`` is not None, the dire
dask/utils.py:379
↓ 58 callersMethodget
BlockwiseDep ``__getitem__`` Wrapper
dask/blockwise.py:56
↓ 57 callersFunctionfuncname
Get the name of a function.
dask/utils.py:1018
↓ 57 callersFunctiontmpfile
Function to create and return a unique temporary file with the given extension, if provided. Parameters ---------- extension : str
dask/utils.py:334
↓ 55 callersFunctionis_dask_collection
Returns ``True`` if ``x`` is a dask collection. Parameters ---------- x : Any Object to test. Returns ------- result
dask/base.py:207
↓ 54 callersMethodmerge
(self, other: Digest)
dask/dataframe/dask_expr/diagnostics/_analyze_plugin.py:30
↓ 54 callersFunctionmeta_from_array
Normalize an array to appropriate meta object Parameters ---------- x: array-like, callable Either an object that looks sufficien
dask/array/utils.py:27
↓ 52 callersMethodrandom
(self, size=None, dtype=np.float64, out=None, chunks="auto", **kwargs)
dask/array/random.py:328
↓ 51 callersMethodcopy
Copy array. This is a no-op for dask.arrays, which are immutable
dask/array/core.py:2944
↓ 51 callersFunctionorder
( dsk: Mapping[Key, Any], dependencies: Mapping[Key, set[Key]] | None = None, *, return_stats:
dask/order.py:64
↓ 50 callersMethodsum
(self)
dask/dataframe/tseries/resample.py:313
↓ 49 callersMethodastype
Copy of the array, cast to a specified type. Parameters ---------- dtype : str or dtype Typecode or data-type to
dask/array/core.py:2296
↓ 49 callersFunctionfiletexts
Dumps a number of textfiles to disk Parameters ---------- d : dict a mapping from filename to text like {'a.csv': '1,1\n2,2'}
dask/utils.py:465
↓ 49 callersFunctionflatten
>>> list(flatten([1])) [1] >>> list(flatten([[1, 2], [1, 2]])) [1, 2, 1, 2] >>> list(flatten([[[1], [2]], [[1], [2]]])) [1
dask/core.py:275
↓ 49 callersMethodmap_blocks
(self, func, *args, **kwargs)
dask/array/core.py:2741
↓ 48 callersFunctionmake_meta
This method creates meta-data based on the type of ``x``, and ``parent_meta`` if supplied. Parameters ---------- x : Object of a
dask/dataframe/dispatch.py:95
↓ 47 callersMethodassign
(self, **pairs)
dask/dataframe/dask_expr/_collection.py:2809
↓ 46 callersMethodrandint
(self, low, high=None, size=None, chunks="auto", dtype="l", **kwargs)
dask/array/random.py:701
↓ 45 callersMethodapply
(self, function, *args, meta=None, **kwargs)
dask/dataframe/dask_expr/_expr.py:395
↓ 45 callersFunctionis_dataframe_like
Looks like a Pandas DataFrame
dask/utils.py:1513
↓ 44 callersFunctionelemwise
Apply an elementwise ufunc-like function blockwise across arguments. Like numpy ufuncs, broadcasting rules are respected. Parameters ---
dask/array/core.py:5089
↓ 44 callersMethodwhere
(self, cond, other=np.nan)
dask/dataframe/dask_expr/_expr.py:385
↓ 43 callersMethodall
(self, skipna=True, split_every=False)
dask/dataframe/dask_expr/_expr.py:315
↓ 43 callersMethodall
Returns True if all elements evaluate to True. Refer to :func:`dask.array.all` for full documentation. See Also --------
dask/array/_array_expr/_collection.py:493
↓ 43 callersMethodchoice
( self, a, size=None, replace=True, p=None, axis=0, sh
dask/array/random.py:126
↓ 43 callersMethoddot
Dot product of self and other. Refer to :func:`dask.array.tensordot` for full documentation. See Also -------- dask.
dask/array/core.py:2185
↓ 43 callersMethodhead
(self, n=5, split_every=None, split_out=None)
dask/dataframe/dask_expr/_groupby.py:1838
↓ 42 callersMethodreplace
(self, to_replace=None, value=no_default, regex=False)
dask/dataframe/dask_expr/_expr.py:398
↓ 42 callersFunctionsame_keys
(a, b)
dask/array/utils.py:191
↓ 41 callersMethodadd
Add a rule to the RuleSet. Parameters ---------- rule : RewriteRule
dask/rewrite.py:256
↓ 41 callersFunctionfunc
(x)
dask/array/tests/test_atop.py:626
↓ 41 callersFunctionpyarrow_strings_enabled
Config setting to convert objects to pyarrow strings
dask/dataframe/utils.py:771
↓ 40 callersMethodunique
Return Series of unique values in the object. Includes NA values. Returns ------- uniques : Series
dask/dataframe/dask_expr/_collection.py:4319
↓ 39 callersFunctionapply_gufunc
Apply a generalized ufunc or similar python function to arrays. ``signature`` determines if the function consumes or produces core dimen
dask/array/_array_expr/_gufunc.py:173
↓ 39 callersMethodto_frame
(self, index=True, name=no_default)
dask/dataframe/dask_expr/_collection.py:4754
↓ 38 callersMethodadd
(self, sample: float)
dask/dataframe/dask_expr/diagnostics/_analyze_plugin.py:25
↓ 38 callersFunctionasarray
Convert the input to a dask array. Parameters ---------- a : array-like Input data, in any form that can be converted to a dask a
dask/array/core.py:4855
↓ 38 callersFunctionelemwise
Apply an elementwise ufunc-like function blockwise across arguments. Like numpy ufuncs, broadcasting rules are respected. Parameters ---
dask/array/_array_expr/_collection.py:878
↓ 38 callersFunctionnormalize_chunks
Normalize chunks to tuple of tuples This takes in a variety of input types and information and produces a full tuple-of-tuples result for chu
dask/array/core.py:3058
↓ 38 callersFunctiontokenize
Deterministic token >>> tokenize([1, 2, '3']) # doctest: +SKIP '06961e8de572e73c2e74b51348177918' >>> tokenize('Hello') == tokenize('He
dask/tokenize.py:47
↓ 37 callersFunctionconcat
Concatenate DataFrames along rows. - When axis=0 (default), concatenate DataFrames row-wise: - If all divisions are known and ordered, con
dask/dataframe/dask_expr/_collection.py:5442
↓ 37 callersMethodrename
Alter Series index labels or name Function / dict values must be unique (1-to-1). Labels not contained in a dict / Series will be lef
dask/dataframe/dask_expr/_collection.py:4481
↓ 36 callersFunctionassert_topological_sort
(dsk, order)
dask/tests/test_order.py:2066
next →1–100 of 9,157, ranked by callers