Class: TransactionalCommitterSpout

Inherits:
Object
  • Object
show all
Defined in:
lib/red_storm/proxy/transactional_committer_spout.rb

Instance Method Summary collapse

Constructor Details

#initialize(base_class_path, real_spout_class_name) ⇒ TransactionalCommitterSpout

Returns a new instance of TransactionalCommitterSpout.



20
21
22
23
24
25
 
# File 'lib/red_storm/proxy/transactional_committer_spout.rb', line 20

def initialize(base_class_path, real_spout_class_name)
  @real_spout = Object.module_eval(real_spout_class_name).new
rescue NameError
  require base_class_path
  @real_spout = Object.module_eval(real_spout_class_name).new
end

Instance Method Details

#declareOutputFields(declarer) ⇒ Object 



38
39
40
 
# File 'lib/red_storm/proxy/transactional_committer_spout.rb', line 38

def declareOutputFields(declarer)
  @real_spout.declare_output_fields(declarer)
end

#getComponentConfiguration ⇒ Object 



43
44
45
 
# File 'lib/red_storm/proxy/transactional_committer_spout.rb', line 43

def getComponentConfiguration
  @real_spout.get_component_configuration
end

#getCoordinator(conf, context) ⇒ Object 



33
34
35
 
# File 'lib/red_storm/proxy/transactional_committer_spout.rb', line 33

def getCoordinator(conf, context)
  @real_spout.get_coordinator(conf, context)
end

#getEmitter(conf, context) ⇒ Object 



28
29
30
 
# File 'lib/red_storm/proxy/transactional_committer_spout.rb', line 28

def getEmitter(conf, context)
  @real_spout.get_emitter(conf, context)
end