Index

A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | R | S | T | U | W | Z

A

add() (disco.worker.classic.func.OutputStream method)
attrs() (disco.ddfs.DDFS method)

B

bin (disco.worker.Worker attribute)
blacklist() (disco.core.Disco method)
blob
blobs() (disco.ddfs.DDFS method)

C

chain_reader() (in module disco.worker.classic.func)
chunk() (disco.ddfs.DDFS method)
classic_iterator() (in module disco.core)
clean() (disco.core.Disco method)
client
close() (disco.worker.classic.func.OutputStream method)
combiner() (in module disco.worker.classic.func)
CommError
copy_entry (C function)

D

data locality
data_err() (in module disco.util)
DataError
DDFS
(class in disco.ddfs)
DDFS_DATA, [1], [2], [3], [4]
DDFS_PUT_PORT
ddfscli (module)
default_partition() (in module disco.worker.classic.func)
defaults() (disco.worker.Worker method)
delattr() (disco.ddfs.DDFS method)
delete() (disco.ddfs.DDFS method)
die (C function)
Disco (class in disco.core)
disco (module)
disco.core (module)
disco.ddfs (module)
disco.error (module)
disco.job (module)
disco.schemes (module)
disco.schemes.scheme_disco (module)
disco.schemes.scheme_discodb (module)
disco.schemes.scheme_file (module)
disco.schemes.scheme_http (module)
disco.schemes.scheme_raw (module)
disco.settings (module)
disco.task (module)
disco.util (module)
disco.worker (module)
disco.worker.classic (module)
disco.worker.classic.external (module)
disco.worker.classic.func (module)
disco.worker.classic.modutil (module)
disco.worker.classic.worker (module)
DISCO_DATA
DISCO_EVENTS, [1], [2]
DISCO_HOME, [1], [2]
disco_input_stream() (in module disco.worker.classic.func)
DISCO_JOB_OWNER
DISCO_LOG_DIR, [1]
DISCO_MASTER_HOME
DISCO_MASTER_HOST, [1], [2]
disco_output_stream() (in module disco.worker.classic.func)
DISCO_PORT, [1], [2]
DISCO_PROXY, [1]
DISCO_ROOT
DISCO_ROTATE_LOG
discocli (module)
DiscoError
dumps() (disco.job.JobPack method)
dxmalloc (C function)

E

environment variable
DDFS_BLOB_REPLICAS
DDFS_DATA, [1], [2], [3], [4], [5]
DDFS_GC_INITIAL_WAIT
DDFS_GET_MAX
DDFS_PARANOID_DELETE
DDFS_PUT_MAX
DDFS_PUT_PORT, [1]
DDFS_READ_TOKEN
DDFS_ROOT
DDFS_TAG_MIN_REPLICAS
DDFS_TAG_REPLICAS
DDFS_WRITE_TOKEN
DISCO_DATA, [1]
DISCO_DEBUG
DISCO_ERLANG
DISCO_EVENTS, [1], [2], [3]
DISCO_FLAGS
DISCO_GC_AFTER
DISCO_HOME, [1], [2], [3]
DISCO_HTTPD
DISCO_JOB_OWNER, [1]
DISCO_LOG_DIR, [1], [2]
DISCO_MASTER_CONFIG
DISCO_MASTER_HOME, [1]
DISCO_MASTER_HOST, [1], [2], [3]
DISCO_MASTER_ROOT
DISCO_NAME
DISCO_PID_DIR
DISCO_PORT, [1], [2], [3]
DISCO_PROXY, [1], [2]
DISCO_PROXY_ENABLED
DISCO_PROXY_PORT
DISCO_ROOT, [1]
DISCO_ROTATE_LOG, [1]
DISCO_SCHEDULER
DISCO_SCHEDULER_ALPHA
DISCO_TEST_DISCODB
DISCO_TEST_HOST
DISCO_TEST_PORT
DISCO_USER
DISCO_WORKER_MAX_MEM
DISCO_WWW_ROOT
PATH
Erlang
err() (in module disco.util)
events() (disco.core.Disco method)
exists() (disco.ddfs.DDFS method)

F

file (disco.worker.Output attribute)
find_modules() (in module disco.worker.classic.modutil)

G

garbage collection (GC)
get() (disco.ddfs.DDFS method)
(disco.task.Task method)
(in module disco.worker.classic.worker)
getattr() (disco.ddfs.DDFS method)
getitem() (disco.worker.Worker method)
gzip_line_reader() (in module disco.worker.classic.func)
gzip_reader() (in module disco.worker.classic.func)

H

host (disco.task.Task attribute)

I

immutable
init() (in module disco.worker.classic.func)
Input (class in disco.worker)
input (jobdict attribute)
input() (disco.worker.Worker method)
input_stream() (in module disco.schemes.scheme_disco)
(in module disco.schemes.scheme_file)
(in module disco.schemes.scheme_http)
(in module disco.schemes.scheme_raw)
(in module disco.worker.classic.func)
InputStream (class in disco.worker.classic.func)

J

