Read lines from text files Parameters ---------- urlpath : string or list Absolute or relative filepath(s). Prefix with a protoco

Convert blocks in dask array x for new chunks. Parameters ---------- x: dask array Array to be rechunked. chunks: int,

Generic row-wise reductions. Parameters ---------- chunk : callable Function to operate on each partition. Should

Given a dask collection's key, replace the collection name with a new one. Parameters ---------- key: string or tuple Dask collec

Blockwise-reshape into a new shape. The regular reshape operation in Dask preserves C-ordering in the array which requires a rechunking for m

A relatively efficient way to shuffle `x` according to `index`. Parameters ---------- x : Array index : ndarray This should b

Translate chunks tuple to a set of slices in product order >>> slices_from_chunks(((2, 2), (3, 3, 3))) # doctest: +NORMALIZE_WHITESPACE [(s

Trim sides from each block This couples well with the overlap operation, which may leave excess data on each block See also --------

Unify chunks across a sequence of arrays This utility function is used within other common operations like :func:`dask.array.core.map_bl

Aggregate RG information to file level.

Test whether the input contains a reference to the index of the df

Convert a dask graph to Cytoscape JSON: https://js.cytoscape.org/#notation/elements-json

Sort the layers in a high level graph topologically Parameters ---------- hlg : HighLevelGraph The high level gra

Validates logic of `axes`/`axis`/`keepdims` arguments and normalize them. Refer to [1]_ for details Arguments --------- axes: Li

Return the wrapped filesystem if fs is ArrowFSWrapper

Generic function for argreduction. Parameters ---------- x : Array chunk : callable Partialed ``arg_chunk``. combine : ca

Formats an ascii table for given columns and rows. Parameters ---------- columns : list The column names rows : list of tuple

Add boundary conditions to an array before overlapping See Also -------- periodic constant

Check that the dask metadata matches the result. If metadata matches, ``x`` is passed through unchanged. A nice error is raised if metadata d

Set categories to be unknown. Parameters ---------- x : DataFrame, Series, Index cols : iterable, optional If x is a DataFram

Collect config from environment variables This grabs environment variables of the form "DASK_FOO__BAR_BAZ=123" and turns these into config va

Complex-conjugate all elements. Refer to :func:`dask.array.conj` for full documentation. See Also -------- dask.arra

Return new dask with only the tasks required to calculate keys. In other words, remove unnecessary tasks from dask. ``keys`` may be a single

Apply function inside nested lists >>> inc = lambda x: x + 1 >>> deepmap(inc, [[1, 2], [3, 4]]) [[2, 3], [4, 5]] >>> add = lambda x,

Get size in pixels for all dimensions

Determine new chunks to ensure that every chunk >= size Parameters ---------- size: int The maximum size of any chunk. chunks

Execute a given graph. The graph is executed in topological order as defined by dask.order until all leaf nodes, i.e. nodes without any depen

Wrap 1D, 2D, and ND real and complex FFT functions Takes a function that behaves like ``numpy.fft`` functions and a specified kind to match i

Parallelizable reduction Fold is like the builtin function ``reduce`` except that it works in parallel. Fold takes two binary operat

Get value from Dask Examples -------- >>> inc = lambda x: x + 1 >>> d = {'x': 1, 'y': (inc, 'x')} >>> get(d, 'x') 1 >>>

Asynchronous get function This is a general version of various asynchronous schedulers for dask. It takes a ``concurrent.futures.Executor.su

Return the current multiprocessing context.

Given a dask collection's key, extract the collection name. Parameters ---------- key: string or tuple Dask collection's key, whi

Does this object have a dask dataframe equivalent?

Concise summary of a Dask DataFrame

Returns True if obj is an instance of a namedtuple. Note: This function checks for the existence of the methods and attributes that make up t

Determine if input is a non-pyarrow string dtype

>>> is_scalar_for_elemwise(42) True >>> is_scalar_for_elemwise('foo') True >>> is_scalar_for_elemwise(True) True >>> is_

A wrapper for functions that don't provide keepdims to ensure that they do.

.. note:: This implementation follows the dask.array.stats implementation of kurtosis and calculates kurtosis without

Apply a function to each partition, sharing rows with adjacent partitions. Parameters ---------- func : function The function app

Pluralize a count-noun string pattern when necessary

Calculate the nth centralized moment. Refer to :func:`dask.array.moment` for the full documentation. See Also --------

>>> new_blockdim(100, [20, 10, 20, 10, 40], slice(0, 90, 2)) [10, 5, 10, 5, 15] >>> new_blockdim(100, [20, 10, 20, 10, 40], [5, 1, 30,