Uses of Interface
org.apache.storm.trident.spout.IBatchSpout
-
-
Uses of IBatchSpout in org.apache.storm.hdfs.trident
Classes in org.apache.storm.hdfs.trident that implement IBatchSpout Modifier and Type Class Description class
FixedBatchSpout
-
Uses of IBatchSpout in org.apache.storm.hive.trident
Classes in org.apache.storm.hive.trident that implement IBatchSpout Modifier and Type Class Description static class
TridentHiveTopology.FixedBatchSpout
-
Uses of IBatchSpout in org.apache.storm.starter.spout
Classes in org.apache.storm.starter.spout that implement IBatchSpout Modifier and Type Class Description class
RandomNumberGeneratorSpout
This spout generates random whole numbers with givenmaxNumber
value as maximum with the givenfields
. -
Uses of IBatchSpout in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type IBatchSpout Modifier and Type Method Description Stream
TridentTopology. newStream(String txId, IBatchSpout spout)
-
Uses of IBatchSpout in org.apache.storm.trident.spout
Constructors in org.apache.storm.trident.spout with parameters of type IBatchSpout Constructor Description BatchSpoutExecutor(IBatchSpout spout)
-
Uses of IBatchSpout in org.apache.storm.trident.testing
Classes in org.apache.storm.trident.testing that implement IBatchSpout Modifier and Type Class Description class
FixedBatchSpout
-
Uses of IBatchSpout in org.apache.storm.trident.topology
Methods in org.apache.storm.trident.topology with parameters of type IBatchSpout Modifier and Type Method Description SpoutDeclarer
TridentTopologyBuilder. setSpout(String id, String streamName, String txStateId, IBatchSpout spout, Integer parallelism, String batchGroup)
-