Modifier and Type | Class and Description |
---|---|
static class |
ExclamationTopology.FixedOrderWordSpout |
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 |
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 |
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 |
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 |
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. |
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 |
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 |
SpoutTracker |
class |
TestEventLogSpout |
class |
TestPlannerSpout |
class |
TestWordSpout |
Modifier and Type | Class and Description |
---|---|
class |
MasterBatchCoordinator |
Copyright © 2023 The Apache Software Foundation. All rights reserved.