Index

_

_compute_part() (in module bndl.compute.dataset)

A

Accumulator (class in bndl.compute.accumulate) accumulator() (bndl.compute.context.ComputeContext method) aggregate() (bndl.compute.dataset.Dataset method) aggregate_by_key() (bndl.compute.dataset.Dataset method)

allow_all_workers() (bndl.compute.dataset.Dataset method) array (bndl.compute.dense.arrays attribute) arrays (class in bndl.compute.dense) attempts (in module bndl.execute) await_workers() (bndl.execute.context.ExecutionContext method)

B

BarrierTask (class in bndl.compute.dataset) block_size_mb (in module bndl.compute.shuffle) bndl.compute (module) bndl.compute.accumulate (module) bndl.compute.broadcast (module) bndl.compute.context (module) bndl.execute (module) bndl.execute.context (module) bndl.execute.exceptions (module) bndl.execute.job (module) bndl.execute.profile (module)

bndl.execute.scheduler (module) bndl.execute.worker (module) bndl.net (module) bndl.net.connection (module) bndl.net.messages (module) bndl.rmi (module) bndl.rmi.exceptions (module) bndl.rmi.messages (module) bndl.util (module) broadcast() (bndl.compute.context.ComputeContext method) (in module bndl.compute.broadcast)

C

cache() (bndl.compute.dataset.Dataset method) cancel() (bndl.execute.job.Task method) CartesianProductDataset (class in bndl.compute.dataset) collect() (bndl.compute.dataset.Dataset method) collect_as_files() (bndl.compute.dataset.Dataset method) collect_as_json() (bndl.compute.dataset.Dataset method) collect_as_map() (bndl.compute.dataset.Dataset method) collect_as_pickles() (bndl.compute.dataset.Dataset method) collect_as_set() (bndl.compute.dataset.Dataset method) collection() (bndl.compute.context.ComputeContext method) combine() (bndl.compute.dataset.Dataset method)

combine_by_key() (bndl.compute.dataset.Dataset method) ComputeContext (class in bndl.compute.context) ComputePartitionTask (class in bndl.compute.dataset) concat() (bndl.compute.dataset.Dataset method) concurrency (in module bndl.execute) Connection (class in bndl.net.connection) count() (bndl.compute.dataset.Dataset method) count_by_value() (bndl.compute.dataset.Dataset method) count_distinct() (bndl.compute.dataset.Dataset method) count_distinct_approx() (bndl.compute.dataset.Dataset method) cpu_profiling (bndl.execute.context.ExecutionContext attribute) CpuProfiling (class in bndl.execute.profile)

D

Dataset (class in bndl.compute.dataset) default_pcount (bndl.compute.context.ComputeContext attribute) dense (bndl.compute.context.ComputeContext attribute) DependenciesFailed

Disconnect (class in bndl.net.messages) Discovered (class in bndl.net.messages) distinct() (bndl.compute.dataset.Dataset method) done (bndl.execute.job.Task attribute)

E

empty (bndl.compute.dense.arrays attribute) exception() (bndl.execute.job.Task method) execute() (bndl.execute.context.ExecutionContext method) (bndl.execute.job.Task method)

executed_on_last() (bndl.execute.job.Task method) ExecutionContext (class in bndl.execute.context)

F

FailedDependency files() (bndl.compute.context.ComputeContext method) filter() (bndl.compute.dataset.Dataset method) filter_bykey() (bndl.compute.dataset.Dataset method)

filter_byvalue() (bndl.compute.dataset.Dataset method) filter_ip_addresses (in module bndl.net.connection) first() (bndl.compute.dataset.Dataset method) flatmap() (bndl.compute.dataset.Dataset method) flatmap_values() (bndl.compute.dataset.Dataset method)

G

gethostbyname (in module bndl.net.connection) getlocalhostname (in module bndl.net.connection)

glom() (bndl.compute.dataset.Dataset method) group_by() (bndl.compute.dataset.Dataset method) group_by_key() (bndl.compute.dataset.Dataset method)

H

Hello (class in bndl.net.messages)

histogram() (bndl.compute.dataset.Dataset method)

I

icollect() (bndl.compute.dataset.Dataset method) Invocation (class in bndl.rmi.node)

InvocationException itake() (bndl.compute.dataset.Dataset method)

J

Job (class in bndl.execute.job)

join() (bndl.compute.dataset.Dataset method)

K

key_by() (bndl.compute.dataset.Dataset method) key_by_id() (bndl.compute.dataset.Dataset method)

key_by_idx() (bndl.compute.dataset.Dataset method) keys() (bndl.compute.dataset.Dataset method)

L

listen_addresses (in module bndl.net)

