Modifier and Type | Class and Description |
---|---|
class |
ClojureBolt |
class |
ClojureSpout |
class |
RichShellBolt |
class |
RichShellSpout |
Modifier and Type | Interface and Description |
---|---|
interface |
IBatchBolt<T> |
Modifier and Type | Class and Description |
---|---|
class |
BatchBoltExecutor |
class |
CoordinatedBolt
Coordination requires the request ids to be globally unique for awhile.
|
Modifier and Type | Class and Description |
---|---|
class |
DRPCSpout |
class |
JoinResult |
class |
KeyedFairBolt |
class |
PrepareRequest |
class |
ReturnResults |
Modifier and Type | Class and Description |
---|---|
class |
BatchNumberList |
class |
BatchProcessWord |
class |
BatchRepeatA |
class |
BoltTracker |
class |
CountingBatchBolt |
class |
CountingCommitBolt |
class |
FeederSpout |
class |
FixedTupleSpout |
class |
IdentityBolt |
class |
KeyedCountingBatchBolt |
class |
KeyedCountingCommitterBolt |
class |
KeyedSummingBatchBolt |
class |
MemoryTransactionalSpout |
class |
OpaqueMemoryTransactionalSpout
This spout only works in local mode.
|
class |
PrepareBatchBolt |
class |
PythonShellMetricsBolt |
class |
PythonShellMetricsSpout |
class |
SpoutTracker |
class |
TestAggregatesCounter |
class |
TestConfBolt |
class |
TestEventLogSpout |
class |
TestEventOrderCheckBolt |
class |
TestGlobalCount |
class |
TestPlannerBolt |
class |
TestPlannerSpout |
class |
TestWordCounter |
class |
TestWordSpout |
class |
TupleCaptureBolt |
Modifier and Type | Interface and Description |
---|---|
interface |
IBasicBolt |
interface |
IRichBolt
When writing topologies using Java,
IRichBolt and IRichSpout are the main interfaces
to use to implement components of the topology. |
interface |
IRichSpout
When writing topologies using Java,
IRichBolt and IRichSpout are the main interfaces
to use to implement components of the topology. |
interface |
IRichStateSpout |
Modifier and Type | Class and Description |
---|---|
class |
BasicBoltExecutor |
Modifier and Type | Class and Description |
---|---|
class |
BaseBasicBolt |
class |
BaseBatchBolt<T> |
class |
BaseComponent |
class |
BaseOpaquePartitionedTransactionalSpout<T> |
class |
BasePartitionedTransactionalSpout<T> |
class |
BaseRichBolt |
class |
BaseRichSpout |
class |
BaseTransactionalBolt |
class |
BaseTransactionalSpout<T> |
Modifier and Type | Interface and Description |
---|---|
interface |
ICommitterTransactionalSpout<X> |
interface |
ITransactionalSpout<T> |
Modifier and Type | Class and Description |
---|---|
class |
TransactionalSpoutBatchExecutor |
class |
TransactionalSpoutCoordinator |
Modifier and Type | Interface and Description |
---|---|
interface |
IOpaquePartitionedTransactionalSpout<T>
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
interface |
IPartitionedTransactionalSpout<T>
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
Modifier and Type | Class and Description |
---|---|
class |
OpaquePartitionedTransactionalSpoutExecutor |
class |
PartitionedTransactionalSpoutExecutor |
Modifier and Type | Class and Description |
---|---|
class |
AbstractHBaseBolt |
class |
HBaseBolt
Basic bolt for writing to HBase.
|
class |
HBaseLookupBolt
Basic bolt for querying from HBase.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractHdfsBolt |
class |
HdfsBolt |
class |
SequenceFileBolt |
Modifier and Type | Class and Description |
---|---|
class |
KafkaSpout |
Modifier and Type | Class and Description |
---|---|
class |
KafkaBolt<K,V>
Bolt implementation that can send Tuple data to Kafka
It expects the producer configuration and topic in storm config under
'kafka.broker.properties' and 'topic'
respectively.
|
Modifier and Type | Class and Description |
---|---|
static class |
BasicDRPCTopology.ExclaimBolt |
static class |
ExclamationTopology.ExclamationBolt |
static class |
ManualDRPC.ExclamationBolt |
static class |
ReachTopology.CountAggregator |
static class |
ReachTopology.GetFollowers |
static class |
ReachTopology.GetTweeters |
static class |
ReachTopology.PartialUniquer |
static class |
TransactionalGlobalCount.BatchCount |
static class |
TransactionalGlobalCount.UpdateGlobalCount |
static class |
TransactionalWords.BucketCountUpdater |
static class |
TransactionalWords.Bucketize |
static class |
TransactionalWords.KeyedCountUpdater |
static class |
WordCountTopology.SplitSentence |
static class |
WordCountTopology.WordCount |
static class |
WordCountTopologyNode.RandomSentence |
static class |
WordCountTopologyNode.SplitSentence |
static class |
WordCountTopologyNode.WordCount |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRankerBolt
This abstract bolt provides the basic behavior of bolts that rank objects according to their count.
|
class |
IntermediateRankingsBolt
This bolt ranks incoming objects by their count.
|
class |
PrinterBolt |
class |
RollingCountBolt
This bolt performs rolling counts of incoming objects, i.e.
|
class |
SingleJoinBolt |
class |
TotalRankingsBolt
This bolt merges incoming
Rankings . |
Modifier and Type | Class and Description |
---|---|
class |
RandomSentenceSpout |
class |
TwitterSampleSpout |
Modifier and Type | Class and Description |
---|---|
class |
SubtopologyBolt |
Modifier and Type | Class and Description |
---|---|
class |
RichSpoutBatchTriggerer |
class |
TridentSpoutCoordinator |
class |
TridentSpoutExecutor |
Modifier and Type | Interface and Description |
---|---|
interface |
ITridentBatchBolt |
Modifier and Type | Class and Description |
---|---|
class |
MasterBatchCoordinator |
class |
TridentBoltExecutor |
Modifier and Type | Method and Description |
---|---|
static Fields |
TridentUtils.getSingleOutputStreamFields(IComponent component) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.