Class: TransactionalSpout

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

Instance Method Summary collapse

Constructor Details

#initialize(base_class_path, real_spout_class_name) ⇒ TransactionalSpout

Returns a new instance of TransactionalSpout.



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

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 



37
38
39
 
# File 'lib/red_storm/proxy/transactional_spout.rb', line 37

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

#getComponentConfiguration ⇒ Object 



42
43
44
 
# File 'lib/red_storm/proxy/transactional_spout.rb', line 42

def getComponentConfiguration
  @real_spout.get_component_configuration
end

#getCoordinator(conf, context) ⇒ Object 



32
33
34
 
# File 'lib/red_storm/proxy/transactional_spout.rb', line 32

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

#getEmitter(conf, context) ⇒ Object 



27
28
29
 
# File 'lib/red_storm/proxy/transactional_spout.rb', line 27

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