MCPcopy Create free account
hub / github.com/dask/dask / nancumprod

Function nancumprod

dask/array/reductions.py:240–262  ·  view source on GitHub ↗

Dask added an additional keyword-only argument ``method``. method : {'sequential', 'blelloch'}, optional Choose which method to use to perform the cumprod. Default is 'sequential'. * 'sequential' performs the cumprod of each prior block before the current block. * 'ble

(x, axis, dtype=None, out=None, *, method="sequential")

Source from the content-addressed store, hash-verified

238
239@derived_from(np)
240def nancumprod(x, axis, dtype=None, out=None, *, method="sequential"):
241 """Dask added an additional keyword-only argument ``method``.
242
243 method : {'sequential', 'blelloch'}, optional
244 Choose which method to use to perform the cumprod. Default is 'sequential'.
245
246 * 'sequential' performs the cumprod of each prior block before the current block.
247 * 'blelloch' is a work-efficient parallel cumprod. It exposes parallelism by first
248 taking the product of each block and combines the products via a binary tree.
249 This method may be faster or more memory efficient depending on workload,
250 scheduler, and hardware. More benchmarking is necessary.
251 """
252 return cumreduction(
253 chunk.nancumprod,
254 operator.mul,
255 1,
256 x,
257 axis,
258 dtype,
259 out=out,
260 method=method,
261 preop=np.nanprod,
262 )
263
264
265@derived_from(np)

Callers

nothing calls this directly

Calls 1

cumreductionFunction · 0.85

Tested by

no test coverage detected