Index

A

AbstractDROP (class in dlg.drop) add() (dlg.dropmake.scheduler.Partition method) add_node() (dlg.dropmake.scheduler.KFamilyPartition method) (dlg.dropmake.scheduler.Partition method) add_pgt() (dlg.dropmake.pg_manager.PGManager method) addCMNode() (dlg.manager.rest.CompositeManagerRestServer method) addConsumer() (dlg.drop.AbstractDROP method) addGraphSpec() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) addLink() (in module dlg.graph_loader)

addProducer() (dlg.drop.AbstractDROP method) addStreamingConsumer() (dlg.drop.AbstractDROP method) allDropContents() (in module dlg.droputils) AppDROP (class in dlg.apps.app_base) AppDROPStates (class in dlg.ddap_protocol) append() (dlg.drop.ListAsDict method) apply_config() (in module dlg.dropmake.pg_generator) args (dlg.rpc.ZeroRPCClient.request attribute) ArrayGatherApp (class in dlg.apps.simple) autofill_environment_variables() (dlg.drop.AbstractDROP method) AverageArraysApp (class in dlg.apps.simple)

B

BAD_IMPORT (dlg.runtime.error_management.ErrorCode attribute) BarrierAppDROP (class in dlg.apps.app_base) BASH_COMMAND_FAILED (dlg.runtime.error_management.ErrorCode attribute) BashShellApp (class in dlg.apps.bash_shell_app) BashShellBase (class in dlg.apps.bash_shell_app) Branch (class in dlg.apps.simple)

BranchAppDrop (class in dlg.apps.branch) breadFirstTraverse() (in module dlg.droputils) browse_service() (in module dlg.utils) buffer() (dlg.data.io.DataIO method) buftype (dlg.data.drops.memory.InMemoryDROP property) (dlg.data.drops.memory.SharedMemoryDROP property) build_dag_from_drops() (dlg.dropmake.scheduler.DAGUtil static method)

C

can_add() (dlg.dropmake.scheduler.Partition method) cancel() (dlg.apps.app_base.AppDROP method) (dlg.apps.dynlib.DynlibProcApp method) (dlg.drop.AbstractDROP method) cancelSession() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) CDlgApp (class in dlg.apps.dynlib) CDlgInput (class in dlg.apps.dynlib) CDlgOutput (class in dlg.apps.dynlib) CDlgStreamingInput (class in dlg.apps.dynlib) checksum (dlg.data.drops.data_base.DataDROP property) checksumType (dlg.data.drops.data_base.DataDROP property) ChecksumTypes (class in dlg.ddap_protocol) close() (dlg.data.drops.data_base.DataDROP method) (dlg.data.io.DataIO method) CommentDrop (class in dlg.apps.constructs)

commit() (dlg.drop.AbstractDROP method) completedrop() (dlg.drop.AbstractDROP method) component_meta (dlg.apps.simple.NullBarrierApp attribute) CompositeManager (class in dlg.manager.composite_manager) CompositeManagerRestServer (class in dlg.manager.rest) constrain_func() (dlg.dropmake.scheduler.PSOScheduler method) consumers (dlg.drop.AbstractDROP property) ContainerIpWaiter (class in dlg.apps.dockerapp) CopyApp (class in dlg.apps.simple) copyDirectoryContents() (in module dlg.droputils) copyDropContents() (in module dlg.droputils) CRCApp (class in dlg.apps.crc) CRCStreamApp (class in dlg.apps.crc) createDirIfMissing() (in module dlg.utils) createSession() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method)

D