job
Job (class in disco.job)
job (disco.error.JobError attribute)
job dict
job functions
job home
job pack
jobdata (disco.job.JobPack attribute)
jobdata() (in module disco.task)
jobdict (disco.job.JobPack attribute)
jobdict() (disco.worker.Worker method)
jobenvs (disco.job.JobPack attribute)
jobenvs() (disco.worker.Worker method)
JobError
jobhome (disco.job.JobPack attribute)
jobhome() (disco.worker.Worker method)
jobinfo() (disco.core.Disco method)
joblist() (disco.core.Disco method)
jobname (disco.task.Task attribute)
jobname() (in module disco.util)
JobPack (class in disco.job)
jobpack() (disco.core.Disco method)
jobzip() (disco.worker.Worker method)
JSON

K

kill() (disco.core.Disco method)
kvgroup() (in module disco.util)

L

list() (disco.ddfs.DDFS method)
load() (disco.job.JobPack class method)
locate_modules() (in module disco.worker.classic.modutil)

M

main() (disco.worker.Worker class method)
make_range_partition() (in module disco.worker.classic.func)
map
map() (in module disco.worker.classic.func)
map_input_stream() (in module disco.worker.classic.func)
map_output_stream() (in module disco.worker.classic.func)
mapreduce
master
(disco.task.Task attribute)
MergedInput (class in disco.worker)
message (disco.error.JobError attribute)
mode (disco.task.Task attribute)
ModUtilImportError
msg() (in module disco.util)

N

new_job() (disco.core.Disco method)
nodeinfo() (disco.core.Disco method)
nop_map() (in module disco.worker.classic.func)
nop_reduce() (in module disco.worker.classic.func)
notifier() (in module disco.worker.classic.func)
nr_reduces (jobdict attribute)

O

old_netstr_reader() (in module disco.worker.classic.func)
oob_get() (disco.core.Disco method)
oob_list() (disco.core.Disco method)
Output (class in disco.worker)
output() (disco.worker.Worker method)
output_stream() (in module disco.worker.classic.func)
OutputStream (class in disco.worker.classic.func)
owner (jobdict attribute)

P

p_entry (C type)
p_entry.data (C member)
p_entry.len (C member)
p_entry.sze (C member)
package() (in module disco.worker.classic.external)
ParallelInput (class in disco.worker)
Params (class in disco.worker.classic.worker)
parse_dir() (in module disco.util)
parse_function() (in module disco.worker.classic.modutil)
partition (disco.worker.Output attribute)
partition() (in module disco.worker.classic.func)
partitioning
PATH
path (disco.worker.classic.func.OutputStream attribute)
(disco.worker.Output attribute)
path() (disco.task.Task method)
pid
prefix (jobdict attribute)
profile_stats() (disco.core.Disco method)
proxy_functions (disco.job.Job attribute)
pull() (disco.ddfs.DDFS method)
purge() (disco.core.Disco method)
push() (disco.ddfs.DDFS method)
put() (disco.ddfs.DDFS method)
(disco.task.Task method)
(in module disco.worker.classic.worker)
Python Enhancement Proposals
PEP 8

R

re-replication
re_reader() (in module disco.worker.classic.func)
read() (disco.worker.classic.func.InputStream method)
read_kv (C function)
read_parameters (C function)
reduce
reduce() (in module disco.worker.classic.func)
reduce2() (in module disco.worker.classic.func)
reduce_input_stream() (in module disco.worker.classic.func)
reduce_output_stream() (in module disco.worker.classic.func)
replica
result_iterator() (in module disco.core)
results() (disco.core.Disco method)
run() (disco.job.Job method)
(disco.worker.Worker method)

S

scheduler (jobdict attribute)
SerialInput (class in disco.worker)
setattr() (disco.ddfs.DDFS method)
slave
SSH
stderr
stdin
stdout
sum_combiner() (in module disco.worker.classic.func)
sum_reduce() (in module disco.worker.classic.func)

T

tag
tag() (disco.ddfs.DDFS method)
task
Task (class in disco.task)
task_input_stream() (in module disco.worker.classic.func)
task_output_stream() (in module disco.worker.classic.func)
taskid (disco.task.Task attribute)
this_host() (in module disco.worker.classic.worker)
this_inputs() (in module disco.worker.classic.worker)
this_master() (in module disco.worker.classic.worker)
this_name() (in module disco.worker.classic.worker)
this_partition() (in module disco.worker.classic.worker)
type (disco.worker.Output attribute)

U

uid (disco.task.Task attribute)
urls() (disco.ddfs.DDFS method)

W

wait() (disco.core.Disco method)
walk() (disco.ddfs.DDFS method)
whitelist() (disco.core.Disco method)
worker
Worker (class in disco.worker)
(class in disco.worker.classic.worker)
(disco.job.Job attribute)
worker (jobdict attribute)
write() (disco.worker.classic.func.OutputStream method)
write_kv (C function)
write_num_prefix (C function)

Z

ZIP
Read the Docs v: 0.4.5
Versions
latest
0.4.5
Downloads
PDF
HTML
Epub
On Read the Docs
Project Home
Builds

Free document hosting provided by Read the Docs.