Uses of Class
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutManager

Packages that use KafkaTridentSpoutManager

Package	Description
org.apache.storm.kafka.spout.trident

Uses of KafkaTridentSpoutManager in org.apache.storm.kafka.spout.trident

Constructors in org.apache.storm.kafka.spout.trident with parameters of type KafkaTridentSpoutManager

Constructor and Description
KafkaTridentSpoutEmitter(KafkaTridentSpoutManager<K,V> kafkaManager, TopologyContext topologyContext) Creates instance of this class with default 500 millisecond refresh subscription timer
KafkaTridentSpoutEmitter(KafkaTridentSpoutManager<K,V> kafkaManager, TopologyContext topologyContext, Timer refreshSubscriptionTimer) Create a new Kafka spout emitter.
KafkaTridentSpoutOpaque(KafkaTridentSpoutManager<K,V> kafkaManager)
KafkaTridentSpoutOpaqueCoordinator(KafkaTridentSpoutManager<K,V> kafkaManager)