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 |
Modifier and Type | Class and Description |
---|---|
class |
EventHubSpout |
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
Deprecated.
storm-kafka has been deprecated and will be removed in a future Storm release. Please upgrade to storm-kafka-client. If you need to migrate the committed offsets to the new spout, consider using the storm-kafka-migration tool.
|
Modifier and Type | Class and Description |
---|---|
class |
KinesisSpout |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
RawInputFromCSVSpout |
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 |
---|---|
static class |
AnchoredWordCount.RandomSentenceSpout |
static class |
BlobStoreAPIWordCountTopology.RandomSentenceSpout |
static class |
FastWordCountTopology.FastRandomSentenceSpout |
static class |
InOrderDeliveryTest.InOrderSpout |
static class |
ThroughputVsLatency.FastRandomSentenceSpout |
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 |
TransactionalSpoutCoordinator |
Modifier and Type | Class and Description |
---|---|
class |
RichSpoutBatchTriggerer |
Modifier and Type | Class and Description |
---|---|
class |
MasterBatchCoordinator |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.