Index

A

add() (dispel4py.workflow_graph.WorkflowGraph method) addTwo() (in module dispel4py.examples.graph_testing.pipeline_composite) AggregatePE (class in dispel4py.new.aggregate) AllToOneCommunication (class in dispel4py.new.processor)

assign_and_connect() (in module dispel4py.new.processor) AverageParallelPE (class in dispel4py.new.aggregate) AverageReducePE (class in dispel4py.new.aggregate)

B

BasePE (class in dispel4py.base)

buildTopology() (in module dispel4py.storm.topology)

C

CompositePE (class in dispel4py.base) compute() (dispel4py.seismo.obspy_stream.ObspyStreamPE method) connect() (dispel4py.workflow_graph.WorkflowGraph method) cons1 (in module dispel4py.examples.graph_testing.delayed_pipeline) cons2 (in module dispel4py.examples.graph_testing.delayed_pipeline) ConsumerPE (class in dispel4py.base) ContinuousReducePE (class in dispel4py.new.aggregate) CountPE (class in dispel4py.new.aggregate)

create() (in module dispel4py.storm.storm_submission) create_arg_parser() (in module dispel4py.new.processor) create_inputs() (in module dispel4py.new.processor) create_iterative_chain() (in module dispel4py.base) create_partitioned() (in module dispel4py.new.processor) create_pipeline() (in module dispel4py.seismo.simple) createPackage() (in module dispel4py.storm.storm_submission) createProcessingComposite() (in module dispel4py.seismo.obspy_stream)

D

DataTuple (class in dispel4py.seismo.simple) dispel4py (module) dispel4py.base (module) dispel4py.core (module) dispel4py.examples (module) dispel4py.examples.graph_testing (module) dispel4py.examples.graph_testing.delayed_pipeline (module) dispel4py.examples.graph_testing.group_by (module) dispel4py.examples.graph_testing.grouping_alltoone (module) dispel4py.examples.graph_testing.grouping_onetoall (module) dispel4py.examples.graph_testing.grouping_split_merge (module) dispel4py.examples.graph_testing.large_teecopy (module) dispel4py.examples.graph_testing.multi_producer (module) dispel4py.examples.graph_testing.parallel_pipeline (module) dispel4py.examples.graph_testing.partition_parallel_pipeline (module) dispel4py.examples.graph_testing.pipeline_composite (module) dispel4py.examples.graph_testing.pipeline_test (module) dispel4py.examples.graph_testing.producer_tee (module) dispel4py.examples.graph_testing.split_merge (module) dispel4py.examples.graph_testing.teecopy (module) dispel4py.examples.graph_testing.testing_PEs (module) dispel4py.examples.graph_testing.unconnected_pipeline (module) dispel4py.examples.graph_testing.word_count (module) dispel4py.examples.graph_testing.word_count_filter (module) dispel4py.new (module) dispel4py.new.aggregate (module) dispel4py.new.aggregate_test (module)

dispel4py.new.mappings (module) dispel4py.new.monitoring (module) dispel4py.new.mpi_process (module) dispel4py.new.multi_process (module) dispel4py.new.processor (module) dispel4py.new.simple_process (module) dispel4py.seismo (module) dispel4py.seismo.obspy_stream (module) dispel4py.seismo.seismo (module) dispel4py.seismo.simple (module) dispel4py.storm (module) dispel4py.storm.client (module) dispel4py.storm.storm_submission (module) dispel4py.storm.storm_submission_client (module) dispel4py.storm.topology (module) dispel4py.storm.utils (module) dispel4py.test (module) dispel4py.test.simple_process_test (module) dispel4py.utils (module) dispel4py.visualisation (module) dispel4py.workflow_graph (module) display() (in module dispel4py.visualisation) divideByTwo() (in module dispel4py.examples.graph_testing.pipeline_composite) draw() (in module dispel4py.workflow_graph) drawDot() (in module dispel4py.workflow_graph) DummyModule (class in dispel4py.utils)

E

