Uses of Interface
org.apache.storm.trident.spout.ICommitterTridentSpout.Emitter
-
Uses of ICommitterTridentSpout.Emitter in org.apache.storm.trident.spout
Modifier and TypeMethodDescriptionICommitterTridentSpout.getEmitter
(String txStateId, Map<String, Object> conf, TopologyContext context) OpaquePartitionedTridentSpoutExecutor.getEmitter
(String txStateId, Map<String, Object> conf, TopologyContext context) -
Uses of ICommitterTridentSpout.Emitter in org.apache.storm.trident.testing
Modifier and TypeMethodDescriptionFeederCommitterBatchSpout.getEmitter
(String txStateId, Map<String, Object> conf, TopologyContext context)