DAGUtil (class in dlg.dropmake.scheduler) DALiuGEApp (class in dlg.apps.simple) DataDROP (class in dlg.data.drops.data_base) DataDROPError (class in dlg.data.drops.data_base) DataIO (class in dlg.data.io) DataIslandManager (class in dlg.manager.composite_manager) dataURL (dlg.data.drops.data_base.DataDROP property) (dlg.data.drops.data_base.NullDROP property) (dlg.data.drops.directory.DirectoryDROP property) (dlg.data.drops.file.FileDROP property) (dlg.data.drops.memory.InMemoryDROP property) (dlg.data.drops.memory.SharedMemoryDROP property) (dlg.data.drops.ngas.NgasDROP property) (dlg.data.drops.rdbms.RDBMSDrop property) dataWritten() (dlg.apps.app_base.AppDROP method) (dlg.apps.bash_shell_app.StreamingInputBashAppBase method) (dlg.apps.crc.CRCStreamApp method) (dlg.apps.dynlib.DynlibStreamApp method) decrRefCount() (dlg.data.drops.data_base.DataDROP method) delayed() (in module dlg.runtime) delete() (dlg.data.drops.data_base.DataDROP method) (dlg.data.drops.directory.DirectoryDROP method) (dlg.data.drops.file.FileDROP method) (dlg.data.io.DataIO method) (dlg.data.io.NgasIO method) deliver_event() (dlg.manager.node_manager.NodeManagerBase method) deploySession() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) depthFirstTraverse() (in module dlg.droputils) deregister_service() (in module dlg.utils) destroySession() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) DictGatherApp (class in dlg.apps.simple) DirectoryDROP (class in dlg.data.drops.directory) DirectoryIO (class in dlg.data.io) dlg module dlg.apps.app_base module dlg.apps.archiving module dlg.apps.bash_shell_app module dlg.apps.branch module dlg.apps.constructs module dlg.apps.crc module dlg.apps.dockerapp module dlg.apps.dynlib module dlg.apps.mpi module dlg.apps.pyfunc module dlg.apps.scp module dlg.apps.simple module dlg.apps.socket_listener module dlg.data module dlg.data.drops.data_base module dlg.data.drops.directory module dlg.data.drops.file module

dlg.data.drops.json_drop module dlg.data.drops.memory module dlg.data.drops.ngas module dlg.data.drops.rdbms module dlg.data.drops.s3_drop module dlg.data.io module dlg.ddap_protocol module dlg.drop module dlg.dropmake module dlg.dropmake.pg_generator module dlg.dropmake.pg_manager module dlg.dropmake.scheduler module dlg.droputils module dlg.event module dlg.graph_loader module dlg.manager module dlg.manager.client module dlg.manager.composite_manager module dlg.manager.drop_manager module dlg.manager.node_manager module dlg.manager.rest module dlg.manager.session module dlg.rpc module dlg.utils module dlg_session_id (dlg.drop.AbstractDROP property) doc_url (dlg.runtime.error_management.ErrorCode property) DockerApp (class in dlg.apps.dockerapp) DockerPath (class in dlg.apps.dockerapp) DROP_ERROR (dlg.runtime.error_management.ErrorCode attribute) drop_runner (dlg.apps.app_base.AppDROP property) dropCompleted() (dlg.apps.app_base.AppDROP method) (dlg.apps.app_base.InputFiredAppDROP method) (dlg.apps.bash_shell_app.StreamingInputBashAppBase method) (dlg.apps.crc.CRCStreamApp method) (dlg.apps.dynlib.DynlibStreamApp method) DROPFile (class in dlg.droputils) DROPLinkType (class in dlg.ddap_protocol) DROPLogFilter (class in dlg.drop) DROPManager (class in dlg.manager.drop_manager) DROPPhases (class in dlg.ddap_protocol) DropProxy (class in dlg.rpc) DROPRel (class in dlg.ddap_protocol) dropReproComplete() (dlg.drop.AbstractDROP method) DropRunner (class in dlg.apps.app_base) DROPStates (class in dlg.ddap_protocol) DROPWaiterCtx (class in dlg.droputils) DynlibApp (class in dlg.apps.dynlib) DynlibProcApp (class in dlg.apps.dynlib) DynlibStreamApp (class in dlg.apps.dynlib)

E

efficiency (dlg.dropmake.scheduler.Schedule property) emit() (dlg.drop.InstanceLogHandler method) ENCODING_ERROR (dlg.runtime.error_management.ErrorCode attribute) EndDROP (class in dlg.data.drops.data_base) endpoint (dlg.manager.node_manager.ZMQPubSubMixIn.subscription attribute) ErrorCode (class in dlg.runtime.error_management) ErrorIO (class in dlg.data.io) ErrorStatusListener (class in dlg.manager.node_manager) escapeQuotes() (in module dlg.utils) Event (class in dlg.event) EventFirer (class in dlg.event) EventHandler (class in dlg.event) EventMixIn (in module dlg.manager.node_manager)