extractItemMetadata() (dispel4py.seismo.seismo.SeismoPE method)

F

findWorkflowGraph() (in module dispel4py.utils)

flatten() (dispel4py.workflow_graph.WorkflowGraph method)

G

GenericPE (class in dispel4py.core) GenericWrapper (class in dispel4py.new.processor) GenericWriter (class in dispel4py.new.processor) get_data() (dispel4py.seismo.simple.SeismoStreamPE method) get_inputs() (in module dispel4py.new.processor) get_partitions() (in module dispel4py.new.processor) getConnectedInputs() (in module dispel4py.workflow_graph) getContainedObject() (dispel4py.workflow_graph.WorkflowNode method) getContainedObjects() (dispel4py.workflow_graph.WorkflowGraph method)

getDataStreams() (dispel4py.seismo.seismo.SeismoPE method) getDestination() (dispel4py.new.processor.AllToOneCommunication method) (dispel4py.new.processor.GroupByCommunication method) (dispel4py.new.processor.OneToAllCommunication method) (dispel4py.new.processor.ShuffleCommunication method) getOutputTypes() (dispel4py.core.GenericPE method) (dispel4py.seismo.obspy_stream.ObspyStreamPE method) graph_avg() (in module dispel4py.new.aggregate_test) graph_count() (in module dispel4py.new.aggregate_test) graph_min_max() (in module dispel4py.new.aggregate_test) graph_sum() (in module dispel4py.new.aggregate_test) GroupByCommunication (class in dispel4py.new.processor)

I

initParameters() (dispel4py.seismo.seismo.SeismoPE method) INPUT_NAME (dispel4py.base.BasePE attribute) (dispel4py.base.ConsumerPE attribute) (dispel4py.base.IterativePE attribute) (dispel4py.base.SimpleFunctionPE attribute) input_name (dispel4py.examples.graph_testing.testing_PEs.RandomFilter attribute) (dispel4py.examples.graph_testing.testing_PEs.WordCounter attribute)

INPUT_NAME (dispel4py.new.aggregate.AggregatePE attribute) (dispel4py.new.aggregate.AverageParallelPE attribute) (dispel4py.new.aggregate.AverageReducePE attribute) (dispel4py.new.aggregate.ContinuousReducePE attribute) (dispel4py.new.aggregate.StdDevPE attribute) (dispel4py.new.aggregate.StdDevReducePE attribute) (dispel4py.seismo.seismo.SeismoPE attribute) (dispel4py.seismo.simple.SeismoStreamPE attribute) IterativePE (class in dispel4py.base)

K

killTopology() (dispel4py.storm.client.StormClient method)

L

load_graph() (in module dispel4py.utils) load_graph_and_inputs() (in module dispel4py.new.processor) loadGraph() (in module dispel4py.utils) loadGraphFromFile() (in module dispel4py.utils) loadGraphFromSource() (in module dispel4py.utils)

loadGraphIgnoreImports() (in module dispel4py.utils) loadIgnoreImports() (in module dispel4py.utils) loadSource() (in module dispel4py.utils) loadSourceIgnoreImports() (in module dispel4py.utils) LockstepPE (class in dispel4py.core)

M

main() (in module dispel4py.new.mpi_process) (in module dispel4py.new.multi_process) (in module dispel4py.new.processor) (in module dispel4py.new.simple_process) make_hash() (in module dispel4py.utils) map_inputs_to_partitions() (in module dispel4py.new.processor) MaxPE (class in dispel4py.new.aggregate) MinPE (class in dispel4py.new.aggregate)

MonitoringWrapper (class in dispel4py.new.monitoring) MPIWrapper (class in dispel4py.new.mpi_process) multiplyByFour() (in module dispel4py.examples.graph_testing.pipeline_composite) MultiProcessingWrapper (class in dispel4py.new.multi_process)

N

node_counter (dispel4py.workflow_graph.WorkflowNode attribute)

NumberProducer (class in dispel4py.examples.graph_testing.testing_PEs)

