Returns a dictionary mapping between each index specified in `indices` and the number of output blocks for that indice.

Ensure that the frequency pertains to the **start** of a period. If e.g. `freq='M'`, then the divisions are: - 2021-31-1 00:00:00 (start

A reduction to count the number of elements. This has an additional kwarg in coerce_np_ndarray, which determines whether to ensure that

Parse string signatures for a generalized universal function. Arguments --------- signature : string Generalized universal f

Rebuild a collection that is represented by several child expressions. Collections using ``__dask_exprs__`` expose their children separately so t

Rename columns of pd.DataFrame or name of pd.Series. Not for dd.DataFrame or dd.Series. Parameters ---------- columns : tuple, s

A helper for creating the ``_repr_data`` property

Reset cached properties. Parameters ---------- key : str, optional Remove specified key. The default rem

Apply the rewrite rules in RuleSet to top level of term

Sanitize a one-element index.

Make a column selection that may include the index Parameters ---------- columns_or_index Column or index name, or a list of

Set up a Zarr store for reading or writing, handling both Zarr v2 and v3. This function prepares a Zarr-compatible storage object (`store`)

Split a Dask bag into new partitions Parameters ---------- bag: Dask bag nsplits: List[int] Number of target bags for each pa

Validates that rechunking an array from ``old_chunks`` to ``new_chunks`` is possible, raises an error if otherwise. Notes ----- This

Are any of the elements truthy? Examples -------- >>> import dask.bag as db >>> bool_bag = db.from_sequence([True, Tr

Parallel version of pandas.Series.apply Parameters ---------- func : function Function to apply $META

Apply a generalized ufunc or similar python function to arrays. ``signature`` determines if the function consumes or produces core dimen

Return evenly spaced values from `start` to `stop` with step size `step`. The values are half-open [start, stop), so including start and exc

Use the `like=` from `np.arange` to create a new array dispatching to the downstream library. If that fails, falls back to the default Nu

If a is dask.array, return dask.array.asanyarray(a, **kwargs), otherwise return np.asanyarray(a, like=like, **kwargs), dispatching the ca

Yields a flat iterable of booleans to mark the zeroth elements of the nested input ``block_lists`` in a flattened output. >>> list(block

>>> blockdims_from_blockshape((10, 10), (4, 3)) ((4, 4, 2), (3, 3, 3, 1)) >>> blockdims_from_blockshape((10, 0), (4, 0)) ((4, 4, 2),

Label boxes in graph by chunk index >>> box_label(('x', 1, 2, 3)) '(1, 2, 3)' >>> box_label(('x', 123)) '123' >>> box_label('x')

Construct a chunks tuple that broadcasts many chunks tuples >>> a = ((5, 5),) >>> b = ((5, 5),) >>> broadcast_chunks(a, b) ((5, 5),)

Provide a decorator to wrap common numpy function with a broadcast trick. Dask arrays are currently immutable; thus when we know an array is

Compute max with caching. Caching is by the identity of `seq` rather than the value. It is thus important that `seq` is a tuple of immutable

Check validity of index for a given dimension Examples -------- >>> check_index(0, 3, 5) >>> check_index(0, 5, 5) Traceback (most

Use an index array to construct a new array from a set of choices. Refer to :func:`dask.array.choose` for full documentation. See Al

Clear out old results from profiler

Return an array whose values are limited to ``[min, max]``. One of max or min must be given. Refer to :func:`dask.array.clip` for ful

Combine with another _DNF object

Add constant slice to either side of array

Return simple chunks tuple such that factor divides all elements Examples -------- >>> contract_tuple((2, 2, 8, 4), 4) (4, 8, 4)

Copy the traverser in its current state. This allows the traversal to be pushed onto a stack, for easy backtracking.

Internal utility for cumulative sum with label. >>> cumdims_label(((5, 3, 3), (2, 2, 1)), 'n') # doctest: +NORMALIZE_WHITESPACE [(('n', 0),

Return the cumulative product of the elements along the given axis. Refer to :func:`dask.array.cumprod` for full documentation. See

Return the default BitGenerator type

De-serialize config data into the original object. Typically when receiving config via the ``DASK_INTERNAL_INHERIT_CONFIG`` environment variable.