EvtConsumer (class in dlg.droputils) ExclusiveForceDrop (class in dlg.apps.constructs) execStatus (dlg.apps.app_base.AppDROP property) execute() (dlg.apps.app_base.InputFiredAppDROP method) (dlg.apps.branch.BranchAppDrop method) ExecutionMode (class in dlg.ddap_protocol) executionMode (dlg.drop.AbstractDROP property) ExistingProcess (class in dlg.utils) exists() (dlg.apps.app_base.InputFiredAppDROP method) (dlg.data.drops.data_base.DataDROP method) (dlg.data.drops.directory.DirectoryDROP method) (dlg.data.io.DataIO method) (dlg.data.io.NgasLiteIO method) ExternalStoreApp (class in dlg.apps.archiving)

F

FileDROP (class in dlg.data.drops.file) FileIO (class in dlg.data.io) fill() (in module dlg.dropmake.pg_generator)

filter() (dlg.drop.DROPLogFilter method) finished_evt (dlg.manager.node_manager.ZMQPubSubMixIn.subscription attribute) FinishSubprocess fname_to_pipname() (in module dlg.utils)

G

ganttchart_matrix() (dlg.dropmake.scheduler.DAGUtil static method) gather_inputs() (dlg.apps.simple.GenericNpyGatherApp method) GatherDrop (class in dlg.apps.constructs) generate_merkle_data() (dlg.drop.AbstractDROP method) generate_recompute_data() (dlg.apps.dockerapp.DockerApp method) (dlg.apps.dynlib.DynlibApp method) (dlg.apps.dynlib.DynlibStreamApp method) (dlg.apps.mpi.MPIApp method) (dlg.apps.pyfunc.PyFuncApp method) (dlg.drop.AbstractDROP method) generate_repeat_data() (dlg.drop.AbstractDROP method) generate_replicate_comp_data() (dlg.drop.AbstractDROP method) generate_replicate_sci_data() (dlg.drop.AbstractDROP method) generate_replicate_total_data() (dlg.drop.AbstractDROP method) generate_reproduce_data() (dlg.data.drops.file.FileDROP method) (dlg.data.drops.memory.InMemoryDROP method) (dlg.data.drops.ngas.NgasDROP method) (dlg.data.drops.rdbms.RDBMSDrop method) (dlg.drop.AbstractDROP method) generate_rerun_data() (dlg.drop.AbstractDROP method) GenericGatherApp (class in dlg.apps.simple) GenericNpyGatherApp (class in dlg.apps.simple) GenericNpyScatterApp (class in dlg.apps.simple) GenericScatterApp (class in dlg.apps.simple) get_all_ipv4_addresses() (in module dlg.utils) get_builtins() (in module dlg.data.drops.memory) get_consumers_nodes() (dlg.drop.AbstractDROP method) get_dir() (dlg.data.drops.data_base.PathBasedDrop method) get_environment_variable() (dlg.drop.AbstractDROP method) get_environment_variables() (dlg.drop.AbstractDROP method) get_from_subprocess() (in module dlg.apps.dynlib) get_gantt_chart() (dlg.dropmake.pg_manager.PGManager method) get_local_ip_addr() (in module dlg.utils) get_longest_path() (dlg.dropmake.scheduler.DAGUtil static method) get_max_antichains() (dlg.dropmake.scheduler.DAGUtil static method) get_max_dop() (dlg.dropmake.scheduler.DAGUtil static method) get_max_width() (dlg.dropmake.scheduler.DAGUtil static method) get_node_from_json() (dlg.manager.composite_manager.CompositeManager method) get_pgt() (dlg.dropmake.pg_manager.PGManager method) get_schedule_matrices() (dlg.dropmake.pg_manager.PGManager method) get_symbol() (in module dlg.utils) getCMNodes() (dlg.manager.rest.CompositeManagerRestServer method) getCMStatus() (dlg.manager.rest.CompositeManagerRestServer method) getDirName() (dlg.data.io.DirectoryIO method) getDlgDir() (in module dlg.utils) getDlgLogsDir() (in module dlg.utils) getDlgPath() (in module dlg.utils) getDlgPidDir() (in module dlg.utils) getDlgVariable() (in module dlg.utils)