O

ObspyStreamPE (class in dispel4py.seismo.obspy_stream) OneToAllCommunication (class in dispel4py.new.processor) OUTPUT_DATA (dispel4py.seismo.seismo.SeismoPE attribute)

OUTPUT_NAME (dispel4py.base.BasePE attribute) (dispel4py.base.IterativePE attribute) (dispel4py.base.ProducerPE attribute) (dispel4py.base.SimpleFunctionPE attribute) output_name (dispel4py.examples.graph_testing.testing_PEs.RandomFilter attribute) (dispel4py.examples.graph_testing.testing_PEs.WordCounter attribute) OUTPUT_NAME (dispel4py.new.aggregate.AggregatePE attribute) (dispel4py.new.aggregate.AverageParallelPE attribute) (dispel4py.new.aggregate.AverageReducePE attribute) (dispel4py.new.aggregate.ContinuousReducePE attribute) (dispel4py.new.aggregate.StdDevPE attribute) (dispel4py.new.aggregate.StdDevReducePE attribute) (dispel4py.seismo.simple.SeismoStreamPE attribute)

P

parallel_aggregate() (in module dispel4py.new.aggregate) parallelAvg() (in module dispel4py.new.aggregate) parallelCount() (in module dispel4py.new.aggregate) parallelMax() (in module dispel4py.new.aggregate) parallelMin() (in module dispel4py.new.aggregate) parallelStdDev() (in module dispel4py.new.aggregate) parallelSum() (in module dispel4py.new.aggregate) parse_args() (in module dispel4py.new.mpi_process) (in module dispel4py.new.multi_process) (in module dispel4py.storm.storm_submission) parse_common_args() (in module dispel4py.new.processor)

postprocess() (dispel4py.core.GenericPE method) preprocess() (dispel4py.core.GenericPE method) process() (dispel4py.base.ConsumerPE method) (dispel4py.base.IterativePE method) (dispel4py.base.ProducerPE method) (dispel4py.core.GenericPE method) (dispel4py.examples.graph_testing.testing_PEs.NumberProducer method) (dispel4py.examples.graph_testing.testing_PEs.ProvenanceLogger method) (dispel4py.examples.graph_testing.testing_PEs.RandomFilter method) (dispel4py.examples.graph_testing.testing_PEs.RandomWordProducer method) (dispel4py.examples.graph_testing.testing_PEs.TestDelayOneInOneOut method) (dispel4py.examples.graph_testing.testing_PEs.TestOneInOneOut method) (dispel4py.examples.graph_testing.testing_PEs.TestOneInOneOutWriter method) (dispel4py.examples.graph_testing.testing_PEs.TestTwoInOneOut method) (dispel4py.new.aggregate.ContinuousReducePE method) (dispel4py.new.monitoring.ProcessTimingPE method) (dispel4py.new.processor.GenericWrapper method) (dispel4py.seismo.simple.SeismoStreamPE method) (in module dispel4py.new.mpi_process) (in module dispel4py.new.multi_process) (in module dispel4py.new.simple_process) (in module dispel4py.storm.storm_submission) process_and_return() (in module dispel4py.new.simple_process) ProcessTimingPE (class in dispel4py.new.monitoring) ProducerPE (class in dispel4py.base) propagate_types() (dispel4py.workflow_graph.WorkflowGraph method) ProvenanceLogger (class in dispel4py.examples.graph_testing.testing_PEs)

R

RandomFilter (class in dispel4py.examples.graph_testing.testing_PEs) RandomWordProducer (class in dispel4py.examples.graph_testing.testing_PEs)

ReadTimingWrapper (class in dispel4py.new.monitoring) runLocal() (in module dispel4py.storm.storm_submission)

S

