Index

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

---

_

__iter__() (disco.func.InputStream method)

A

add() (disco.func.OutputStream method)

B

blacklist() (disco.core.Disco method) blobs() (disco.ddfs.DDFS method)

C

chain_reader() (in module disco.func) clean() (disco.core.Disco method) combiner() (in module disco.func) CommError

conjunctive normal form copy_entry (C function) csvrecordparse() (in module discodex.mapreduce.parsers)

D

data (C member) data_err() (in module disco.util) DataError DataSet (class in discodex.objects) DDFS (class in disco.ddfs) DDFS_BLOB_REPLICAS DDFS_GET_MAX DDFS_PUT_MAX DDFS_PUT_PORT DDFS_ROOT DDFS_TAG_MIN_REPLICAS DDFS_TAG_REPLICAS ddfscli (module) default_partition() (in module disco.func) DefaultDict (class in disco.util) delete() (disco.ddfs.DDFS method) die (C function) Disco (class in disco.core) disco master disco.core (module) disco.ddfs (module) disco.error (module) disco.func (module) disco.modutil (module) disco.node.worker (module) disco.schemes (module) disco.schemes.scheme_dfs (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.util (module) DISCO_DATA DISCO_DEBUG DISCO_ERLANG DISCO_EVENTS DISCO_FLAGS DISCO_GC_AFTER DISCO_HOME DISCO_HTTPD DISCO_LOG_DIR

DISCO_MASTER_CONFIG DISCO_MASTER_HOME DISCO_MASTER_HOST DISCO_MASTER_ROOT DISCO_NAME DISCO_PID_DIR DISCO_PORT DISCO_PROXY DISCO_PROXY_ENABLED DISCO_PROXY_PORT DISCO_ROOT DISCO_SCHEDULER DISCO_SCHEDULER_ALPHA DISCO_SORT_BUFFER_SIZE DISCO_TEST_HOST DISCO_TEST_PORT DISCO_USER DISCO_WORKER DISCO_WWW_ROOT discocli (module) DiscoDB (class in discodb) discodb (module) discodex.mapreduce (module) discodex.mapreduce.balancers (module) discodex.mapreduce.demuxers (module) discodex.mapreduce.func (module) discodex.mapreduce.metakeyers (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 dump (discodb.DiscoDB attribute) dump() (discodb.MetaDB method) dumps (discodb.DiscoDB attribute) dxmalloc (C function)

E

enumfieldparse() (in module discodex.mapreduce.parsers) environment variable DDFS_BLOB_REPLICAS DDFS_GET_MAX DDFS_PUT_MAX DDFS_PUT_PORT DDFS_ROOT DDFS_TAG_MIN_REPLICAS DDFS_TAG_REPLICAS DISCODEX_DISCO_MASTER, [1] DISCODEX_HOME DISCODEX_HTTP_HOST DISCODEX_HTTP_PORT DISCODEX_INDEX_PREFIX DISCODEX_PURGE_FILE, [1] DISCO_DATA DISCO_DEBUG DISCO_ERLANG DISCO_EVENTS DISCO_FLAGS DISCO_GC_AFTER DISCO_HOME DISCO_HTTPD DISCO_LOG_DIR DISCO_MASTER_CONFIG DISCO_MASTER_HOME DISCO_MASTER_HOST DISCO_MASTER_ROOT DISCO_NAME DISCO_PID_DIR DISCO_PORT DISCO_PROXY DISCO_PROXY_ENABLED DISCO_PROXY_PORT DISCO_ROOT DISCO_SCHEDULER DISCO_SCHEDULER_ALPHA DISCO_SORT_BUFFER_SIZE DISCO_TEST_HOST DISCO_TEST_PORT DISCO_USER DISCO_WORKER DISCO_WWW_ROOT

err() (in module disco.util) events() (disco.core.Disco method) exists() (disco.ddfs.DDFS method) external() (in module disco.util)

F

find_modules() (in module disco.modutil)

G

get() (disco.ddfs.DDFS method) (in module disco.node.worker)

I

ichunk immutable index Index (class in discodex.objects) Indexer (class in discodex.mapreduce) init() (in module disco.func) input_stream() (in module disco.func) (in module disco.schemes.scheme_dfs) (in module disco.schemes.scheme_disco) (in module disco.schemes.scheme_file) (in module disco.schemes.scheme_http) (in module disco.schemes.scheme_raw)

InputStream (class in disco.func) inverteddemux() (in module discodex.mapreduce.demuxers) invertediddemux() (in module discodex.mapreduce.demuxers) items (discodb.DiscoDB attribute) items() (discodb.MetaDB method) iterdemux() (in module discodex.mapreduce.demuxers)

J

job Job (class in disco.core) job functions JobDict (class in disco.core) JobError

jobinfo() (disco.core.Disco method) joblist() (disco.core.Disco method) jobname() (in module disco.util) jobspec() (disco.core.Disco method)

K

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

kvgroup() (in module discodb)

L

len (C member) list() (disco.ddfs.DDFS method) load() (discodb.DiscoDB static method)

loads() (discodb.DiscoDB static method) locate_modules() (in module disco.modutil)

M

make_range_partition() (in module disco.func) map() (in module disco.func) map_input_stream() (in module disco.func) map_line_reader() (in module disco.func) map_output_stream() (in module disco.func) master (disco.error.JobError attribute) MetaDB (class in discodb)

metaindex MetaIndexer (class in discodex.mapreduce) MetaSet (class in discodex.objects) ModUtilImportError msg (disco.error.JobError attribute) msg() (in module disco.util)

N

name (disco.error.JobError attribute) namedfielddemux() (in module discodex.mapreduce.demuxers) nchunksbalance() (in module discodex.mapreduce.balancers) netstr_reader() (in module disco.func) netstr_writer() (in module disco.func) netstrparse() (in module discodex.mapreduce.parsers)

new_job() (disco.core.Disco method) nodeinfo() (disco.core.Disco method) nodemux() (in module discodex.mapreduce.demuxers) nop_reduce() (in module disco.func) noparse() (in module discodex.mapreduce.parsers)

O

object_reader() (in module disco.func) object_writer() (in module disco.func) oob_get() (disco.core.Disco method) oob_list() (disco.core.Disco method)

output_stream() (in module disco.func) OutputStream (class in disco.func)

P

p_entry (C type) pack() (disco.core.JobDict method) Params (class in disco.core) parse_dir() (in module disco.util) parse_function() (in module disco.modutil) partition() (in module disco.func) partitioning persistent

prefixkeyer() (in module discodex.mapreduce.metakeyers) profile_stats() (disco.core.Disco method) pure function purge() (disco.core.Disco method) push() (disco.ddfs.DDFS method) put() (disco.ddfs.DDFS method) (in module disco.node.worker)

Q

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

query() (discodb.MetaDB method)

R

rawparse() (in module discodex.mapreduce.parsers) re_reader() (in module disco.func) read() (disco.func.InputStream method) read_kv (C function) read_parameters (C function) Record (class in discodex.mapreduce) recordparse() (in module discodex.mapreduce.parsers) reduce() (in module disco.func)

reduce_input_stream() (in module disco.func) reduce_output_stream() (in module disco.func) request() (disco.core.Disco method) result_iterator() (in module disco.core) results() (disco.core.Disco method) roundrobinbalance() (in module discodex.mapreduce.balancers) run() (disco.core.Job method)

S

sze (C member)

T

tag() (disco.ddfs.DDFS method) task this_host() (in module disco.node.worker) this_inputs() (in module disco.node.worker)

this_master() (in module disco.node.worker) this_partition() (in module disco.node.worker)

U

unpack() (disco.core.JobDict class method)

V

values (discodb.DiscoDB attribute) values() (discodb.MetaDB method)

W

wait() (disco.core.Disco method) walk() (disco.ddfs.DDFS method) whitelist() (disco.core.Disco method) wordparse() (in module discodex.mapreduce.parsers) wrap() (discodb.Q class method)

write() (disco.func.OutputStream method) write_kv (C function) write_num_prefix (C function)