getDlgWorkDir() (in module dlg.utils) getDownstreamObjects() (in module dlg.droputils) getDropData() (dlg.manager.rest.ManagerRestServer method) getFileName() (dlg.data.io.FileIO method) getGraph() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) getGraphReproData() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.composite_manager.DataIslandManager method) (dlg.manager.composite_manager.MasterManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) getGraphSize() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) getGraphStatus() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) getInputArrays() (dlg.apps.simple.AverageArraysApp method) getIO() (dlg.data.drops.data_base.DataDROP method) (dlg.data.drops.data_base.NullDROP method) (dlg.data.drops.directory.DirectoryDROP method) (dlg.data.drops.file.FileDROP method) (dlg.data.drops.memory.InMemoryDROP method) (dlg.data.drops.memory.SharedMemoryDROP method) (dlg.data.drops.ngas.NgasDROP method) (dlg.data.drops.rdbms.RDBMSDrop method) getLeafNodes() (in module dlg.droputils) getLogs() (dlg.data.drops.data_base.DataDROP method) getNodeSessions() (dlg.manager.rest.CompositeManagerRestServer method) getPastSessionIds() (dlg.manager.composite_manager.CompositeManager method) getPastSessions() (dlg.manager.rest.CompositeManagerRestServer method) getSessionDir() (dlg.manager.composite_manager.CompositeManager method) getSessionIds() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) getSessionReproStatus() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.composite_manager.DataIslandManager method) (dlg.manager.composite_manager.MasterManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) getSessionStatus() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) getUpstreamObjects() (in module dlg.droputils) GlobalVariableDrop (class in dlg.apps.constructs) GRAPH_ERROR (dlg.runtime.error_management.ErrorCode attribute) GroupByDrop (class in dlg.apps.constructs) guess_type() (in module dlg.data.drops.memory)

H

handleEvent() (dlg.apps.app_base.AppDROP method) (dlg.drop.AbstractDROP method) handleInterest() (dlg.apps.dockerapp.DockerApp method) (dlg.drop.AbstractDROP method)

has_path() (in module dlg.droputils) HelloWorldApp (class in dlg.apps.simple) humanKey (dlg.drop.AbstractDROP property)

I

import_using_code() (in module dlg.apps.pyfunc) import_using_code_ser() (in module dlg.apps.pyfunc) INCOMPLETE_DROP_SPEC (dlg.runtime.error_management.ErrorCode attribute) incrRefCount() (dlg.data.drops.data_base.DataDROP method) initialize() (dlg.apps.app_base.AppDROP method) (dlg.apps.app_base.BarrierAppDROP method) (dlg.apps.app_base.InputFiredAppDROP method) (dlg.apps.bash_shell_app.StreamingInputBashAppBase method) (dlg.apps.crc.CRCStreamApp method) (dlg.apps.dockerapp.DockerApp method) (dlg.apps.dynlib.DynlibApp method) (dlg.apps.dynlib.DynlibProcApp method) (dlg.apps.dynlib.DynlibStreamApp method) (dlg.apps.mpi.MPIApp method) (dlg.apps.pyfunc.PyFuncApp method) (dlg.apps.scp.ScpApp method) (dlg.apps.simple.ArrayGatherApp method) (dlg.apps.simple.AverageArraysApp method) (dlg.apps.simple.DictGatherApp method) (dlg.apps.simple.ListAppendThrashingApp method) (dlg.apps.simple.PickOne method) (dlg.apps.simple.RandomArrayApp method) (dlg.apps.simple.SimpleBranch method) (dlg.data.drops.directory.DirectoryDROP method) (dlg.data.drops.file.FileDROP method) (dlg.data.drops.memory.InMemoryDROP method) (dlg.data.drops.memory.SharedMemoryDROP method) (dlg.data.drops.ngas.NgasDROP method) (dlg.data.drops.rdbms.RDBMSDrop method) (dlg.drop.AbstractDROP method)

