Class: T2Flow::Dataflow

Inherits:
Object
  • Object
show all
Defined in:
lib/t2flow/model/dataflow.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initializeDataflow

Creates a new Dataflow object.


30
31
32
33
34
35
36
37
# File 'lib/t2flow/model/dataflow.rb', line 30

def initialize
  @annotations = DataflowAnnotation.new
  @processors = []
  @datalinks = []
  @sources = []
  @sinks = []
  @coordinations = []
end

Instance Attribute Details

#annotationsObject

This returns a DataflowAnnotation object.


6
7
8
# File 'lib/t2flow/model/dataflow.rb', line 6

def annotations
  @annotations
end

#coordinationsObject

Retrieve the list of coordinations specific to the dataflow.


21
22
23
# File 'lib/t2flow/model/dataflow.rb', line 21

def coordinations
  @coordinations
end

#dataflow_idObject

The unique identifier of the dataflow.


24
25
26
# File 'lib/t2flow/model/dataflow.rb', line 24

def dataflow_id
  @dataflow_id
end

Retrieve the list of datalinks specific to the dataflow.


12
13
14
# File 'lib/t2flow/model/dataflow.rb', line 12

def datalinks
  @datalinks
end

#processorsObject

Retrieve the list of processors specific to the dataflow.


9
10
11
# File 'lib/t2flow/model/dataflow.rb', line 9

def processors
  @processors
end

#roleObject

The role of the workflow


27
28
29
# File 'lib/t2flow/model/dataflow.rb', line 27

def role
  @role
end

#sinksObject

Retrieve the list of sinks specific to the dataflow.


18
19
20
# File 'lib/t2flow/model/dataflow.rb', line 18

def sinks
  @sinks
end

#sourcesObject

Retrieve the list of sources specific to the dataflow.


15
16
17
# File 'lib/t2flow/model/dataflow.rb', line 15

def sources
  @sources
end

Instance Method Details

#beanshellsObject

Retrieve beanshell processors specific to this dataflow.


44
45
46
# File 'lib/t2flow/model/dataflow.rb', line 44

def beanshells
  @processors.select { |x| x.type == "beanshell" }
end

#nameObject


39
40
41
# File 'lib/t2flow/model/dataflow.rb', line 39

def name
  @annotations.name
end