Uses of Interface
org.apache.storm.trident.spout.IPartitionedTridentSpout.Coordinator
-
Packages that use IPartitionedTridentSpout.Coordinator Package Description org.apache.storm.kafka.spout.trident org.apache.storm.trident.spout -
-
Uses of IPartitionedTridentSpout.Coordinator in org.apache.storm.kafka.spout.trident
Classes in org.apache.storm.kafka.spout.trident that implement IPartitionedTridentSpout.Coordinator Modifier and Type Class Description class
KafkaTridentSpoutCoordinator<K,V>
Methods in org.apache.storm.kafka.spout.trident that return IPartitionedTridentSpout.Coordinator Modifier and Type Method Description IPartitionedTridentSpout.Coordinator<List<Map<String,Object>>>
KafkaTridentSpoutTransactional. getCoordinator(Map<String,Object> conf, TopologyContext context)
-
Uses of IPartitionedTridentSpout.Coordinator in org.apache.storm.trident.spout
Methods in org.apache.storm.trident.spout that return IPartitionedTridentSpout.Coordinator Modifier and Type Method Description IPartitionedTridentSpout.Coordinator<PartitionsT>
IPartitionedTridentSpout. getCoordinator(Map<String,Object> conf, TopologyContext context)
-