Class: Wukong::Dataflow

Inherits:
Hanuman::Tree show all
Defined in:
lib/wukong/dataflow.rb

Constant Summary

Constants included from Hanuman::TreeInstanceMethods

Hanuman::TreeInstanceMethods::MultipleRoots

Instance Attribute Summary

Attributes included from Hanuman::StageInstanceMethods

#graph

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Hanuman::TreeInstanceMethods

#add_link, #ancestor, #append, #directed_sort, #each_stage, #leaves, #prepend, #root, #tsort_each_child, #tsort_each_node

Methods included from Hanuman::GraphInstanceMethods

#add_link, #add_stage, #ancestors, #descendents, #each_stage, #has_link?

Methods inherited from Hanuman::Stage

#clone

Methods included from Hanuman::StageClassMethods

#builder, #label, #register, #set_builder

Methods included from Hanuman::StageInstanceMethods

#add_stage_link, #linkable_name, #root

Class Method Details

.configure(settings) ⇒ Object 



4
5
6
 
# File 'lib/wukong/dataflow.rb', line 4

def self.configure(settings)
  settings.description = builder.description if builder.description
end

Instance Method Details

#finalize(&emit) ⇒ Object 



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

def finalize(&emit)
  finalize_list([root], &emit)
end

#process(record, &emit) ⇒ Object 



14
15
16
 
# File 'lib/wukong/dataflow.rb', line 14

def process(record, &emit)
  process_list(record, [root], &emit)
end

#setup ⇒ Object 



8
9
10
11
12
 
# File 'lib/wukong/dataflow.rb', line 8

def setup
  each_stage do |stage|
    stage.setup
  end
end

#stop ⇒ Object 



22
23
24
25
26
 
# File 'lib/wukong/dataflow.rb', line 22

def stop
  each_stage do |stage|
    stage.stop
  end
end