Index

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) Clause (class in discodb.query) clean() (disco.core.Disco method) client

close() (disco.worker.classic.func.OutputStream method) combiner() (in module disco.worker.classic.func) CommError conjunctive normal form copy_entry (C function) csvrecordparse() (in module discodex.mapreduce.parsers)

D

data locality data_err() (in module disco.util) DataError DataSet (class in discodex.objects) DDFS (class in disco.ddfs) DDFS_DATA, [1], [2] 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) DiscoDB (class in discodb) discodb (module) discodb.query (module) discodbparse() (in module discodex.mapreduce.parsers) discodex.mapreduce (module) discodex.mapreduce.balancers (module) discodex.mapreduce.demuxers (module) discodex.mapreduce.parsers (module) discodex.objects (module) discodex.settings (module) DISCODEX_DISCO_MASTER, [1] DISCODEX_HOME DISCODEX_HTTP_HOST DISCODEX_HTTP_PORT DISCODEX_INDEX_PREFIX DISCODEX_PURGE_FILE, [1] discodexcli (module) DiscoError dumps() (disco.job.JobPack method) dxmalloc (C function)

E

enumfieldparse() (in module discodex.mapreduce.parsers) environment variable DDFS_BLOB_REPLICAS DDFS_DATA, [1], [2], [3] 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 DISCODEX_DISCO_MASTER, [1] DISCODEX_HOME DISCODEX_HTTP_HOST DISCODEX_HTTP_PORT DISCODEX_INDEX_PREFIX DISCODEX_PURGE_FILE, [1] 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

get() (disco.ddfs.DDFS method) (disco.task.Task method) (discodb.DiscoDB 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

ichunk immutable index Index (class in discodex.objects) Indexer (class in discodex.mapreduce) 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) inverteddemux() (in module discodex.mapreduce.demuxers) invertediddemux() (in module discodex.mapreduce.demuxers) itemdemux() (in module discodex.mapreduce.demuxers) items() (discodb.DiscoDB method)

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

keys() (discodb.DiscoDB method) kill() (disco.core.Disco method)

kvgroup() (in module disco.util) (in module discodb)

L

list() (disco.ddfs.DDFS method) Literal (class in discodb.query)

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) metaquery() (discodb.DiscoDB method) mode (disco.task.Task attribute) ModUtilImportError msg() (in module disco.util)

N

namedfielddemux() (in module discodex.mapreduce.demuxers) nchunksbalance() (in module discodex.mapreduce.balancers) netstrparse() (in module discodex.mapreduce.parsers) new_job() (disco.core.Disco method) nodeinfo() (disco.core.Disco method) nodemux() (in module discodex.mapreduce.demuxers)

nop_map() (in module disco.worker.classic.func) nop_reduce() (in module disco.worker.classic.func) noparse() (in module discodex.mapreduce.parsers) 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() (discodb.Q class method) (discodb.query.Q class method) 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) peek() (discodb.DiscoDB method) persistent pid prefix (jobdict attribute) profile_stats() (disco.core.Disco method) proxy_functions (disco.job.Job attribute) 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

Q

Q (class in discodb) (class in discodb.query)

query() (discodb.DiscoDB method)

R

rawparse() (in module discodex.mapreduce.parsers) re_reader() (in module disco.worker.classic.func) read() (disco.worker.classic.func.InputStream method) read_kv (C function) read_parameters (C function) Record (class in discodex.mapreduce) recordparse() (in module discodex.mapreduce.parsers) 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) result_iterator() (in module disco.core) results() (disco.core.Disco method) roundrobinbalance() (in module discodex.mapreduce.balancers) 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) unique_values() (discodb.DiscoDB method)

urls() (disco.ddfs.DDFS method)

V

values() (discodb.DiscoDB method)

W

wait() (disco.core.Disco method) walk() (disco.ddfs.DDFS method) whitelist() (disco.core.Disco method) wordparse() (in module discodex.mapreduce.parsers) worker Worker (class in disco.worker) (class in disco.worker.classic.worker) (disco.job.Job attribute)

worker (jobdict attribute) wrap() (discodb.Q class method) (discodb.query.Q class method) write() (disco.worker.classic.func.OutputStream method) write_kv (C function) write_num_prefix (C function)

Z

ZIP