Uses of Interface
org.apache.storm.trident.spout.ITridentSpout
-
Packages that use ITridentSpout Package Description org.apache.storm.jms.trident org.apache.storm.trident org.apache.storm.trident.spout org.apache.storm.trident.testing org.apache.storm.trident.topology -
-
Uses of ITridentSpout in org.apache.storm.jms.trident
Classes in org.apache.storm.jms.trident that implement ITridentSpout Modifier and Type Class Description class
TridentJmsSpout
Trident implementation of the JmsSpout. -
Uses of ITridentSpout in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type ITridentSpout Modifier and Type Method Description Stream
TridentTopology. newStream(String txId, ITridentSpout spout)
-
Uses of ITridentSpout in org.apache.storm.trident.spout
Subinterfaces of ITridentSpout in org.apache.storm.trident.spout Modifier and Type Interface Description interface
ICommitterTridentSpout<X>
Classes in org.apache.storm.trident.spout that implement ITridentSpout Modifier and Type Class Description class
BatchSpoutExecutor
class
OpaquePartitionedTridentSpoutExecutor
class
PartitionedTridentSpoutExecutor
class
RichSpoutBatchExecutor
Constructors in org.apache.storm.trident.spout with parameters of type ITridentSpout Constructor Description TridentSpoutCoordinator(String id, ITridentSpout<Object> spout)
TridentSpoutExecutor(String txStateId, String streamName, ITridentSpout<Object> spout)
-
Uses of ITridentSpout in org.apache.storm.trident.testing
Classes in org.apache.storm.trident.testing that implement ITridentSpout Modifier and Type Class Description class
FeederBatchSpout
class
FeederCommitterBatchSpout
-
Uses of ITridentSpout in org.apache.storm.trident.topology
Methods in org.apache.storm.trident.topology with parameters of type ITridentSpout Modifier and Type Method Description SpoutDeclarer
TridentTopologyBuilder. setSpout(String id, String streamName, String txStateId, ITridentSpout spout, Integer parallelism, String batchGroup)
-