Uses of Interface
org.apache.storm.trident.spout.IPartitionedTridentSpout
-
Packages that use IPartitionedTridentSpout Package Description org.apache.storm.kafka.spout.trident org.apache.storm.trident org.apache.storm.trident.spout -
-
Uses of IPartitionedTridentSpout in org.apache.storm.kafka.spout.trident
Classes in org.apache.storm.kafka.spout.trident that implement IPartitionedTridentSpout Modifier and Type Class Description class
KafkaTridentSpoutTransactional<K,V>
-
Uses of IPartitionedTridentSpout in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type IPartitionedTridentSpout Modifier and Type Method Description Stream
TridentTopology. newStream(String txId, IPartitionedTridentSpout spout)
-
Uses of IPartitionedTridentSpout in org.apache.storm.trident.spout
Methods in org.apache.storm.trident.spout that return IPartitionedTridentSpout Modifier and Type Method Description IPartitionedTridentSpout<Object,ISpoutPartition,Object>
PartitionedTridentSpoutExecutor. getPartitionedSpout()
Constructors in org.apache.storm.trident.spout with parameters of type IPartitionedTridentSpout Constructor Description PartitionedTridentSpoutExecutor(IPartitionedTridentSpout<Object,ISpoutPartition,Object> spout)
-