| Modifier and Type | Class and Description | 
|---|---|
static class  | 
ExclamationTopology.FixedOrderWordSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ClojureSpout  | 
class  | 
RichShellSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DRPCSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
EsIndexTopology.UserDataSpout
The user data spout. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
EventHubSpout  | 
| Constructor and Description | 
|---|
SpoutOutputCollectorImpl(ISpout spout,
                        SpoutExecutor executor,
                        Task taskData,
                        MutableLong emittedCount,
                        boolean hasAckers,
                        Random random,
                        Boolean isEventLoggers,
                        Boolean isDebug,
                        RotatingMap<Long,TupleInfo> pending)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
FluxShellSpout
A generic  
ShellSpout implementation that allows you specify output fields and even streams without having to subclass ShellSpout to do so. | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
HdfsFileTopology.SentenceSpout  | 
static class  | 
SequenceFileTopology.SentenceSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
HdfsSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
BucketTestHiveTopology.UserDataSpout  | 
static class  | 
HiveTopology.UserDataSpout  | 
static class  | 
HiveTopologyPartitioned.UserDataSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
UserSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
JmsSpout
A Storm  
Spout implementation that listens to a JMS topic or queue and outputs tuples based on the messages it receives. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KafkaSpout<K,V>  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KinesisSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LambdaSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LoadSpout
A spout that simulates a real world spout based off of statistics about it. 
 | 
static class  | 
ThroughputVsLatency.FastRandomSentenceSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
WordSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
MqttSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
MetricGenSpout
Spout to generate tuples containing metric data. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ConstSpout  | 
class  | 
FileReadSpout  | 
class  | 
StringGenSpout
Spout pre-computes a list with 30k fixed length random strings. 
 | 
class  | 
WordGenSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
RawInputFromCSVSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
RocketMqSpout
RocketMqSpout uses MQPushConsumer as the default implementation. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SolrFieldsSpout  | 
class  | 
SolrJsonSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CheckpointSpout
Emits checkpoint tuples which is used to save the state of the  
IStatefulComponent across the topology. | 
class  | 
ShellSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SocketSpout
Spout for Socket data. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
IncrementingSpout  | 
class  | 
TimeDataIncrementingSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
AnchoredWordCount.RandomSentenceSpout  | 
static class  | 
BlobStoreAPIWordCountTopology.RandomSentenceSpout  | 
static class  | 
FastWordCountTopology.FastRandomSentenceSpout  | 
static class  | 
InOrderDeliveryTest.InOrderSpout  | 
static class  | 
WordCountTopologyNode.RandomSentence  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
RandomIntegerSpout
Emits a random integer and a timestamp value (offset by one day), every 100 ms. 
 | 
class  | 
RandomSentenceSpout  | 
static class  | 
RandomSentenceSpout.TimeStamped  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
FeederSpout  | 
class  | 
FixedTupleSpout  | 
class  | 
PythonShellMetricsSpout  | 
class  | 
SpoutTracker  | 
class  | 
TestEventLogSpout  | 
class  | 
TestPlannerSpout  | 
class  | 
TestWordSpout  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
IRichSpout
When writing topologies using Java,  
IRichBolt and IRichSpout are the main interfaces to use to implement components of the topology. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BaseRichSpout  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
RichSpoutBatchTriggerer  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
MasterBatchCoordinator  | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.