Dask.distributed
0+unknown
Getting Started
Install Dask.Distributed
Quickstart
Setup Network
Client
API
Frequently Asked Questions
Build Understanding
Efficiency
Data Locality
Managing Computation
Managing Memory
Resilience
Scheduling Policies
Scheduling State
Worker
Work Stealing
Limitations
Related Work
Additional Features
Local Cluster
EC2 Startup Script
Web Interface
Joblib Integration
IPython Integration
Publish Datasets
Data Streams with Queues
Shared Futures With Channels
Worker Resources
Launch Tasks from Tasks
Adaptive Deployments
Submitting Applications
Developer Documentation
Development Guidelines
Foundations
Journey of a Task
Protocol
Scheduler Plugins
Changelog
Dask.distributed
Docs
»
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
L
|
M
|
N
|
P
|
R
|
S
|
T
|
U
|
V
|
W
A
abort() (distributed.comm.Comm method)
add_client() (distributed.scheduler.Scheduler method)
add_done_callback() (distributed.client.Future method)
add_keys() (distributed.scheduler.Scheduler method)
add_plugin() (distributed.scheduler.Scheduler method)
add_worker() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
as_completed() (in module distributed.client)
B
broadcast() (distributed.scheduler.Scheduler method)
C
cancel() (distributed.client.Client method)
(distributed.client.Future method)
cancel_key() (distributed.scheduler.Scheduler method)
cancelled() (distributed.client.Future method)
cleanup() (distributed.scheduler.Scheduler method)
Client (class in distributed.client)
client_releases_keys() (distributed.scheduler.Scheduler method)
close() (distributed.comm.Comm method)
(distributed.deploy.local.LocalCluster method)
(distributed.scheduler.Scheduler method)
close_comms() (distributed.scheduler.Scheduler method)
close_worker() (distributed.scheduler.Scheduler method)
closed() (distributed.comm.Comm method)
coerce_address() (distributed.scheduler.Scheduler method)
coerce_hostname() (distributed.scheduler.Scheduler method)
collections_to_dsk() (distributed.client.Client static method)
Comm (class in distributed.comm)
CompatibleExecutor (class in distributed.client)
compute() (distributed.client.Client method)
connect() (in module distributed.comm)
contact_address (distributed.comm.core.Listener attribute)
correct_time_delay() (distributed.scheduler.Scheduler method)
D
decide_worker() (in module distributed.scheduler)
deserialize() (in module distributed.protocol.serialize)
done() (distributed.client.Future method)
E
exception() (distributed.client.Future method)
F
feed() (distributed.scheduler.Scheduler method)
finished() (distributed.scheduler.Scheduler method)
Future (class in distributed.client)
G
gather() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
get() (distributed.client.Client method)
get_dataset() (distributed.client.Client method)
get_restrictions() (distributed.client.Client static method)
get_versions() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
get_worker_service_addr() (distributed.scheduler.Scheduler method)
H
handle_client() (distributed.scheduler.Scheduler method)
handle_worker() (distributed.scheduler.Scheduler method)
has_what() (distributed.client.Client method)
I
identity() (distributed.scheduler.Scheduler method)
L
list_datasets() (distributed.client.Client method)
listen() (in module distributed.comm)
listen_address (distributed.comm.core.Listener attribute)
Listener (class in distributed.comm.core)
LocalCluster (class in distributed.deploy.local)
M
map() (distributed.client.Client method)
(distributed.client.CompatibleExecutor method)
N
nbytes() (distributed.client.Client method)
ncores() (distributed.client.Client method)
normalize_collection() (distributed.client.Client method)
P
peer_address (distributed.comm.Comm attribute)
persist() (distributed.client.Client method)
processing() (distributed.client.Client method)
progress() (in module distributed.diagnostics)
publish_dataset() (distributed.client.Client method)
R
read() (distributed.comm.Comm method)
rebalance() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
register_serialization() (in module distributed.protocol.serialize)
remove_client() (distributed.scheduler.Scheduler method)
remove_plugin() (distributed.scheduler.Scheduler method)
remove_worker() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
replicate() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
report() (distributed.scheduler.Scheduler method)
restart() (distributed.client.Client method)
(distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
result() (distributed.client.Future method)
rpc (class in distributed.core)
run() (distributed.client.Client method)
run_coroutine() (distributed.client.Client method)
run_function() (distributed.scheduler.Scheduler method)
run_on_scheduler() (distributed.client.Client method)
S
scale_down() (distributed.deploy.local.LocalCluster method)
scale_up() (distributed.deploy.local.LocalCluster method)
scatter() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
Scheduler (class in distributed.scheduler)
scheduler_info() (distributed.client.Client method)
SchedulerPlugin (class in distributed.diagnostics.plugin)
send_task_to_worker() (distributed.scheduler.Scheduler method)
serialize() (in module distributed.protocol.serialize)
Server (class in distributed.core)
shutdown() (distributed.client.Client method)
stacks() (distributed.client.Client method)
start() (distributed.client.Client method)
(distributed.comm.core.Listener method)
(distributed.scheduler.Scheduler method)
start_diagnostics_server() (distributed.deploy.local.LocalCluster method)
start_ipython() (distributed.scheduler.Scheduler method)
start_ipython_scheduler() (distributed.client.Client method)
start_ipython_workers() (distributed.client.Client method)
start_worker() (distributed.deploy.local.LocalCluster method)
stimulus_cancel() (distributed.scheduler.Scheduler method)
stimulus_missing_data() (distributed.scheduler.Scheduler method)
stimulus_task_erred() (distributed.scheduler.Scheduler method)
stimulus_task_finished() (distributed.scheduler.Scheduler method)
stop() (distributed.comm.core.Listener method)
stop_worker() (distributed.deploy.local.LocalCluster method)
submit() (distributed.client.Client method)
T
traceback() (distributed.client.Future method)
transition() (distributed.scheduler.Scheduler method)
transition_story() (distributed.scheduler.Scheduler method)
transitions() (distributed.scheduler.Scheduler method)
U
unpublish_dataset() (distributed.client.Client method)
update_data() (distributed.scheduler.Scheduler method)
update_graph() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
upload_file() (distributed.client.Client method)
V
valid_workers() (distributed.scheduler.Scheduler method)
W
wait() (in module distributed.client)
who_has() (distributed.client.Client method)
Worker (class in distributed.worker)
worker_objective() (distributed.scheduler.Scheduler method)
workers_list() (distributed.scheduler.Scheduler method)
workers_to_close() (distributed.scheduler.Scheduler method)
write() (distributed.comm.Comm method)