locality() (bndl.compute.dataset.Partition method) (bndl.execute.job.Task method)

M

map() (bndl.compute.dataset.Dataset method) map_keys() (bndl.compute.dataset.Dataset method) map_partitions() (bndl.compute.dataset.Dataset method) map_partitions_with_index() (bndl.compute.dataset.Dataset method) map_partitions_with_part() (bndl.compute.dataset.Dataset method) map_values() (bndl.compute.dataset.Dataset method) mark_done() (bndl.execute.job.Task method) mark_failed() (bndl.execute.job.Task method) mask_partitions() (bndl.compute.dataset.Dataset method)

max() (bndl.compute.dataset.Dataset method) max_block_size (in module bndl.compute.broadcast) max_mem_pct (in module bndl.compute.shuffle) mean() (bndl.compute.dataset.Dataset method) memory_profiling (bndl.execute.context.ExecutionContext attribute) MemoryProfiling (class in bndl.execute.profile) min() (bndl.compute.dataset.Dataset method) min_block_size (in module bndl.compute.broadcast) mvstats() (bndl.compute.dataset.Dataset method)

N

nlargest() (bndl.compute.dataset.Dataset method) nlargest_by_key() (bndl.compute.dataset.Dataset method)

NotConnected nsmallest() (bndl.compute.dataset.Dataset method) nsmallest_by_key() (bndl.compute.dataset.Dataset method)

O

ones (bndl.compute.dense.arrays attribute)

P

Partition (class in bndl.compute.dataset) Ping (class in bndl.net.messages) pipe() (bndl.compute.dataset.Dataset method) pluck() (bndl.compute.dataset.Dataset method) pluck_values() (bndl.compute.dataset.Dataset method)

Pong (class in bndl.net.messages) print_stats() (bndl.execute.profile.CpuProfiling method) print_top() (bndl.execute.profile.MemoryProfiling method) Python Enhancement Proposals PEP 484

R

random (bndl.compute.dense.arrays attribute) range (bndl.compute.dense.arrays attribute) range() (bndl.compute.context.ComputeContext method) recv() (bndl.net.connection.Connection method) reduce() (bndl.compute.dataset.Dataset method) reduce_by_key() (bndl.compute.dataset.Dataset method) release() (bndl.execute.job.Task method) Request (class in bndl.rmi.messages)

require_local_workers() (bndl.compute.dataset.Dataset method) require_workers() (bndl.compute.dataset.Dataset method) Response (class in bndl.rmi.messages) result() (bndl.execute.job.Task method) RMINode (class in bndl.rmi.node) RMIPeerNode (class in bndl.rmi.node) RmiTask (class in bndl.execute.job) root_exc() (in module bndl.rmi.exceptions)

S

sample() (bndl.compute.dataset.Dataset method) Scheduler (class in bndl.execute.scheduler) seeds (in module bndl.net) send() (bndl.net.connection.Connection method) set_executing() (bndl.execute.job.Task method) shuffle() (bndl.compute.dataset.Dataset method) sort() (bndl.compute.dataset.Dataset method) starfilter() (bndl.compute.dataset.Dataset method)

starmap() (bndl.compute.dataset.Dataset method) start() (bndl.execute.profile.CpuProfiling method) (bndl.execute.profile.MemoryProfiling method) started (bndl.execute.job.Task attribute) stats() (bndl.compute.dataset.Dataset method) stop() (bndl.execute.profile.CpuProfiling method) (bndl.execute.profile.MemoryProfiling method) sum() (bndl.compute.dataset.Dataset method)

T

take() (bndl.compute.dataset.Dataset method) take_sample() (bndl.compute.dataset.Dataset method) Task (class in bndl.execute.job) task_done() (bndl.execute.scheduler.Scheduler method)

TaskCancelled TransformingDataset (class in bndl.compute.dataset) tree_aggregate() (bndl.compute.dataset.Dataset method) tree_combine() (bndl.compute.dataset.Dataset method) tree_reduce() (bndl.compute.dataset.Dataset method)

U

union() (bndl.compute.dataset.Dataset method)

UnionDataset (class in bndl.compute.dataset) urlparse() (in module bndl.net.connection)

V

values() (bndl.compute.dataset.Dataset method)

W

with_timeout() (bndl.rmi.node.Invocation method) with_value() (bndl.compute.dataset.Dataset method)

worker_count (bndl.execute.context.ExecutionContext attribute) workers (bndl.execute.context.ExecutionContext attribute)

Z

zeros (bndl.compute.dense.arrays attribute)

zip() (bndl.compute.dataset.Dataset method) zip_partitions() (bndl.compute.dataset.Dataset method)