explicit parent class for Emitter and Coordinator classes
This commit is contained in:
parent
72fbac4e92
commit
5d2c8076ac
|
@ -29,7 +29,7 @@ class TransactionalCommitterSpout
|
|||
@real_spout.get_emitter(conf, context)
|
||||
end
|
||||
|
||||
java_signature 'Coordinator getCoordinator(Map, TopologyContext)'
|
||||
java_signature 'ITransactionalSpout.Coordinator getCoordinator(Map, TopologyContext)'
|
||||
def getCoordinator(conf, context)
|
||||
@real_spout.get_coordinator(conf, context)
|
||||
end
|
||||
|
|
|
@ -23,12 +23,12 @@ class TransactionalSpout
|
|||
@real_spout = Object.module_eval(real_spout_class_name).new
|
||||
end
|
||||
|
||||
java_signature 'Emitter getEmitter(Map, TopologyContext)'
|
||||
java_signature 'ITransactionalSpout.Emitter getEmitter(Map, TopologyContext)'
|
||||
def getEmitter(conf, context)
|
||||
@real_spout.get_emitter(conf, context)
|
||||
end
|
||||
|
||||
java_signature 'Coordinator getCoordinator(Map, TopologyContext)'
|
||||
java_signature 'ITransactionalSpout.Coordinator getCoordinator(Map, TopologyContext)'
|
||||
def getCoordinator(conf, context)
|
||||
@real_spout.get_coordinator(conf, context)
|
||||
end
|
||||
|
|
|
@ -38,7 +38,7 @@ public class JRubyTransactionalSpout extends BaseTransactionalSpout {
|
|||
}
|
||||
|
||||
@Override
|
||||
public Coordinator getCoordinator(Map conf, TopologyContext context) {
|
||||
public ITransactionalSpout.Coordinator getCoordinator(Map conf, TopologyContext context) {
|
||||
// create instance of the jruby class here, after deserialization in the workers.
|
||||
if (_proxySpout == null) {
|
||||
_proxySpout = newProxySpout(_baseClassPath, _realSpoutClassName);
|
||||
|
|
Loading…
Reference in New Issue