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
Dask
Getting Started
Install Dask
Setup
Use Cases
Community
Why Dask?
Institutional FAQ
User Interface
User Interfaces
Array
Bag
DataFrame
Delayed
Futures
Machine Learning
Best Practices
API
Scheduling
Scheduling
Distributed Scheduling
Diagnostics
Understanding Performance
Visualize task graphs
Diagnostics (local)
Diagnostics (distributed)
Debugging
Ordering
Help & reference
Development Guidelines
Changelog
Configuration
Configuration Reference
Educational Resources
Presentations On Dask
Dask Cheat Sheet
Comparison to Spark
Opportunistic Caching
Task Graphs
Stages of Computation
Remote Data
GPUs
Citations
Funding
Images and Logos
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 <bokeh_port>
dask-scheduler command line option
dask-worker command line option
--bokeh-prefix <bokeh_prefix>
dask-scheduler command line option
dask-worker command line option
--bokeh-whitelist <bokeh_whitelist>
dask-scheduler command line option
--contact-address <contact_address>
dask-worker command line option
--death-timeout <death_timeout>
dask-worker command line option
--host <host>
dask-scheduler command line option
dask-worker command line option
--hostfile <hostfile>
dask-ssh command line option
--interface <interface>
dask-scheduler command line option
dask-worker command line option
--listen-address <listen_address>
dask-worker command line option
--local-directory <local_directory>
dask-scheduler command line option
dask-worker command line option
--log-directory <log_directory>
dask-ssh command line option
--memory-limit <memory_limit>
dask-ssh command line option
dask-worker command line option
--name <name>
dask-worker command line option
--nanny
dask-worker command line option
--nanny-port <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-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 <nprocs>
dask-ssh command line option
dask-worker command line option
--nthreads <nthreads>
dask-ssh command line option
dask-worker command line option
--pid-file <pid_file>
dask-scheduler command line option
dask-worker command line option
--port <port>
dask-scheduler command line option
--preload <preload>
dask-scheduler command line option
dask-worker command line option
--reconnect
dask-worker command line option
--remote-python <remote_python>
dask-ssh command line option
--resources <resources>
dask-worker command line option
--scheduler <scheduler>
dask-ssh command line option
--scheduler-file <scheduler_file>
dask-scheduler command line option
dask-worker command line option
--scheduler-port <scheduler_port>
dask-ssh command line option
--show
dask-scheduler command line option
--ssh-port <ssh_port>
dask-ssh command line option
--ssh-private-key <ssh_private_key>
dask-ssh command line option
--ssh-username <ssh_username>
dask-ssh command line option
--tls-ca-file <tls_ca_file>
dask-scheduler command line option
dask-worker command line option
--tls-cert <tls_cert>
dask-scheduler command line option
dask-worker command line option
--tls-key <tls_key>
dask-scheduler command line option
dask-worker command line option
--use-xheaders <use_xheaders>
dask-scheduler command line option
--worker-port <worker_port>
dask-ssh command line option
dask-worker command line option
_
__dask_graph__()
__dask_keys__()
__dask_optimize__()
__dask_postcompute__()
__dask_postpersist__()
__dask_scheduler__()
A
abs() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
accumulate() (dask.bag.Bag method)
acquire() (distributed.Lock method)
Adaptive (class in distributed.deploy)
add() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
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.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(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)
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)
apply() (dask.dataframe.DataFrame method)
(dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy 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_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)
asynchronous() (distributed.Client property)
atleast_1d() (in module dask.array)
atleast_2d() (in module dask.array)
atleast_3d() (in module dask.array)
attrs() (dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
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)
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)
categorize() (dask.dataframe.DataFrame method)
cbrt() (in module dask.array)
ceil() (in module dask.array)
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)
clear_divisions() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
Client (class in distributed)
client_heartbeat() (distributed.Scheduler method)
client_releases_keys() (distributed.Scheduler method)
clip() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
close() (distributed.Client method)
(distributed.deploy.local.LocalCluster method)
(distributed.Scheduler method)
close_worker() (distributed.Scheduler method)
Cluster (class in distributed.deploy)
coarsen() (in module dask.array)
,
[1]
coerce_address() (distributed.Scheduler method)
coerce_hostname() (distributed.Scheduler method)
collect() (in module dask.config)
combine() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
combine_first() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
compress() (in module dask.array)
compute() (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)
,
[1]
conj() (in module dask.array)
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.groupby.SeriesGroupBy 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.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.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
(in module dask.array)
cull() (dask.highlevelgraph.HighLevelGraph method)
(in module dask.optimization)
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
dask-scheduler command line option
--bokeh
--bokeh-port <bokeh_port>
--bokeh-prefix <bokeh_prefix>
--bokeh-whitelist <bokeh_whitelist>
--host <host>
--interface <interface>
--local-directory <local_directory>
--no-bokeh
--no-show
--pid-file <pid_file>
--port <port>
--preload <preload>
--scheduler-file <scheduler_file>
--show
--tls-ca-file <tls_ca_file>
--tls-cert <tls_cert>
--tls-key <tls_key>
--use-xheaders <use_xheaders>
PRELOAD_ARGV
dask-ssh command line option
--hostfile <hostfile>
--log-directory <log_directory>
--memory-limit <memory_limit>
--nanny-port <nanny_port>
--nohost
--nprocs <nprocs>
--nthreads <nthreads>
--remote-python <remote_python>
--scheduler <scheduler>
--scheduler-port <scheduler_port>
--ssh-port <ssh_port>
--ssh-private-key <ssh_private_key>
--ssh-username <ssh_username>
--worker-port <worker_port>
HOSTNAMES
dask-worker command line option
--bokeh
--bokeh-port <bokeh_port>
--bokeh-prefix <bokeh_prefix>
--contact-address <contact_address>
--death-timeout <death_timeout>
--host <host>
--interface <interface>
--listen-address <listen_address>
--local-directory <local_directory>
--memory-limit <memory_limit>
--name <name>
--nanny
--nanny-port <nanny_port>
--no-bokeh
--no-nanny
--no-reconnect
--nprocs <nprocs>
--nthreads <nthreads>
--pid-file <pid_file>
--preload <preload>
--reconnect
--resources <resources>
--scheduler-file <scheduler_file>
--tls-ca-file <tls_ca_file>
--tls-cert <tls_cert>
--tls-key <tls_key>
--worker-port <worker_port>
PRELOAD_ARGV
SCHEDULER
dask.bag.random
module
DataFrame (class in dask.dataframe)
DataFrameGroupBy (class in dask.dataframe.groupby)
decide_worker() (distributed.Scheduler method)
deg2rad() (in module dask.array)
degrees() (in module dask.array)
delayed() (in module dask.delayed)
delete() (distributed.Variable 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)
(dask.dataframe.Series method)
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.dataframe.Series property)
dtypes() (dask.dataframe.DataFrame property)
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)
exception() (distributed.Future method)
executor_submit() (distributed.Worker method)
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)
finished() (distributed.Scheduler 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)
,
[1]
(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() (in module dask.array)
,
[1]
(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)
G
gamma() (in module dask.array.random)
gather() (distributed.Client method)
(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_comm_cost() (distributed.Scheduler method)
get_current_task() (distributed.Worker method)
get_dataset() (distributed.Client method)
get_dummies() (in module dask.dataframe.reshape)
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_restrictions() (distributed.Client class method)
get_scheduler_logs() (distributed.Client method)
get_task_duration() (distributed.Scheduler 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() (in module dask.array.gufunc)
gumbel() (in module dask.array.random)
H
handle_long_running() (distributed.Scheduler 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)
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() (in module dask.array)
imread() (in module dask.array.image)
index() (dask.dataframe.DataFrame property)
(dask.dataframe.Series 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)
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)
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)
keyset() (dask.highlevelgraph.HighLevelGraph method)
kill() (distributed.Nanny method)
known_divisions() (dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
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)
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)
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)
(in module dask.array.core)
map_overlap() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
(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.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.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
median() (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)
(in module dask.config)
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.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
minimum() (in module dask.array)
mod() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
mode() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
modf() (in module dask.array)
module
dask.bag.random
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
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)
(distributed.Client method)
ncores() (distributed.Client method)
ndim() (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.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
npartitions() (dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
nsmallest() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
nunique() (dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
(dask.dataframe.tseries.resample.Resampler method)
nunique_approx() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
O
ohlc() (dask.dataframe.tseries.resample.Resampler method)
ones() (in module dask.array)
ones_like() (in module dask.array)
open_files() (in module dask.bytes)
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)
(dask.dataframe.Series property)
percentile() (in module dask.array)
persist() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(distributed.Client method)
(in module dask)
piecewise() (in module dask.array)
pipe() (dask.dataframe.DataFrame method)
(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)
(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.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy 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)
Q
qr() (in module dask.array.linalg)
qsize() (distributed.Queue method)
quantile() (dask.dataframe.DataFrame 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_table() (in module dask.dataframe)
read_table() (in module dask.dataframe)
read_text() (in module dask.bag)
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.DataFrame 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_series_accessor() (in module dask.dataframe.extensions)
register_worker_callbacks() (distributed.Client method)
(distributed.Scheduler method)
rejoin() (in module distributed)
release() (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)
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)
(dask.dataframe.Series method)
rint() (in module dask.array)
rmod() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
rmul() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
roll() (in module dask.array)
rollaxis() (in module dask.array)
rolling() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
round() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
rpow() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
rsub() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
rtruediv() (dask.dataframe.DataFrame method)
(dask.dataframe.Series 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)
scale_down() (distributed.deploy.local.LocalCluster method)
scale_up() (distributed.deploy.local.LocalCluster method)
scatter() (distributed.Client method)
(distributed.Scheduler method)
SCHEDULER
dask-worker command line option
Scheduler (class in distributed)
scheduler_info() (distributed.Client method)
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_task_to_worker() (distributed.Scheduler method)
Series (class in dask.dataframe)
SeriesGroupBy (class in dask.dataframe.groupby)
set() (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.dataframe.DataFrame property)
(dask.dataframe.Series property)
shift() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
shuffle() (dask.dataframe.DataFrame method)
(dask.dataframe.Series 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.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series property)
(dask.dataframe.tseries.resample.Resampler method)
skew() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array.stats)
skewtest() (in module dask.array.stats)
solve() (in module dask.array.linalg)
solve_triangular() (in module dask.array.linalg)
sqrt() (in module dask.array)
square() (in module dask.array)
squeeze() (dask.array.Array method)
(dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
(in module dask.array)
SSHCluster() (in module distributed.deploy.ssh)
stack() (in module dask.array)
,
[1]
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.Scheduler method)
start_ipython() (distributed.Scheduler method)
(distributed.Worker method)
start_ipython_scheduler() (distributed.Client method)
start_ipython_workers() (distributed.Client method)
start_worker() (distributed.deploy.local.LocalCluster method)
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.Series method)
(dask.dataframe.tseries.resample.Resampler method)
(in module dask.array)
stimulus_cancel() (distributed.Scheduler method)
stimulus_missing_data() (distributed.Scheduler method)
stimulus_task_erred() (distributed.Scheduler method)
stimulus_task_finished() (distributed.Scheduler method)
stop_worker() (distributed.deploy.local.LocalCluster method)
store() (dask.array.Array method)
(in module dask.array)
,
[1]
story() (distributed.Scheduler method)
str (dask.dataframe.Series attribute)
str() (dask.bag.Bag property)
Sub (class in distributed)
sub() (dask.dataframe.DataFrame method)
(dask.dataframe.Series method)
submit() (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.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)
(dask.dataframe.Series 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)
(in module dask.dataframe)
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.dataframe.DataFrame method)
(dask.dataframe.Series 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)
(dask.dataframe.Series 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)
(dask.dataframe.Series 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.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)
traceback() (distributed.Future method)
transform() (dask.dataframe.groupby.DataFrameGroupBy method)
(dask.dataframe.groupby.SeriesGroupBy method)
transition() (distributed.Scheduler method)
transition_story() (distributed.Scheduler method)
transitions() (distributed.Scheduler 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)
U
uniform() (in module dask.array.random)
unique() (dask.dataframe.groupby.SeriesGroupBy method)
(dask.dataframe.Series method)
(in module dask.array)
unpublish_dataset() (distributed.Client method)
unravel_index() (in module dask.array)
unzip() (dask.bag.Bag method)
update() (in module dask.config)
update_data() (distributed.Scheduler method)
update_graph() (distributed.Scheduler method)
upload_file() (distributed.Client method)
V
valid_workers() (distributed.Scheduler method)
value_counts() (dask.dataframe.Series method)
values() (dask.dataframe.DataFrame property)
(dask.dataframe.Series property)
(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.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.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() (in module distributed)
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_objective() (distributed.Scheduler method)
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)