Dask.distributed
1.14.3
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
Related Work
Additional Features
Local Cluster
EC2 Startup Script
Web Interface
Joblib Integration
IPython Integration
Publish Datasets
Data Streams with Queues
Launch Tasks from Tasks
Adaptive Deployments
Submitting Applications
Developer Documentation
Development Guidelines
Foundations
Journey of a Task
Protocol
Scheduler Plugins
Dask.distributed
Docs
»
Index
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
L
|
M
|
N
|
P
|
R
|
S
|
T
|
U
|
W
A
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.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)
change_worker_cores() (distributed.scheduler.Scheduler method)
cleanup() (distributed.scheduler.Scheduler method)
clear_data_from_workers() (distributed.scheduler.Scheduler method)
Client (class in distributed.client)
client_releases_keys() (distributed.scheduler.Scheduler method)
close() (distributed.deploy.local.LocalCluster method)
(distributed.scheduler.Scheduler method)
close_streams() (distributed.scheduler.Scheduler method)
coerce_address() (distributed.scheduler.Scheduler method)
CompatibleExecutor (class in distributed.client)
compute() (distributed.client.Client method)
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
ensure_occupied() (distributed.scheduler.Scheduler method)
ensure_occupied_queue() (distributed.scheduler.Scheduler method)
ensure_occupied_stacks() (distributed.scheduler.Scheduler method)
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_versions() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
H
handle_messages() (distributed.scheduler.Scheduler method)
handle_queues() (distributed.scheduler.Scheduler method)
has_what() (distributed.client.Client method)
I
identity() (distributed.scheduler.Scheduler method)
issaturated() (distributed.scheduler.Scheduler method)
L
list_datasets() (distributed.client.Client method)
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
persist() (distributed.client.Client method)
processing() (distributed.client.Client method)
progress() (in module distributed.diagnostics)
publish_dataset() (distributed.client.Client method)
R
read() (in module distributed.core)
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.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)
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.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)
steal_time_ratio() (distributed.scheduler.Scheduler 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_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)
W
wait() (in module distributed.client)
who_has() (distributed.client.Client method)
work_steal() (distributed.scheduler.Scheduler method)
Worker (class in distributed.worker)
worker_stream() (distributed.scheduler.Scheduler method)
workers_list() (distributed.scheduler.Scheduler method)
write() (in module distributed.core)