initialize_with_func_code() (dlg.apps.pyfunc.PyFuncApp method) initializeSpecifics() (dlg.manager.rest.CompositeManagerRestServer method) (dlg.manager.rest.ManagerRestServer method) (dlg.manager.rest.MasterManagerRestServer method) (dlg.manager.rest.NMRestServer method) InMemoryDROP (class in dlg.data.drops.memory) InputFiredAppDROP (class in dlg.apps.app_base) inputs (dlg.apps.app_base.AppDROP property) insert() (dlg.data.drops.rdbms.RDBMSDrop method) InstanceLogHandler (class in dlg.drop) INVALID_GRAPH_CONFIGURATION (dlg.runtime.error_management.ErrorCode attribute) InvalidLibrary IOForURL() (in module dlg.data.io) is_exception (dlg.rpc.ZeroRPCClient.response attribute) isabs() (in module dlg.utils) isBeingRead() (dlg.data.drops.data_base.DataDROP method) isCompleted() (dlg.drop.AbstractDROP method) isOpened() (dlg.data.io.DataIO method)

K

KFamilyPartition (class in dlg.dropmake.scheduler)

kill() (dlg.utils.ExistingProcess method)

L

label_schedule() (dlg.dropmake.scheduler.DAGUtil static method) lhs (dlg.ddap_protocol.DROPRel attribute) ListAppendThrashingApp (class in dlg.apps.simple) ListAsDict (class in dlg.drop)

listify() (in module dlg.droputils) load_and_init() (in module dlg.apps.dynlib) loadDropSpecs() (in module dlg.graph_loader) log_level (dlg.drop.AbstractDROP property) LoopDrop (class in dlg.apps.constructs)

M

manage_session_failure() (dlg.manager.node_manager.NodeManagerBase method) ManagerRestServer (class in dlg.manager.rest) map_partitions() (dlg.dropmake.scheduler.Scheduler method) MasterManager (class in dlg.manager.composite_manager) MasterManagerRestServer (class in dlg.manager.rest) MemoryIO (class in dlg.data.io) merge_partitions() (dlg.dropmake.scheduler.Scheduler method) method (dlg.rpc.ZeroRPCClient.request attribute) MinNumPartsScheduler (class in dlg.dropmake.scheduler) MKNDrop (class in dlg.apps.constructs) module dlg dlg.apps.app_base dlg.apps.archiving dlg.apps.bash_shell_app dlg.apps.branch dlg.apps.constructs dlg.apps.crc dlg.apps.dockerapp dlg.apps.dynlib dlg.apps.mpi dlg.apps.pyfunc dlg.apps.scp dlg.apps.simple dlg.apps.socket_listener dlg.data dlg.data.drops.data_base dlg.data.drops.directory dlg.data.drops.file dlg.data.drops.json_drop dlg.data.drops.memory dlg.data.drops.ngas dlg.data.drops.rdbms dlg.data.drops.s3_drop dlg.data.io dlg.ddap_protocol dlg.drop dlg.dropmake dlg.dropmake.pg_generator dlg.dropmake.pg_manager dlg.dropmake.scheduler dlg.droputils dlg.event dlg.graph_loader dlg.manager dlg.manager.client dlg.manager.composite_manager dlg.manager.drop_manager dlg.manager.node_manager dlg.manager.rest dlg.manager.session dlg.rpc dlg.utils

MPIApp (class in dlg.apps.mpi) MySarkarScheduler (class in dlg.dropmake.scheduler)

N

NgasArchivingApp (class in dlg.apps.archiving) NgasDROP (class in dlg.data.drops.ngas) NgasIO (class in dlg.data.io) NgasLiteIO (class in dlg.data.io) NMRestServer (class in dlg.manager.rest) NodeManager (class in dlg.manager.node_manager)

