Uses of Class
org.apache.storm.topology.base.BaseRichSpout
-
-
Uses of BaseRichSpout in org.apache.storm
Subclasses of BaseRichSpout in org.apache.storm Modifier and Type Class Description static class
ExclamationTopology.FixedOrderWordSpout
-
Uses of BaseRichSpout in org.apache.storm.drpc
Subclasses of BaseRichSpout in org.apache.storm.drpc Modifier and Type Class Description class
DRPCSpout
-
Uses of BaseRichSpout in org.apache.storm.hdfs.bolt
Subclasses of BaseRichSpout in org.apache.storm.hdfs.bolt Modifier and Type Class Description static class
HdfsFileTopology.SentenceSpout
static class
SequenceFileTopology.SentenceSpout
-
Uses of BaseRichSpout in org.apache.storm.hdfs.spout
Subclasses of BaseRichSpout in org.apache.storm.hdfs.spout Modifier and Type Class Description class
HdfsSpout
-
Uses of BaseRichSpout in org.apache.storm.hive.bolt
Subclasses of BaseRichSpout in org.apache.storm.hive.bolt Modifier and Type Class Description static class
BucketTestHiveTopology.UserDataSpout
static class
HiveTopology.UserDataSpout
static class
HiveTopologyPartitioned.UserDataSpout
-
Uses of BaseRichSpout in org.apache.storm.jms.spout
Subclasses of BaseRichSpout in org.apache.storm.jms.spout Modifier and Type Class Description class
JmsSpout
A StormSpout
implementation that listens to a JMS topic or queue and outputs tuples based on the messages it receives. -
Uses of BaseRichSpout in org.apache.storm.kafka.spout
Subclasses of BaseRichSpout in org.apache.storm.kafka.spout Modifier and Type Class Description class
KafkaSpout<K,V>
-
Uses of BaseRichSpout in org.apache.storm.lambda
Subclasses of BaseRichSpout in org.apache.storm.lambda Modifier and Type Class Description class
LambdaSpout
-
Uses of BaseRichSpout in org.apache.storm.loadgen
Subclasses of BaseRichSpout in org.apache.storm.loadgen Modifier and Type Class Description class
LoadSpout
A spout that simulates a real world spout based off of statistics about it.static class
ThroughputVsLatency.FastRandomSentenceSpout
-
Uses of BaseRichSpout in org.apache.storm.perf.spout
Subclasses of BaseRichSpout in org.apache.storm.perf.spout Modifier and Type Class Description class
ConstSpout
class
FileReadSpout
class
StringGenSpout
Spout pre-computes a list with 30k fixed length random strings.class
WordGenSpout
-
Uses of BaseRichSpout in org.apache.storm.spout
Subclasses of BaseRichSpout in org.apache.storm.spout Modifier and Type Class Description class
CheckpointSpout
Emits checkpoint tuples which is used to save the state of theIStatefulComponent
across the topology. -
Uses of BaseRichSpout in org.apache.storm.st.topology.window
Subclasses of BaseRichSpout in org.apache.storm.st.topology.window Modifier and Type Class Description class
IncrementingSpout
class
TimeDataIncrementingSpout
-
Uses of BaseRichSpout in org.apache.storm.starter
Subclasses of BaseRichSpout in org.apache.storm.starter Modifier and Type Class Description static class
AnchoredWordCount.RandomSentenceSpout
static class
BlobStoreAPIWordCountTopology.RandomSentenceSpout
static class
FastWordCountTopology.FastRandomSentenceSpout
static class
InOrderDeliveryTest.InOrderSpout
-
Uses of BaseRichSpout in org.apache.storm.starter.spout
Subclasses of BaseRichSpout in org.apache.storm.starter.spout Modifier and Type Class Description class
RandomIntegerSpout
Emits a random integer and a timestamp value (offset by one day), every 100 ms.class
RandomSentenceSpout
static class
RandomSentenceSpout.TimeStamped
-
Uses of BaseRichSpout in org.apache.storm.testing
Subclasses of BaseRichSpout in org.apache.storm.testing Modifier and Type Class Description class
FeederSpout
class
SpoutTracker
class
TestEventLogSpout
class
TestPlannerSpout
class
TestWordSpout
-
Uses of BaseRichSpout in org.apache.storm.trident.topology
Subclasses of BaseRichSpout in org.apache.storm.trident.topology Modifier and Type Class Description class
MasterBatchCoordinator
-