SeismoPE (class in dispel4py.seismo.seismo) SeismoStreamPE (class in dispel4py.seismo.simple) setCompute() (dispel4py.seismo.obspy_stream.ObspyStreamPE method) setInputTypes() (dispel4py.core.GenericPE method) (dispel4py.seismo.obspy_stream.ObspyStreamPE method) ShuffleCommunication (class in dispel4py.new.processor) SimpleFunctionPE (class in dispel4py.base) simpleLogger() (in module dispel4py.new.processor) (in module dispel4py.new.simple_process) SimpleProcessingPE (class in dispel4py.new.processor) SimpleProcessingWrapper (class in dispel4py.new.simple_process) SimpleWriter (class in dispel4py.new.processor)

SourcePE (class in dispel4py.core) sources (dispel4py.new.processor.GenericWrapper attribute) StdDevPE (class in dispel4py.new.aggregate) StdDevReducePE (class in dispel4py.new.aggregate) StormClient (class in dispel4py.storm.client) stormLogger() (in module dispel4py.storm.utils) submit() (in module dispel4py.storm.storm_submission) submitTopology() (dispel4py.storm.client.StormClient method) subtract() (in module dispel4py.examples.graph_testing.pipeline_composite) SumPE (class in dispel4py.new.aggregate)

T

testAlltoOne() (in module dispel4py.examples.graph_testing.grouping_alltoone) testAvg() (in module dispel4py.new.aggregate_test) testCount() (in module dispel4py.new.aggregate_test) TestDelayOneInOneOut (class in dispel4py.examples.graph_testing.testing_PEs) testGrouping() (in module dispel4py.examples.graph_testing.group_by) (in module dispel4py.examples.graph_testing.grouping_split_merge) testMinMax() (in module dispel4py.new.aggregate_test) TestMultiProducer (class in dispel4py.examples.graph_testing.testing_PEs) TestOneInOneOut (class in dispel4py.examples.graph_testing.testing_PEs) TestOneInOneOutWriter (class in dispel4py.examples.graph_testing.testing_PEs) testOnetoAll() (in module dispel4py.examples.graph_testing.grouping_onetoall) testParallelPipeline() (in module dispel4py.examples.graph_testing.parallel_pipeline) (in module dispel4py.examples.graph_testing.partition_parallel_pipeline)

testPipeline() (in module dispel4py.examples.graph_testing.pipeline_test) (in module dispel4py.examples.graph_testing.unconnected_pipeline) (in module dispel4py.test.simple_process_test) TestProducer (class in dispel4py.examples.graph_testing.testing_PEs) testSplitMerge() (in module dispel4py.examples.graph_testing.split_merge) testSquare() (in module dispel4py.test.simple_process_test) testSum() (in module dispel4py.new.aggregate_test) testTee() (in module dispel4py.examples.graph_testing.large_teecopy) (in module dispel4py.examples.graph_testing.teecopy) (in module dispel4py.test.simple_process_test) TestTwoInOneOut (class in dispel4py.examples.graph_testing.testing_PEs) testUnconnected() (in module dispel4py.examples.graph_testing.unconnected_pipeline) testWriter() (in module dispel4py.test.simple_process_test) Timer (class in dispel4py.new.monitoring) total_size() (in module dispel4py.utils)

W

WordCounter (class in dispel4py.examples.graph_testing.testing_PEs) words (dispel4py.examples.graph_testing.testing_PEs.RandomWordProducer attribute) WORKFLOW_NODE_CP (dispel4py.workflow_graph.WorkflowNode attribute) WORKFLOW_NODE_FN (dispel4py.workflow_graph.WorkflowNode attribute) WORKFLOW_NODE_PE (dispel4py.workflow_graph.WorkflowNode attribute) WorkflowGraph (class in dispel4py.workflow_graph)

WorkflowNode (class in dispel4py.workflow_graph) write() (dispel4py.core.GenericPE method) (dispel4py.new.processor.GenericWriter method) (dispel4py.new.processor.SimpleWriter method) write_data() (dispel4py.seismo.simple.SeismoStreamPE method) writeOutputStreams() (dispel4py.seismo.seismo.SeismoPE method) writeStream() (dispel4py.seismo.seismo.SeismoPE method)