NodeManagerBase (class in dlg.manager.node_manager) NodeManagerDropRunner (class in dlg.manager.node_manager) NodeManagerProcessDropRunner (class in dlg.manager.node_manager) NodeManagerThreadDropRunner (class in dlg.manager.node_manager) NullBarrierApp (class in dlg.apps.simple) NullDROP (class in dlg.data.drops.data_base) NullIO (class in dlg.data.io)

O

object_tracking() (in module dlg.utils) objective_func() (dlg.dropmake.scheduler.PSOScheduler method) oid (dlg.drop.AbstractDROP property) open() (dlg.data.drops.data_base.DataDROP method) (dlg.data.io.DataIO method)

OpenMode (class in dlg.data.io) OUTPUT_DROPPED_CANCELLED (dlg.runtime.error_management.ErrorCode attribute) outputs (dlg.apps.app_base.AppDROP property) override_cannot_add() (dlg.dropmake.scheduler.MinNumPartsScheduler method) (dlg.dropmake.scheduler.MySarkarScheduler method)

P

parent (dlg.drop.AbstractDROP property) parse_pydata() (in module dlg.data.drops.memory) Partition (class in dlg.dropmake.scheduler) partition() (in module dlg.dropmake.pg_generator) partition_dag() (dlg.dropmake.scheduler.MySarkarScheduler method) (dlg.dropmake.scheduler.PSOScheduler method) pastSessions() (dlg.manager.rest.CompositeManagerRestServer method) path (dlg.apps.dockerapp.DockerPath attribute) PATH_ERROR (dlg.runtime.error_management.ErrorCode attribute) PathBasedDrop (class in dlg.data.drops.data_base) persist (dlg.drop.AbstractDROP property) PGManager (class in dlg.dropmake.pg_manager) PGUtil (class in dlg.dropmake.pg_manager) phase (dlg.drop.AbstractDROP property) PickOne (class in dlg.apps.simple) poll() (dlg.utils.ExistingProcess method)

prepare_c_inputs() (in module dlg.apps.dynlib) prepare_c_outputs() (in module dlg.apps.dynlib) prepare_c_ranks() (in module dlg.apps.dynlib) prepare_input_channel() (in module dlg.apps.bash_shell_app) prepare_output_channel() (in module dlg.apps.bash_shell_app) prepare_sql() (in module dlg.utils) probe_max_dop() (dlg.dropmake.scheduler.Partition method) producerFinished() (dlg.drop.AbstractDROP method) producers (dlg.drop.AbstractDROP property) proxy_info (dlg.rpc.DropProxy property) ProxyInfo (class in dlg.rpc) prune_antichains() (dlg.dropmake.scheduler.DAGUtil static method) PSOScheduler (class in dlg.dropmake.scheduler) PyFuncApp (class in dlg.apps.pyfunc) PyMemberApp (class in dlg.apps.pyfunc) PythonObjectDROP (class in dlg.data.drops.memory)

Q

queue (dlg.rpc.ZeroRPCClient.request attribute)

R

RandomArrayApp (class in dlg.apps.simple) RDBMSDrop (class in dlg.data.drops.rdbms) read() (dlg.data.drops.data_base.DataDROP method) (dlg.data.io.DataIO method) reduce_gather_inputs() (dlg.apps.simple.GenericNpyGatherApp method) reduce_partitions() (dlg.dropmake.scheduler.MySarkarScheduler method) register_service() (in module dlg.utils) rel (dlg.ddap_protocol.DROPRel attribute) remove() (dlg.dropmake.scheduler.Partition method) removeCMNode() (dlg.manager.rest.CompositeManagerRestServer method) replace_dataurl_placeholders() (in module dlg.droputils) replace_placeholders() (in module dlg.droputils) replicate() (dlg.manager.composite_manager.CompositeManager method) resource_map() (in module dlg.dropmake.pg_generator)

