Dask.distributed
0+unknown
Getting Started
Install Dask.Distributed
Quickstart
Setup Network
Client
API
Frequently Asked Questions
Build Understanding
Diagnosing Performance
Efficiency
Limitations
Data Locality
Managing Computation
Managing Memory
Related Work
Resilience
Scheduling Policies
Scheduling State
Worker
Work Stealing
Additional Features
Adaptive Deployments
Asynchronous Operation
Configuration
EC2 Startup Script
Local Cluster
IPython Integration
Joblib Integration
Publish Datasets
Data Streams with Queues
Worker Resources
Submitting Applications
Launch Tasks from Tasks
TLS/SSL
Web Interface
Developer Documentation
Changelog
Communications
Development Guidelines
Foundations
Journey of a Task
Protocol
Custom Serialization
Scheduler Plugins
Dask.distributed
Docs
»
Index
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
L
|
M
|
N
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
A
abort() (distributed.comm.Comm method)
Adaptive (class in distributed.deploy)
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)
AioClient (class in distributed.asyncio)
as_completed() (in module distributed.client)
asynchronous (distributed.client.Client attribute)
B
Backend (class in distributed.comm.registry)
broadcast() (distributed.scheduler.Scheduler method)
C
call_stack() (distributed.client.Client method)
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.asyncio.AioClient method)
(distributed.client.Client method)
(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)
Comm (class in distributed.comm)
compute() (distributed.client.Client method)
connect() (in module distributed.comm)
contact_address (distributed.comm.core.Listener attribute)
current() (distributed.client.Client class method)
D
decide_worker() (in module distributed.scheduler)
delete() (distributed.Variable method)
deserialize() (in module distributed.protocol.serialize)
done() (distributed.client.Future method)
E
exception() (distributed.client.Future method)
extra_info (distributed.comm.Comm attribute)
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.asyncio.AioClient method)
(distributed.Queue method)
(distributed.Variable method)
(distributed.client.Client method)
get_address_host() (distributed.comm.registry.Backend method)
(in module distributed.comm)
get_address_host_port() (distributed.comm.registry.Backend method)
get_client() (in module distributed)
get_comm_cost() (distributed.scheduler.Scheduler method)
get_connector() (distributed.comm.registry.Backend method)
get_dataset() (distributed.client.Client method)
get_executor() (distributed.client.Client method)
get_futures_error() (distributed.recreate_exceptions.ReplayExceptionClient method)
get_listener() (distributed.comm.registry.Backend method)
get_local_address_for() (distributed.comm.registry.Backend method)
get_metadata() (distributed.client.Client method)
get_restrictions() (distributed.client.Client class method)
get_scale_up_kwargs() (distributed.deploy.Adaptive method)
get_scheduler_logs() (distributed.client.Client method)
get_task_duration() (distributed.scheduler.Scheduler method)
get_versions() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
get_worker() (in module distributed)
get_worker_logs() (distributed.client.Client method)
get_worker_service_addr() (distributed.scheduler.Scheduler method)
H
handle_client() (distributed.scheduler.Scheduler method)
handle_long_running() (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)
local_address (distributed.comm.Comm attribute)
LocalCluster (class in distributed.deploy.local)
M
map() (distributed.client.Client method)
N
nbytes() (distributed.client.Client method)
ncores() (distributed.client.Client method)
needs_cpu() (distributed.deploy.Adaptive method)
needs_memory() (distributed.deploy.Adaptive method)
normalize_address() (in module distributed.comm)
normalize_collection() (distributed.client.Client method)
P
parse_address() (in module distributed.comm)
peer_address (distributed.comm.Comm attribute)
persist() (distributed.client.Client method)
processing() (distributed.client.Client method)
profile() (distributed.client.Client method)
progress() (in module distributed.diagnostics)
publish_dataset() (distributed.client.Client method)
put() (distributed.Queue method)
Python Enhancement Proposals
PEP 3184
Q
qsize() (distributed.Queue method)
Queue (class in distributed)
R
read() (distributed.comm.Comm method)
rebalance() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
recreate_error_locally() (distributed.recreate_exceptions.ReplayExceptionClient method)
reevaluate_occupancy() (distributed.scheduler.Scheduler method)
register_serialization() (in module distributed.protocol.serialize)
rejoin() (in module distributed)
remove_client() (distributed.scheduler.Scheduler method)
remove_plugin() (distributed.scheduler.Scheduler method)
remove_worker() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
ReplayExceptionClient (class in distributed.recreate_exceptions)
replicate() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
report() (distributed.scheduler.Scheduler method)
reschedule() (distributed.scheduler.Scheduler method)
resolve_address() (distributed.comm.registry.Backend method)
(in module distributed.comm)
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)
secede() (in module distributed)
send_task_to_worker() (distributed.scheduler.Scheduler method)
serialize() (in module distributed.protocol.serialize)
Server (class in distributed.core)
set() (distributed.Variable method)
set_metadata() (distributed.client.Client method)
should_scale_down() (distributed.deploy.Adaptive method)
should_scale_up() (distributed.deploy.Adaptive method)
shutdown() (distributed.asyncio.AioClient method)
(distributed.client.Client method)
stacks() (distributed.client.Client method)
start() (distributed.client.Client method)
(distributed.comm.core.Listener method)
(distributed.scheduler.Scheduler 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)
story() (distributed.scheduler.Scheduler method)
submit() (distributed.client.Client method)
T
traceback() (distributed.client.Future method)
transition() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
transition_story() (distributed.scheduler.Scheduler method)
transitions() (distributed.scheduler.Scheduler method)
U
unparse_address() (in module distributed.comm)
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)
Variable (class in distributed)
W
wait() (in module distributed.client)
who_has() (distributed.client.Client method)
Worker (class in distributed.worker)
worker_client() (in module distributed)
worker_objective() (distributed.scheduler.Scheduler method)
worker_send() (distributed.scheduler.Scheduler method)
workers_list() (distributed.scheduler.Scheduler method)
workers_to_close() (distributed.scheduler.Scheduler method)
write() (distributed.comm.Comm method)