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) 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

BarrierAppDROP (class in dlg.apps.app_base) 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) 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) 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) 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.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.directorycontainer.DirectoryContainer 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) DirectoryContainer (class in dlg.data.drops.directorycontainer) 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.directorycontainer 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 DockerApp (class in dlg.apps.dockerapp) DockerPath (class in dlg.apps.dockerapp) 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.apps.app_base) 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.apps.app_base.InstanceLogHandler method) EndDROP (class in dlg.data.drops.data_base) endpoint (dlg.manager.node_manager.ZMQPubSubMixIn.subscription attribute) 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.directorycontainer.DirectoryContainer 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.apps.app_base.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) 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) 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.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.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.apps.app_base.AppDROP method) getNodeSessions() (dlg.manager.rest.CompositeManagerRestServer method) getPastSessionIds() (dlg.manager.composite_manager.CompositeManager method) getPastSessions() (dlg.manager.rest.CompositeManagerRestServer method) getSessionIds() (dlg.manager.composite_manager.CompositeManager method) (dlg.manager.drop_manager.DROPManager method) (dlg.manager.node_manager.NodeManagerBase method) getSessionReproStatus() (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) GroupByDrop (class in dlg.apps.constructs)

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)

I

import_using_code() (in module dlg.apps.pyfunc) import_using_code_ser() (in module dlg.apps.pyfunc) 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.archiving.NgasArchivingApp 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.GenericGatherApp method) (dlg.apps.simple.GenericScatterApp method) (dlg.apps.simple.ListAppendThrashingApp method) (dlg.apps.simple.PickOne method) (dlg.apps.simple.RandomArrayApp method) (dlg.apps.simple.SimpleBranch method) (dlg.apps.simple.SleepApp method) (dlg.apps.socket_listener.SocketListenerApp method) (dlg.data.drops.directorycontainer.DirectoryContainer 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.apps.app_base) InvalidLibrary IOForURL() (in module dlg.data.io) is_exception (dlg.rpc.ZeroRPCClient.response attribute) is_time_critical() (dlg.dropmake.scheduler.MinNumPartsScheduler method) (dlg.dropmake.scheduler.MySarkarScheduler method) 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) LoopDrop (class in dlg.apps.constructs)

M

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) metis_part() (dlg.dropmake.scheduler.DAGUtil static method) 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.directorycontainer 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) 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) 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) 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) 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) 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)