Get Started
Install
Examples
Tutorial
Why Dask?
Use Cases
Talks
Try Online
Slides
Algorithms
Arrays
Dataframes
Bags
Delayed (custom)
Futures (real-time)
Machine Learning
XArray
Setup
Local
Cloud
HPC
Kubernetes
Hadoop / Yarn
Community
Ask for Help
Github
Stack Overflow
Twitter
Developer Blog
YouTube Channel
Slack
Dask
Getting Started
Install Dask
10 Minutes to Dask
Talks & Tutorials
Best Practices
How To…
FAQ
Fundamentals
Array
Bag
DataFrame
Delayed
Futures
Scheduling
Task Graphs
Deploying Clusters
Dask Internals
Reference
API Reference
Development Guidelines
Changelog
Configuration
Dask
»
Index
Index
Symbols
|
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
Symbols
--bokeh
dask-scheduler command line option
dask-worker command line option
--bokeh-port
dask-scheduler command line option
dask-worker command line option
--contact-address
dask-worker command line option
--dashboard
dask-scheduler command line option
dask-worker command line option
--dashboard-address
dask-scheduler command line option
dask-worker command line option
--dashboard-prefix
dask-scheduler command line option
dask-worker command line option
--death-timeout
dask-worker command line option
--host
dask-scheduler command line option
dask-worker command line option
--hostfile
dask-ssh command line option
--idle-timeout
dask-scheduler command line option
--interface
dask-scheduler command line option
dask-worker command line option
--lifetime
dask-worker command line option
--lifetime-restart
dask-worker command line option
--lifetime-stagger
dask-worker command line option
--listen-address
dask-worker command line option
--local-directory
dask-ssh command line option
dask-worker command line option
--log-directory
dask-ssh command line option
--memory-limit
dask-ssh command line option
dask-worker command line option
--name
dask-worker command line option
--nanny
dask-worker command line option
--nanny-port
dask-ssh command line option
dask-worker command line option
--no-bokeh
dask-scheduler command line option
dask-worker command line option
--no-dashboard
dask-scheduler command line option
dask-worker command line option
--no-lifetime-restart
dask-worker command line option
--no-nanny
dask-worker command line option
--no-reconnect
dask-worker command line option
--no-show
dask-scheduler command line option
--nohost
dask-ssh command line option
--nprocs
dask-ssh command line option
dask-worker command line option
--nthreads
dask-ssh command line option
dask-worker command line option
--nworkers
dask-ssh command line option
dask-worker command line option
--pid-file
dask-scheduler command line option
dask-worker command line option
--port
dask-scheduler command line option
--preload
dask-scheduler command line option
dask-worker command line option
--preload-nanny
dask-worker command line option
--protocol
dask-scheduler command line option
dask-worker command line option
--reconnect
dask-worker command line option
--remote-dask-worker
dask-ssh command line option
--remote-python
dask-ssh command line option
--resources
dask-worker command line option
--scheduler
dask-ssh command line option
--scheduler-file
dask-scheduler command line option
dask-worker command line option
--scheduler-port
dask-ssh command line option
--show
dask-scheduler command line option
--ssh-port
dask-ssh command line option
--ssh-private-key
dask-ssh command line option
--ssh-username
dask-ssh command line option
--tls-ca-file
dask-scheduler command line option
dask-worker command line option
--tls-cert
dask-scheduler command line option
dask-worker command line option
--tls-key
dask-scheduler command line option
dask-worker command line option
--use-xheaders
dask-scheduler command line option
--version
dask-scheduler command line option
dask-ssh command line option
dask-worker command line option
--worker-class
dask-worker command line option
--worker-port
dask-ssh command line option
dask-worker command line option
_
__dask_graph__()
__dask_keys__()
__dask_layers__()
__dask_optimize__()
__dask_postcompute__()
__dask_postpersist__()
__dask_scheduler__()
__init__() (dask.array.Array method)
(dask.array.gufunc.gufunc method)
(dask.bag.Bag method)
(dask.bag.Item method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.Aggregation method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
A
abs() (dask.dataframe.DataFrame method)
accumulate() (dask.bag.Bag method)
acquire() (distributed.Lock method)
Adaptive (class in distributed.deploy)
adaptive_target() (distributed.Scheduler method)
add (in module dask.array)
add() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
add_client() (distributed.Scheduler method)
add_done_callback() (distributed.Future method)
add_keys() (distributed.Scheduler method)
add_plugin() (distributed.Scheduler method)
add_worker() (distributed.Scheduler method)
agg() (dask.dataframe.tseries.resample.Resampler method)
aggregate() (dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
Aggregation (class in dask.dataframe.groupby)
align() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
all() (dask.array.Array method)
(dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
allclose() (in module dask.array)
amm (distributed.Client property)
angle() (in module dask.array)
annotate() (in module dask)
any() (dask.array.Array method)
(dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
append() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
apply() (dask.bag.Item method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.rolling.Rolling method)
(dask.dataframe.Series method)
apply_along_axis() (in module dask.array)
apply_gufunc() (in module dask.array.gufunc)
apply_over_axes() (in module dask.array)
applymap() (dask.dataframe.DataFrame method)
arange() (in module dask.array)
arccos (in module dask.array)
arccosh (in module dask.array)
arcsin (in module dask.array)
arcsinh (in module dask.array)
arctan (in module dask.array)
arctan2 (in module dask.array)
arctanh (in module dask.array)
argmax() (dask.array.Array method)
(in module dask.array)
argmin() (dask.array.Array method)
(in module dask.array)
argtopk() (dask.array.Array method)
(in module dask.array)
argwhere() (in module dask.array)
around() (in module dask.array)
Array (class in dask.array)
array() (in module dask.array)
as_completed() (in module distributed)
as_current() (distributed.Client method)
as_gufunc() (in module dask.array.gufunc)
asanyarray() (in module dask.array)
asarray() (in module dask.array)
assign() (dask.dataframe.DataFrame method)
astype() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
atleast_1d() (in module dask.array)
atleast_2d() (in module dask.array)
atleast_3d() (in module dask.array)
autocorr() (dask.dataframe.Series method)
average() (in module dask.array)
(in module dask.array.ma)
B
Bag (class in dask.bag)
beta() (in module dask.array.random)
between() (dask.dataframe.Series method)
bfill() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
bincount() (in module dask.array)
bind() (in module dask.graph_manipulation)
binomial() (in module dask.array.random)
bitwise_and (in module dask.array)
bitwise_not (in module dask.array)
bitwise_or (in module dask.array)
bitwise_xor (in module dask.array)
block() (in module dask.array)
blocks (dask.array.Array property)
blockwise() (in module dask.array)
(in module dask.array.core)
broadcast() (distributed.Scheduler method)
broadcast_arrays() (in module dask.array)
broadcast_to() (in module dask.array)
C
CacheProfiler() (in module dask.diagnostics)
call_stack() (distributed.Client method)
Callback() (in module dask.diagnostics)
cancel() (distributed.Client method)
(distributed.Future method)
cancel_key() (distributed.Scheduler method)
cancelled() (distributed.Future method)
cat (dask.dataframe.Series attribute)
categorize() (dask.dataframe.DataFrame method)
cbrt (in module dask.array)
ceil (in module dask.array)
checkpoint() (in module dask.graph_manipulation)
chisquare() (in module dask.array.random)
(in module dask.array.stats)
choice() (in module dask.array.random)
choices() (in module dask.bag.random)
cholesky() (in module dask.array.linalg)
choose() (dask.array.Array method)
(in module dask.array)
chunks (dask.array.Array property)
chunksize (dask.array.Array property)
clear() (distributed.Event method)
clear_divisions() (dask.dataframe.Series method)
Client (class in distributed)
client_heartbeat() (distributed.Scheduler method)
client_releases_keys() (distributed.Scheduler method)
client_send() (distributed.Scheduler method)
clip() (dask.array.Array method)
(dask.dataframe.Series method)
(in module dask.array)
clip_lower() (dask.dataframe.Series method)
clip_upper() (dask.dataframe.Series method)
clone() (in module dask.graph_manipulation)
close() (distributed.Client method)
(distributed.Nanny method)
(distributed.Scheduler method)
close_gracefully() (distributed.Nanny method)
(distributed.Worker method)
close_worker() (distributed.Scheduler method)
Cluster (class in distributed.deploy)
coarsen() (in module dask.array)
coerce_address() (distributed.Scheduler method)
collect() (in module dask.config)
collections_to_dsk() (distributed.Client static method)
columns (dask.dataframe.DataFrame property)
compress() (in module dask.array)
compute() (dask.array.Array method)
(dask.bag.Bag method)
(dask.bag.Item method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(distributed.Client method)
(in module dask)
(in module dask.dataframe)
compute_chunk_sizes() (dask.array.Array method)
concat() (in module dask.bag)
(in module dask.dataframe.multi)
concatenate() (in module dask.array)
conj (in module dask.array)
conj() (dask.array.Array method)
copy() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
copysign (in module dask.array)
corr() (dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.Series method)
corrcoef() (in module dask.array)
cos (in module dask.array)
cosh (in module dask.array)
count() (dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.rolling.Rolling method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
count_nonzero() (in module dask.array)
cov() (dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.Series method)
(in module dask.array)
cull() (dask.highlevelgraph.HighLevelGraph method)
(in module dask.optimization)
cull_layers() (dask.highlevelgraph.HighLevelGraph method)
cumcount() (dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
cummax() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
cummin() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
cumprod() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
(in module dask.array)
cumsum() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
(in module dask.array)
current() (distributed.Client class method)
D
dashboard_link (distributed.Client property)
dask (dask.array.Array attribute)
dask-scheduler command line option
--bokeh
--bokeh-port
--dashboard
--dashboard-address
--dashboard-prefix
--host
--idle-timeout
--interface
--no-bokeh
--no-dashboard
--no-show
--pid-file
--port
--preload
--protocol
--scheduler-file
--show
--tls-ca-file
--tls-cert
--tls-key
--use-xheaders
--version
PRELOAD_ARGV
dask-ssh command line option
--hostfile
--local-directory
--log-directory
--memory-limit
--nanny-port
--nohost
--nprocs
--nthreads
--nworkers
--remote-dask-worker
--remote-python
--scheduler
--scheduler-port
--ssh-port
--ssh-private-key
--ssh-username
--version
--worker-port
HOSTNAMES
dask-worker command line option
--bokeh
--bokeh-port
--contact-address
--dashboard
--dashboard-address
--dashboard-prefix
--death-timeout
--host
--interface
--lifetime
--lifetime-restart
--lifetime-stagger
--listen-address
--local-directory
--memory-limit
--name
--nanny
--nanny-port
--no-bokeh
--no-dashboard
--no-lifetime-restart
--no-nanny
--no-reconnect
--nprocs
--nthreads
--nworkers
--pid-file
--preload
--preload-nanny
--protocol
--reconnect
--resources
--scheduler-file
--tls-ca-file
--tls-cert
--tls-key
--version
--worker-class
--worker-port
PRELOAD_ARGV
SCHEDULER
DataFrame (class in dask.dataframe)
deg2rad (in module dask.array)
degrees (in module dask.array)
Delayed (class in dask.delayed)
delayed() (in module dask.delayed)
delete() (distributed.Variable method)
delete_worker_data() (distributed.Scheduler method)
describe() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
diag() (in module dask.array)
diagonal() (in module dask.array)
diff() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
digitize() (in module dask.array)
distinct() (dask.bag.Bag method)
div() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
divide() (dask.dataframe.DataFrame method)
divmod() (in module dask.array)
done() (distributed.Future method)
dot() (dask.array.Array method)
(in module dask.array)
drop() (dask.dataframe.DataFrame method)
drop_duplicates() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
dropna() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
dstack() (in module dask.array)
dt (dask.dataframe.Series attribute)
dtype (dask.array.Array property)
(dask.dataframe.Series property)
dtypes (dask.dataframe.DataFrame property)
dump_cluster_state() (distributed.Client method)
E
ediff1d() (in module dask.array)
einsum() (in module dask.array)
empty() (in module dask.array)
empty_like() (in module dask.array)
ensure_file() (in module dask.config)
eq() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
equal (in module dask.array)
eval() (dask.dataframe.DataFrame method)
Event (class in distributed)
exception() (distributed.Future method)
executor (distributed.Future property)
exp (in module dask.array)
exp2 (in module dask.array)
expand_environment_variables() (in module dask.config)
explode() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
expm1 (in module dask.array)
exponential() (in module dask.array.random)
eye() (in module dask.array)
F
f() (in module dask.array.random)
f_oneway() (in module dask.array.stats)
fabs (in module dask.array)
feed() (distributed.Scheduler method)
ffill() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
fft() (in module dask.array.fft)
fft2() (in module dask.array.fft)
fft_wrap() (in module dask.array.fft)
fftfreq() (in module dask.array.fft)
fftn() (in module dask.array.fft)
fftshift() (in module dask.array.fft)
filled() (in module dask.array.ma)
fillna() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
filter() (dask.bag.Bag method)
fire_and_forget() (in module distributed)
first() (dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
fix() (in module dask.array)
fix_invalid() (in module dask.array.ma)
flatnonzero() (in module dask.array)
flatten() (dask.array.Array method)
(dask.bag.Bag method)
flip() (in module dask.array)
fliplr() (in module dask.array)
flipud() (in module dask.array)
float_power (in module dask.array)
floor (in module dask.array)
floor_divide (in module dask.array)
floordiv() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
fmax (in module dask.array)
fmin (in module dask.array)
fmod (in module dask.array)
fold() (dask.bag.Bag method)
foldby() (dask.bag.Bag method)
format_bytes() (in module dask.utils)
format_time() (in module dask.utils)
frequencies() (dask.bag.Bag method)
frexp() (in module dask.array)
from_array() (in module dask.array)
(in module dask.dataframe)
from_bcolz() (in module dask.dataframe)
from_collections() (dask.highlevelgraph.HighLevelGraph class method)
from_dask_array() (in module dask.dataframe)
from_delayed() (dask.bag.Item static method)
(in module dask.array)
(in module dask.bag)
(in module dask.dataframe)
from_npy_stack() (in module dask.array)
from_pandas() (in module dask.dataframe)
from_sequence() (in module dask.bag)
from_tiledb() (in module dask.array)
from_url() (in module dask.bag)
from_zarr() (in module dask.array)
fromfunction() (in module dask.array)
frompyfunc() (in module dask.array)
full() (in module dask.array)
full_like() (in module dask.array)
functions_of() (in module dask.optimization)
fuse() (in module dask.optimization)
Future (class in distributed)
futures_of() (distributed.Client method)
G
gamma() (in module dask.array.random)
gather() (distributed.Client method)
(distributed.Scheduler method)
gather_dep() (distributed.Worker method)
gather_on_worker() (distributed.Scheduler method)
ge() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
geometric() (in module dask.array.random)
get() (dask.highlevelgraph.HighLevelGraph method)
(distributed.Client method)
(distributed.Queue method)
(distributed.Sub method)
(distributed.Variable method)
(in module dask.config)
get_all_dependencies() (dask.highlevelgraph.HighLevelGraph method)
get_all_external_keys() (dask.highlevelgraph.HighLevelGraph method)
get_client() (in module distributed)
get_current_task() (distributed.Worker method)
get_dataset() (distributed.Client method)
get_dummies() (in module dask.dataframe.reshape)
get_events() (distributed.Client method)
get_executor() (distributed.Client method)
get_group() (dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
get_metadata() (distributed.Client method)
get_partition() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
get_scheduler_logs() (distributed.Client method)
get_task_stream() (distributed.Client method)
(in module dask.distributed)
get_versions() (distributed.Client method)
get_worker_logs() (distributed.Client method)
get_worker_service_addr() (distributed.Scheduler method)
getdata() (in module dask.array.ma)
getmaskarray() (in module dask.array.ma)
gradient() (in module dask.array)
greater (in module dask.array)
greater_equal (in module dask.array)
groupby() (dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
gt() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
gufunc (class in dask.array.gufunc)
gumbel() (in module dask.array.random)
H
handle_cancel_compute() (distributed.Worker method)
handle_free_keys() (distributed.Worker method)
handle_long_running() (distributed.Scheduler method)
handle_missing_data() (distributed.Scheduler method)
handle_remove_replicas() (distributed.Worker method)
handle_worker() (distributed.Scheduler method)
has_what() (distributed.Client method)
head() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
hfft() (in module dask.array.fft)
HighLevelGraph (class in dask.highlevelgraph)
histogram() (in module dask.array)
histogram2d() (in module dask.array)
histogramdd() (in module dask.array)
HOSTNAMES
dask-ssh command line option
hstack() (in module dask.array)
hypergeometric() (in module dask.array.random)
hypot (in module dask.array)
I
identity() (distributed.Scheduler method)
idxmax() (dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
idxmin() (dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
ifft() (in module dask.array.fft)
ifft2() (in module dask.array.fft)
ifftn() (in module dask.array.fft)
ifftshift() (in module dask.array.fft)
ihfft() (in module dask.array.fft)
iloc (dask.dataframe.DataFrame property)
imag (dask.array.Array property)
imag() (in module dask.array)
imread() (in module dask.array.image)
index (dask.dataframe.DataFrame property)
indices() (in module dask.array)
info() (dask.dataframe.DataFrame method)
inline() (in module dask.optimization)
inline_functions() (in module dask.optimization)
insert() (in module dask.array)
instantiate() (distributed.Nanny method)
inv() (in module dask.array.linalg)
invert (in module dask.array)
irfft() (in module dask.array.fft)
irfft2() (in module dask.array.fft)
irfftn() (in module dask.array.fft)
is_dask_collection() (in module dask)
is_set() (distributed.Event method)
isclose() (in module dask.array)
iscomplex() (in module dask.array)
isfinite (in module dask.array)
isin() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
isinf (in module dask.array)
isna() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
isnan (in module dask.array)
isneginf (in module dask.array)
isnull() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
isposinf (in module dask.array)
isreal() (in module dask.array)
Item (class in dask.bag)
items() (dask.dataframe.DataFrame method)
(dask.highlevelgraph.HighLevelGraph method)
itemsize (dask.array.Array property)
iteritems() (dask.dataframe.Series method)
iterrows() (dask.dataframe.DataFrame method)
itertuples() (dask.dataframe.DataFrame method)
J
join() (dask.bag.Bag method)
(dask.dataframe.DataFrame method)
K
keys() (dask.highlevelgraph.HighLevelGraph method)
kill() (distributed.Nanny method)
known_divisions (dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
kurt() (dask.dataframe.rolling.Rolling method)
kurtosis() (in module dask.array.stats)
kurtosistest() (in module dask.array.stats)
L
laplace() (in module dask.array.random)
last() (dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
ldexp (in module dask.array)
le() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
less (in module dask.array)
linspace() (in module dask.array)
list_datasets() (distributed.Client method)
loc (dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
local_dir (distributed.Nanny property)
(distributed.Worker property)
LocalCluster (class in distributed.deploy.local)
Lock (class in distributed)
log (in module dask.array)
log10 (in module dask.array)
log1p (in module dask.array)
log2 (in module dask.array)
log_event() (distributed.Client method)
logaddexp (in module dask.array)
logaddexp2 (in module dask.array)
logical_and (in module dask.array)
logical_not (in module dask.array)
logical_or (in module dask.array)
logical_xor (in module dask.array)
logistic() (in module dask.array.random)
lognormal() (in module dask.array.random)
logseries() (in module dask.array.random)
lstsq() (in module dask.array.linalg)
lt() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
lu() (in module dask.array.linalg)
M
make_meta() (in module dask.dataframe.utils)
make_people() (in module dask.datasets)
map() (dask.bag.Bag method)
(dask.dataframe.Series method)
(distributed.Client method)
(in module dask.bag)
map_blocks() (dask.array.Array method)
(in module dask.array)
map_overlap() (dask.array.Array method)
(dask.dataframe.Series method)
(in module dask.array)
,
[1]
(in module dask.array.overlap)
(in module dask.dataframe.rolling)
map_partitions() (dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.bag)
(in module dask.dataframe)
mask() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
masked_array() (in module dask.array.ma)
masked_equal() (in module dask.array.ma)
masked_greater() (in module dask.array.ma)
masked_greater_equal() (in module dask.array.ma)
masked_inside() (in module dask.array.ma)
masked_invalid() (in module dask.array.ma)
masked_less() (in module dask.array.ma)
masked_less_equal() (in module dask.array.ma)
masked_not_equal() (in module dask.array.ma)
masked_outside() (in module dask.array.ma)
masked_values() (in module dask.array.ma)
masked_where() (in module dask.array.ma)
matmul() (in module dask.array)
max() (dask.array.Array method)
(dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.rolling.Rolling method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
maximum (in module dask.array)
mean() (dask.array.Array method)
(dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.rolling.Rolling method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
median() (dask.dataframe.rolling.Rolling method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
melt() (dask.dataframe.DataFrame method)
(in module dask.dataframe.reshape)
memory_monitor() (distributed.Nanny method)
(distributed.Worker method)
memory_usage() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
memory_usage_per_partition() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
merge() (dask.dataframe.DataFrame method)
(dask.dataframe.multi.DataFrame method)
(in module dask.config)
(in module dask.dataframe.multi)
merge_asof() (in module dask.dataframe.multi)
meshgrid() (in module dask.array)
min() (dask.array.Array method)
(dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.rolling.Rolling method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
minimum (in module dask.array)
mod (in module dask.array)
mod() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
mode() (dask.dataframe.DataFrame method)
modf() (in module dask.array)
moment() (dask.array.Array method)
(in module dask.array)
(in module dask.array.stats)
moveaxis() (in module dask.array)
mul() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
multiply (in module dask.array)
N
name (dask.array.Array property)
nan_to_num() (in module dask.array)
nanargmax() (in module dask.array)
nanargmin() (in module dask.array)
nancumprod() (in module dask.array)
nancumsum() (in module dask.array)
nanmax() (in module dask.array)
nanmean() (in module dask.array)
nanmedian() (in module dask.array)
nanmin() (in module dask.array)
Nanny (class in distributed)
nanprod() (in module dask.array)
nanstd() (in module dask.array)
nansum() (in module dask.array)
nanvar() (in module dask.array)
nbytes (dask.array.Array property)
(dask.dataframe.Series property)
nbytes() (distributed.Client method)
ncores() (distributed.Client method)
ndim (dask.array.Array property)
(dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
ne() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
negative (in module dask.array)
negative_binomial() (in module dask.array.random)
next() (distributed.Sub method)
nextafter (in module dask.array)
nlargest() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
noncentral_chisquare() (in module dask.array.random)
noncentral_f() (in module dask.array.random)
nonzero() (dask.array.Array method)
(in module dask.array)
norm() (in module dask.array.linalg)
normal() (in module dask.array.random)
normalize_chunks() (in module dask.array.core)
normalize_collection() (distributed.Client method)
normaltest() (in module dask.array.stats)
not_equal (in module dask.array)
notnull() (dask.dataframe.Series method)
(in module dask.array)
npartitions (dask.array.Array property)
(dask.dataframe.DataFrame property)
nsmallest() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
nthreads() (distributed.Client method)
numblocks (dask.array.Array property)
nunique() (dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
nunique_approx() (dask.dataframe.Series method)
O
ohlc() (dask.dataframe.tseries.resample.Resampler method)
ones() (in module dask.array)
ones_like() (in module dask.array)
optimize() (in module dask)
outer() (in module dask.array)
overlap() (in module dask.array.overlap)
P
pad() (in module dask.array)
pareto() (in module dask.array.random)
parse_bytes() (in module dask.utils)
parse_timedelta() (in module dask.utils)
partitions (dask.array.Array property)
(dask.dataframe.DataFrame property)
percentile() (in module dask.array)
PerformanceWarning
permutation() (in module dask.array.random)
persist() (dask.array.Array method)
(dask.bag.Bag method)
(dask.bag.Item method)
(dask.dataframe.Series method)
(distributed.Client method)
(in module dask)
piecewise() (in module dask.array)
pipe() (dask.dataframe.Series method)
pivot_table() (dask.dataframe.DataFrame method)
(in module dask.dataframe.reshape)
pluck() (dask.bag.Bag method)
poisson() (in module dask.array.random)
pop() (dask.dataframe.DataFrame method)
pow() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
power (in module dask.array)
power() (in module dask.array.random)
power_divergence() (in module dask.array.stats)
PRELOAD_ARGV
dask-scheduler command line option
dask-worker command line option
processing() (distributed.Client method)
prod() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
product() (dask.bag.Bag method)
profile() (distributed.Client method)
Profiler() (in module dask.diagnostics)
progress() (in module dask.distributed)
ProgressBar() (in module dask.diagnostics)
proxy() (distributed.Scheduler method)
ptp() (in module dask.array)
Pub (class in distributed)
,
[1]
publish_dataset() (distributed.Client method)
put() (distributed.Pub method)
,
[1]
(distributed.Queue method)
Python Enhancement Proposals
PEP 465
Q
qr() (in module dask.array.linalg)
qsize() (distributed.Queue method)
quantile() (dask.dataframe.DataFrame method)
(dask.dataframe.rolling.Rolling method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
query() (dask.dataframe.DataFrame method)
Queue (class in distributed)
R
rad2deg (in module dask.array)
radd() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
radians (in module dask.array)
randint() (in module dask.array.random)
random() (in module dask.array.random)
random_sample() (dask.bag.Bag method)
(in module dask.array.random)
random_split() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
range() (in module dask.bag)
ravel() (dask.array.Array method)
(in module dask.array)
rayleigh() (in module dask.array.random)
rdiv() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
read_avro() (in module dask.bag)
read_bytes() (in module dask.bytes)
read_csv() (in module dask.dataframe)
read_fwf() (in module dask.dataframe)
read_hdf() (in module dask.dataframe)
read_json() (in module dask.dataframe)
read_orc() (in module dask.dataframe)
read_parquet() (in module dask.dataframe)
read_sql() (in module dask.dataframe)
read_sql_query() (in module dask.dataframe)
read_sql_table() (in module dask.dataframe)
read_table() (in module dask.dataframe)
read_text() (in module dask.bag)
real (dask.array.Array property)
real() (in module dask.array)
rebalance() (distributed.Client method)
(distributed.Scheduler method)
rechunk() (dask.array.Array method)
(in module dask.array)
reciprocal (in module dask.array)
reduction() (dask.bag.Bag method)
(dask.dataframe.Series method)
(in module dask.array)
reevaluate_occupancy() (distributed.Scheduler method)
refresh() (in module dask.config)
register_chunk_type() (in module dask.array)
register_dataframe_accessor() (in module dask.dataframe.extensions)
register_index_accessor() (in module dask.dataframe.extensions)
register_nanny_plugin() (distributed.Scheduler method)
register_scheduler_plugin() (distributed.Client method)
(distributed.Scheduler method)
register_series_accessor() (in module dask.dataframe.extensions)
register_worker_callbacks() (distributed.Client method)
register_worker_plugin() (distributed.Client method)
(distributed.Scheduler method)
rejoin() (in module distributed)
release() (distributed.Future method)
(distributed.Lock method)
remainder (in module dask.array)
remove() (dask.bag.Bag method)
remove_client() (distributed.Scheduler method)
remove_plugin() (distributed.Scheduler method)
remove_worker() (distributed.Scheduler method)
rename() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
repartition() (dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
repeat() (dask.array.Array method)
(in module dask.array)
replace() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
replicate() (distributed.Client method)
(distributed.Scheduler method)
report() (distributed.Scheduler method)
request_acquire_replicas() (distributed.Scheduler method)
request_remove_replicas() (distributed.Scheduler method)
resample() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
Resampler (class in dask.dataframe.tseries.resample)
reschedule() (distributed.Scheduler method)
reset_index() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
reshape() (dask.array.Array method)
(in module dask.array)
ResourceProfiler() (in module dask.diagnostics)
restart() (distributed.Client method)
(distributed.Scheduler method)
result() (distributed.Future method)
result_type() (in module dask.array)
retire_workers() (distributed.Client method)
(distributed.Scheduler method)
retry() (distributed.Client method)
(distributed.Future method)
RewriteRule() (in module dask.rewrite)
rfft() (in module dask.array.fft)
rfft2() (in module dask.array.fft)
rfftfreq() (in module dask.array.fft)
rfftn() (in module dask.array.fft)
rfloordiv() (dask.dataframe.DataFrame method)
rint (in module dask.array)
rmod() (dask.dataframe.DataFrame method)
rmul() (dask.dataframe.DataFrame method)
roll() (in module dask.array)
rollaxis() (in module dask.array)
rolling() (dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
rot90() (in module dask.array)
round() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
rpow() (dask.dataframe.DataFrame method)
rsub() (dask.dataframe.DataFrame method)
rtruediv() (dask.dataframe.DataFrame method)
RuleSet() (in module dask.rewrite)
run() (distributed.Client method)
run_coroutine() (distributed.Client method)
run_function() (distributed.Scheduler method)
run_on_scheduler() (distributed.Client method)
S
sample() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.bag.random)
scatter() (distributed.Client method)
(distributed.Scheduler method)
SCHEDULER
dask-worker command line option
Scheduler (class in distributed)
scheduler_info() (distributed.Client method)
searchsorted() (in module dask.array)
secede() (in module distributed)
select_dtypes() (dask.dataframe.DataFrame method)
sem() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
send_all() (distributed.Scheduler method)
send_task_to_worker() (distributed.Scheduler method)
Series (class in dask.dataframe)
set() (distributed.Event method)
(distributed.Variable method)
(in module dask.config)
set_fill_value() (in module dask.array.ma)
set_index() (dask.dataframe.DataFrame method)
set_metadata() (distributed.Client method)
sfqr() (in module dask.array.linalg)
shape (dask.array.Array property)
(dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
shift() (dask.dataframe.Series method)
shuffle() (dask.dataframe.DataFrame method)
shutdown() (distributed.Client method)
sign (in module dask.array)
signbit (in module dask.array)
sin (in module dask.array)
sinc() (in module dask.array)
sinh (in module dask.array)
size (dask.array.Array property)
(dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
size() (dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.tseries.resample.Resampler method)
skew() (dask.dataframe.rolling.Rolling method)
(in module dask.array.stats)
skewtest() (in module dask.array.stats)
sliding_window_view() (in module dask.array.lib.stride_tricks)
solve() (in module dask.array.linalg)
solve_triangular() (in module dask.array.linalg)
sort_values() (dask.dataframe.DataFrame method)
sqrt (in module dask.array)
square (in module dask.array)
squeeze() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(in module dask.array)
SSHCluster() (in module dask.distributed)
stack() (in module dask.array)
standard_cauchy() (in module dask.array.random)
standard_exponential() (in module dask.array.random)
standard_gamma() (in module dask.array.random)
standard_normal() (in module dask.array.random)
standard_t() (in module dask.array.random)
starmap() (dask.bag.Bag method)
start() (distributed.Client method)
(distributed.Nanny method)
(distributed.Scheduler method)
start_ipython() (distributed.Client method)
(distributed.Scheduler method)
(distributed.Worker method)
start_ipython_scheduler() (distributed.Client method)
start_ipython_workers() (distributed.Client method)
status (distributed.Future property)
std() (dask.array.Array method)
(dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.rolling.Rolling method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
stimulus_cancel() (distributed.Scheduler method)
stimulus_task_erred() (distributed.Scheduler method)
stimulus_task_finished() (distributed.Scheduler method)
store() (dask.array.Array method)
(in module dask.array)
story() (distributed.Scheduler method)
str (dask.dataframe.Series attribute)
Sub (class in distributed)
sub() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
submit() (distributed.Client method)
subscribe_topic() (distributed.Client method)
subtract (in module dask.array)
sum() (dask.array.Array method)
(dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.rolling.Rolling method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
svd() (in module dask.array.linalg)
svd_compressed() (in module dask.array.linalg)
swapaxes() (dask.array.Array method)
T
tail() (dask.dataframe.DataFrame method)
take() (dask.bag.Bag method)
(in module dask.array)
tan (in module dask.array)
tanh (in module dask.array)
tensordot() (in module dask.array)
tile() (in module dask.array)
timeseries() (in module dask.datasets)
to_avro() (dask.bag.Bag method)
(in module dask.bag.avro)
to_bag() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
to_csv() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.dataframe)
to_dask_array() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
to_dask_dataframe() (dask.array.Array method)
to_dataframe() (dask.bag.Bag method)
(dask.bag.core.Bag method)
to_datetime() (in module dask.dataframe)
to_delayed() (dask.array.Array method)
(dask.bag.Bag method)
(dask.bag.core.Bag method)
(dask.bag.Item method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
to_dict() (dask.highlevelgraph.HighLevelGraph method)
to_frame() (dask.dataframe.Series method)
to_hdf() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.dataframe)
to_hdf5() (dask.array.Array method)
(in module dask.array)
to_html() (dask.dataframe.DataFrame method)
to_json() (dask.dataframe.DataFrame method)
(in module dask.dataframe)
to_npy_stack() (in module dask.array)
to_numeric() (in module dask.dataframe)
to_parquet() (dask.dataframe.DataFrame method)
(in module dask.dataframe)
to_records() (dask.dataframe.DataFrame method)
(in module dask.dataframe)
to_sql() (dask.dataframe.DataFrame method)
(in module dask.dataframe)
to_string() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
to_svg() (dask.array.Array method)
to_textfiles() (dask.bag.Bag method)
(in module dask.bag)
(in module dask.bag.core)
to_tiledb() (dask.array.Array method)
(in module dask.array)
to_timestamp() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
to_zarr() (dask.array.Array method)
(in module dask.array)
topk() (dask.array.Array method)
(dask.bag.Bag method)
(in module dask.array)
trace() (dask.array.Array method)
(in module dask.array)
traceback() (distributed.Future method)
transition() (distributed.Scheduler method)
(distributed.Worker method)
transition_resumed_fetch() (distributed.Worker method)
transition_resumed_missing() (distributed.Worker method)
transition_resumed_waiting() (distributed.Worker method)
transition_story() (distributed.Scheduler method)
transitions() (distributed.Scheduler method)
(distributed.Worker method)
transpose() (dask.array.Array method)
(in module dask.array)
triangular() (in module dask.array.random)
trigger_profile() (distributed.Worker method)
tril() (in module dask.array)
trim_internal() (in module dask.array.overlap)
trim_overlap() (in module dask.array.overlap)
triu() (in module dask.array)
true_divide (in module dask.array)
truediv() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
trunc (in module dask.array)
tsqr() (in module dask.array.linalg)
ttest_1samp() (in module dask.array.stats)
ttest_ind() (in module dask.array.stats)
ttest_rel() (in module dask.array.stats)
type (distributed.Future property)
U
uniform() (in module dask.array.random)
unify_chunks() (in module dask.array.core)
unique() (dask.dataframe.Series method)
(in module dask.array)
unpublish_dataset() (distributed.Client method)
unravel_index() (in module dask.array)
unregister_nanny_plugin() (distributed.Scheduler method)
unregister_worker_plugin() (distributed.Client method)
(distributed.Scheduler method)
unsubscribe_topic() (distributed.Client method)
update() (in module dask.config)
update_data() (distributed.Scheduler method)
update_graph() (distributed.Scheduler method)
upload_file() (distributed.Client method)
V
value_counts() (dask.dataframe.Series method)
values (dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
values() (dask.highlevelgraph.HighLevelGraph method)
var() (dask.array.Array method)
(dask.bag.Bag method)
(dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.rolling.Rolling method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
Variable (class in distributed)
vdot() (in module dask.array)
view() (dask.array.Array method)
vindex (dask.array.Array property)
visualize() (dask.array.Array method)
(dask.bag.Bag method)
(dask.bag.Item method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask)
(in module dask.diagnostics)
vonmises() (in module dask.array.random)
vstack() (in module dask.array)
W
wait() (distributed.Event method)
(in module distributed)
wait_for_workers() (distributed.Client method)
wait_on() (in module dask.graph_manipulation)
wald() (in module dask.array.random)
weibull() (in module dask.array.random)
where() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
who_has() (distributed.Client method)
Worker (class in distributed)
worker_address (distributed.Worker property)
worker_send() (distributed.Scheduler method)
workers_list() (distributed.Scheduler method)
workers_to_close() (distributed.Scheduler method)
write_scheduler_file() (distributed.Client method)
Z
zeros() (in module dask.array)
zeros_like() (in module dask.array)
zip() (in module dask.bag)
zipf() (in module dask.array.random)