rhs (dlg.ddap_protocol.DROPRel attribute) RPCClient (in module dlg.rpc) RPCClientBase (class in dlg.rpc) RpcMixIn (class in dlg.manager.node_manager) RPCObject (class in dlg.rpc) RPCServer (in module dlg.rpc) RPCServerBase (class in dlg.rpc) run() (dlg.apps.pyfunc.PyFuncApp method) (in module dlg.apps.dynlib) run_drop() (dlg.apps.app_base.DropRunner method) (dlg.apps.app_base.SyncDropRunner method) (dlg.manager.node_manager.NodeManagerProcessDropRunner method) (dlg.manager.node_manager.NodeManagerThreadDropRunner method) run_on_daemon_thread() (in module dlg.apps.app_base)

S

sanitize_link() (in module dlg.manager.composite_manager) sanitize_paths() (dlg.data.drops.file.FileDROP method) ScatterDrop (class in dlg.apps.constructs) Schedule (class in dlg.dropmake.scheduler) schedule (dlg.dropmake.scheduler.Partition property) schedule_matrix (dlg.dropmake.scheduler.Schedule property) Scheduler (class in dlg.dropmake.scheduler) SchedulerException ScpApp (class in dlg.apps.scp) select() (dlg.data.drops.rdbms.RDBMSDrop method) SESSION_ERROR (dlg.runtime.error_management.ErrorCode attribute) SESSION_MISSING_ERROR (dlg.runtime.error_management.ErrorCode attribute) SESSION_STATE_ERROR (dlg.runtime.error_management.ErrorCode attribute) setCompleted() (dlg.data.drops.file.FileDROP method) (dlg.data.drops.ngas.NgasDROP method) (dlg.drop.AbstractDROP method) setError() (dlg.drop.AbstractDROP method) SharedMemoryDROP (class in dlg.data.drops.memory) SharedMemoryIO (class in dlg.data.io)

SimpleBranch (class in dlg.apps.simple) size (dlg.drop.AbstractDROP property) size() (dlg.data.io.DataIO method) skip() (dlg.apps.app_base.AppDROP method) (dlg.drop.AbstractDROP method) SleepAndCopyApp (class in dlg.apps.simple) SleepApp (class in dlg.apps.simple) SocketListenerApp (class in dlg.apps.socket_listener) status (dlg.drop.AbstractDROP property) store() (dlg.apps.archiving.ExternalStoreApp method) (dlg.apps.archiving.NgasArchivingApp method) streamingConsumers (dlg.drop.AbstractDROP property) StreamingInputBashApp (class in dlg.apps.bash_shell_app) StreamingInputBashAppBase (class in dlg.apps.bash_shell_app) StreamingInputOutputBashApp (class in dlg.apps.bash_shell_app) streamingInputs (dlg.apps.app_base.AppDROP property) StreamingOutputBashApp (class in dlg.apps.bash_shell_app) SubGraphDrop (class in dlg.apps.constructs) subscribe() (dlg.event.EventFirer method) SyncDropRunner (class in dlg.apps.app_base)

T

terminate() (dlg.utils.ExistingProcess method) timed_import() (in module dlg.utils)

to_externally_contactable_host() (in module dlg.utils) total_dir_size() (in module dlg.data.io) truncateUidToKey() (in module dlg.utils)

U

uid (dlg.drop.AbstractDROP property) unroll() (in module dlg.dropmake.pg_generator)

unsubscribe() (dlg.event.EventFirer method) UrlRetrieveApp (class in dlg.apps.simple)

V

value (dlg.rpc.ZeroRPCClient.response attribute)

vstack_mat() (dlg.dropmake.pg_manager.PGUtil static method)

W

wait() (dlg.utils.ExistingProcess method) workload (dlg.dropmake.scheduler.Schedule property) write() (dlg.data.drops.data_base.DataDROP method) (dlg.data.io.DataIO method)

write_results() (dlg.apps.simple.Branch method) writeData() (dlg.apps.simple.PickOne method)

Z

ZeroRPCClient (class in dlg.rpc) ZeroRPCClient.request (class in dlg.rpc) ZeroRPCClient.response (class in dlg.rpc) ZeroRPCServer (class in dlg.rpc)

ZlibUncompressedStream (class in dlg.utils) zmq_safe() (in module dlg.utils) ZMQPubSubMixIn (class in dlg.manager.node_manager) ZMQPubSubMixIn.subscription (class in dlg.manager.node_manager)