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 © 2020 The Apache Software Foundation. All rights reserved.