Uses of Interface
org.apache.storm.topology.IComponent

Packages that use IComponent

Package	Description
org.apache.storm.bolt
org.apache.storm.cassandra.bolt
org.apache.storm.clojure
org.apache.storm.coordination
org.apache.storm.drpc
org.apache.storm.druid.bolt
org.apache.storm.elasticsearch.bolt
org.apache.storm.eventhubs.bolt
org.apache.storm.eventhubs.samples.bolt
org.apache.storm.eventhubs.spout
org.apache.storm.flux.wrappers.bolts
org.apache.storm.flux.wrappers.spouts
org.apache.storm.hbase.bolt
org.apache.storm.hbase.topology
org.apache.storm.hdfs.bolt
org.apache.storm.hdfs.spout
org.apache.storm.hive.bolt
org.apache.storm.jdbc.bolt
org.apache.storm.jdbc.spout
org.apache.storm.jms.bolt
org.apache.storm.jms.example
org.apache.storm.jms.spout
org.apache.storm.kafka
org.apache.storm.kafka.bolt
org.apache.storm.kinesis.spout
org.apache.storm.mongodb.bolt
org.apache.storm.mongodb.topology
org.apache.storm.mqtt.bolt
org.apache.storm.mqtt.spout
org.apache.storm.opentsdb
org.apache.storm.opentsdb.bolt
org.apache.storm.perf.bolt
org.apache.storm.perf.spout
org.apache.storm.pmml
org.apache.storm.redis.bolt
org.apache.storm.redis.topology
org.apache.storm.solr.bolt
org.apache.storm.solr.spout
org.apache.storm.spout
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.starter.spout
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.transactional
org.apache.storm.transactional.partitioned
org.apache.storm.trident.planner
org.apache.storm.trident.spout
org.apache.storm.trident.topology
org.apache.storm.trident.util
storm.starter

Uses of IComponent in org.apache.storm.bolt

Classes in org.apache.storm.bolt that implement IComponent

Modifier and Type	Class and Description
class	JoinBolt

Uses of IComponent in org.apache.storm.cassandra.bolt

Classes in org.apache.storm.cassandra.bolt that implement IComponent

Modifier and Type	Class and Description
class	BaseCassandraBolt<T> A base cassandra bolt.
class	BatchCassandraWriterBolt
class	CassandraWriterBolt

Uses of IComponent in org.apache.storm.clojure

Classes in org.apache.storm.clojure that implement IComponent

Modifier and Type	Class and Description
class	ClojureBolt
class	ClojureSpout
class	RichShellBolt
class	RichShellSpout

Uses of IComponent in org.apache.storm.coordination

Subinterfaces of IComponent in org.apache.storm.coordination

Modifier and Type	Interface and Description
interface	IBatchBolt<T>

Classes in org.apache.storm.coordination that implement IComponent

Modifier and Type	Class and Description
class	BatchBoltExecutor
class	CoordinatedBolt Coordination requires the request ids to be globally unique for awhile.

Uses of IComponent in org.apache.storm.drpc

Classes in org.apache.storm.drpc that implement IComponent

Modifier and Type	Class and Description
class	DRPCSpout
class	JoinResult
class	KeyedFairBolt
class	PrepareRequest
class	ReturnResults

Uses of IComponent in org.apache.storm.druid.bolt

Classes in org.apache.storm.druid.bolt that implement IComponent

Modifier and Type	Class and Description
class	DruidBeamBolt<E> Deprecated. the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.

Uses of IComponent in org.apache.storm.elasticsearch.bolt

Classes in org.apache.storm.elasticsearch.bolt that implement IComponent

Modifier and Type	Class and Description
class	AbstractEsBolt
class	EsIndexBolt Basic bolt for storing tuple to ES document.
static class	EsIndexTopology.UserDataSpout
class	EsLookupBolt
class	EsPercolateBolt Basic bolt for retrieve matched percolate queries.

Uses of IComponent in org.apache.storm.eventhubs.bolt

Classes in org.apache.storm.eventhubs.bolt that implement IComponent

Modifier and Type	Class and Description
class	EventHubBolt A bolt that writes event message to EventHub.

Uses of IComponent in org.apache.storm.eventhubs.samples.bolt

Classes in org.apache.storm.eventhubs.samples.bolt that implement IComponent

Modifier and Type	Class and Description
class	GlobalCountBolt Globally count number of messages
class	PartialCountBolt Partially count number of messages from EventHubs

Uses of IComponent in org.apache.storm.eventhubs.spout

Classes in org.apache.storm.eventhubs.spout that implement IComponent

Modifier and Type	Class and Description
class	EventHubSpout

Uses of IComponent in org.apache.storm.flux.wrappers.bolts

Classes in org.apache.storm.flux.wrappers.bolts that implement IComponent

Modifier and Type	Class and Description
class	FluxShellBolt A generic ShellBolt implementation that allows you specify output fields and even streams without having to subclass ShellBolt to do so.
class	LogInfoBolt Simple bolt that does nothing other than LOG.info() every tuple recieveed.

Uses of IComponent in org.apache.storm.flux.wrappers.spouts

Classes in org.apache.storm.flux.wrappers.spouts that implement IComponent

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.

Uses of IComponent in org.apache.storm.hbase.bolt

Classes in org.apache.storm.hbase.bolt that implement IComponent

Modifier and Type	Class and Description
class	AbstractHBaseBolt
class	HBaseBolt Basic bolt for writing to HBase.
class	HBaseLookupBolt Basic bolt for querying from HBase.

Uses of IComponent in org.apache.storm.hbase.topology

Classes in org.apache.storm.hbase.topology that implement IComponent

Modifier and Type	Class and Description
class	TotalWordCounter

Uses of IComponent in org.apache.storm.hdfs.bolt

Classes in org.apache.storm.hdfs.bolt that implement IComponent

Modifier and Type	Class and Description
class	AbstractHdfsBolt
class	AvroGenericRecordBolt
class	HdfsBolt
static class	HdfsFileTopology.MyBolt
static class	HdfsFileTopology.SentenceSpout
class	SequenceFileBolt
static class	SequenceFileTopology.MyBolt
static class	SequenceFileTopology.SentenceSpout

Uses of IComponent in org.apache.storm.hdfs.spout

Classes in org.apache.storm.hdfs.spout that implement IComponent

Modifier and Type	Class and Description
class	HdfsSpout
static class	HdfsSpoutTopology.ConstBolt

Uses of IComponent in org.apache.storm.hive.bolt

Classes in org.apache.storm.hive.bolt that implement IComponent

Modifier and Type	Class and Description
static class	BucketTestHiveTopology.UserDataSpout
class	HiveBolt
static class	HiveTopology.UserDataSpout
static class	HiveTopologyPartitioned.UserDataSpout

Uses of IComponent in org.apache.storm.jdbc.bolt

Classes in org.apache.storm.jdbc.bolt that implement IComponent

Modifier and Type	Class and Description
class	AbstractJdbcBolt
class	JdbcInsertBolt Basic bolt for writing to any Database table.
class	JdbcLookupBolt Basic bolt for querying from any database.

Uses of IComponent in org.apache.storm.jdbc.spout

Classes in org.apache.storm.jdbc.spout that implement IComponent

Modifier and Type	Class and Description
class	UserSpout

Uses of IComponent in org.apache.storm.jms.bolt

Classes in org.apache.storm.jms.bolt that implement IComponent

Modifier and Type	Class and Description
class	JmsBolt A JmsBolt receives org.apache.storm.tuple.Tuple objects from a Storm topology and publishes JMS Messages to a destination (topic or queue).

Uses of IComponent in org.apache.storm.jms.example

Classes in org.apache.storm.jms.example that implement IComponent

Modifier and Type	Class and Description
class	GenericBolt A generic org.apache.storm.topology.IRichBolt implementation for testing/debugging the Storm JMS Spout and example topologies.

Uses of IComponent in org.apache.storm.jms.spout

Classes in org.apache.storm.jms.spout that implement IComponent

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.

Uses of IComponent in org.apache.storm.kafka

Classes in org.apache.storm.kafka that implement IComponent

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.

Uses of IComponent in org.apache.storm.kafka.bolt

Classes in org.apache.storm.kafka.bolt that implement IComponent

Modifier and Type	Class and Description
class	KafkaBolt<K,V> Deprecated. Please use the KafkaBolt in storm-kafka-client

Uses of IComponent in org.apache.storm.kinesis.spout

Classes in org.apache.storm.kinesis.spout that implement IComponent

Modifier and Type	Class and Description
class	KinesisSpout

Uses of IComponent in org.apache.storm.mongodb.bolt

Classes in org.apache.storm.mongodb.bolt that implement IComponent

Modifier and Type	Class and Description
class	AbstractMongoBolt
class	MongoInsertBolt Basic bolt for writing to MongoDB.
class	MongoUpdateBolt Basic bolt for updating from MongoDB.

Uses of IComponent in org.apache.storm.mongodb.topology

Classes in org.apache.storm.mongodb.topology that implement IComponent

Modifier and Type	Class and Description
class	WordCounter
class	WordSpout

Uses of IComponent in org.apache.storm.mqtt.bolt

Classes in org.apache.storm.mqtt.bolt that implement IComponent

Modifier and Type	Class and Description
class	MqttBolt

Uses of IComponent in org.apache.storm.mqtt.spout

Classes in org.apache.storm.mqtt.spout that implement IComponent

Modifier and Type	Class and Description
class	MqttSpout

Uses of IComponent in org.apache.storm.opentsdb

Classes in org.apache.storm.opentsdb that implement IComponent

Modifier and Type	Class and Description
class	MetricGenSpout Spout to generate tuples containing metric data.

Uses of IComponent in org.apache.storm.opentsdb.bolt

Classes in org.apache.storm.opentsdb.bolt that implement IComponent

Modifier and Type	Class and Description
class	OpenTsdbBolt Basic bolt implementation for storing timeseries datapoints to OpenTSDB.

Uses of IComponent in org.apache.storm.perf.bolt

Classes in org.apache.storm.perf.bolt that implement IComponent

Modifier and Type	Class and Description
class	CountBolt
class	DevNullBolt
class	IdBolt
class	SplitSentenceBolt

Uses of IComponent in org.apache.storm.perf.spout

Classes in org.apache.storm.perf.spout that implement IComponent

Modifier and Type	Class and Description
class	ConstSpout
class	FileReadSpout
class	StringGenSpout Spout pre-computes a list with 30k fixed length random strings.

Uses of IComponent in org.apache.storm.pmml

Classes in org.apache.storm.pmml that implement IComponent

Modifier and Type	Class and Description
class	PMMLPredictorBolt
class	RawInputFromCSVSpout

Uses of IComponent in org.apache.storm.redis.bolt

Classes in org.apache.storm.redis.bolt that implement IComponent

Modifier and Type	Class and Description
class	AbstractRedisBolt AbstractRedisBolt class is for users to implement custom bolts which makes interaction with Redis.
class	RedisFilterBolt Basic bolt for querying from Redis and filters out if key/field doesn’t exist.
class	RedisLookupBolt Basic bolt for querying from Redis and emits response as tuple.
class	RedisStoreBolt Basic bolt for writing to Redis Various data types are supported: STRING, LIST, HASH, SET, SORTED_SET, HYPER_LOG_LOG, GEO

Uses of IComponent in org.apache.storm.redis.topology

Classes in org.apache.storm.redis.topology that implement IComponent

Modifier and Type	Class and Description
static class	LookupWordCount.PrintWordTotalCountBolt
static class	WhitelistWordCount.PrintWordTotalCountBolt

Uses of IComponent in org.apache.storm.solr.bolt

Classes in org.apache.storm.solr.bolt that implement IComponent

Modifier and Type	Class and Description
class	SolrUpdateBolt

Uses of IComponent in org.apache.storm.solr.spout

Classes in org.apache.storm.solr.spout that implement IComponent

Modifier and Type	Class and Description
class	SolrFieldsSpout
class	SolrJsonSpout

Uses of IComponent in org.apache.storm.spout

Classes in org.apache.storm.spout that implement IComponent

Modifier and Type	Class and Description
class	CheckpointSpout Emits checkpoint tuples which is used to save the state of the IStatefulComponent across the topology.

Uses of IComponent in org.apache.storm.starter

Classes in org.apache.storm.starter that implement IComponent

Modifier and Type	Class and Description
static class	AnchoredWordCount.RandomSentenceSpout
static class	AnchoredWordCount.SplitSentence
static class	AnchoredWordCount.WordCount
static class	BasicDRPCTopology.ExclaimBolt
static class	BlobStoreAPIWordCountTopology.FilterWords
static class	BlobStoreAPIWordCountTopology.RandomSentenceSpout
static class	BlobStoreAPIWordCountTopology.SplitSentence
static class	ExclamationTopology.ExclamationBolt
static class	FastWordCountTopology.FastRandomSentenceSpout
static class	FastWordCountTopology.SplitSentence
static class	FastWordCountTopology.WordCount
static class	InOrderDeliveryTest.Check
static class	InOrderDeliveryTest.InOrderSpout
static class	ManualDRPC.ExclamationBolt
static class	MultipleLoggerTopology.ExclamationLoggingBolt
static class	ReachTopology.CountAggregator
static class	ReachTopology.GetFollowers
static class	ReachTopology.GetTweeters
static class	ReachTopology.PartialUniquer
static class	ResourceAwareExampleTopology.ExclamationBolt
static class	ThroughputVsLatency.FastRandomSentenceSpout
static class	ThroughputVsLatency.SplitSentence
static class	ThroughputVsLatency.WordCount
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

Uses of IComponent in org.apache.storm.starter.bolt

Classes in org.apache.storm.starter.bolt that implement IComponent

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	RollingCountAggBolt This bolt aggregates counts from multiple upstream bolts.
class	RollingCountBolt This bolt performs rolling counts of incoming objects, i.e.
class	SingleJoinBolt Example of a simple custom bolt for joining two streams NOTE: Prefer to use the built-in JoinBolt wherever applicable
class	SlidingWindowSumBolt Computes sliding window sum
class	TotalRankingsBolt This bolt merges incoming Rankings.

Uses of IComponent in org.apache.storm.starter.spout

Classes in org.apache.storm.starter.spout that implement IComponent

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

Uses of IComponent in org.apache.storm.testing

Classes in org.apache.storm.testing that implement IComponent

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	TestWordBytesCounter
class	TestWordCounter
class	TestWordSpout
class	TupleCaptureBolt

Uses of IComponent in org.apache.storm.topology

Subinterfaces of IComponent in org.apache.storm.topology

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
interface	IStatefulBolt<T extends State> A bolt abstraction for supporting stateful computation.
interface	IStatefulComponent<T extends State> Common methods for stateful components in the topology.
interface	IStatefulWindowedBolt<T extends State> A windowed bolt abstraction for supporting windowing operation with state
interface	IWindowedBolt A bolt abstraction for supporting time and count based sliding & tumbling windows.

Classes in org.apache.storm.topology that implement IComponent

Modifier and Type	Class and Description
class	BaseStatefulBoltExecutor Base class that abstracts the common logic for executing bolts in a stateful topology.
class	BasicBoltExecutor
class	CheckpointTupleForwarder Wraps IRichBolt and forwards checkpoint tuples in a stateful topology.
class	StatefulBoltExecutor<T extends State> Wraps a IStatefulBolt and manages the state of the bolt.
class	StatefulWindowedBoltExecutor<T extends State> Wraps a IStatefulWindowedBolt and handles the execution.
class	WindowedBoltExecutor An IWindowedBolt wrapper that does the windowing of tuples.

Uses of IComponent in org.apache.storm.topology.base

Classes in org.apache.storm.topology.base that implement IComponent

Modifier and Type	Class and Description
class	BaseBasicBolt
class	BaseBatchBolt<T>
class	BaseComponent
class	BaseOpaquePartitionedTransactionalSpout<T>
class	BasePartitionedTransactionalSpout<T>
class	BaseRichBolt
class	BaseRichSpout
class	BaseStatefulBolt<T extends State>
class	BaseStatefulWindowedBolt<T extends State>
class	BaseTickTupleAwareRichBolt This class is based on BaseRichBolt, but is aware of tick tuple.
class	BaseTransactionalBolt
class	BaseTransactionalSpout<T>
class	BaseWindowedBolt

Uses of IComponent in org.apache.storm.transactional

Subinterfaces of IComponent in org.apache.storm.transactional

Modifier and Type	Interface and Description
interface	ICommitterTransactionalSpout<X>
interface	ITransactionalSpout<T>

Classes in org.apache.storm.transactional that implement IComponent

Modifier and Type	Class and Description
class	TransactionalSpoutBatchExecutor
class	TransactionalSpoutCoordinator

Uses of IComponent in org.apache.storm.transactional.partitioned

Subinterfaces of IComponent in org.apache.storm.transactional.partitioned

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.

Classes in org.apache.storm.transactional.partitioned that implement IComponent

Modifier and Type	Class and Description
class	OpaquePartitionedTransactionalSpoutExecutor
class	PartitionedTransactionalSpoutExecutor

Uses of IComponent in org.apache.storm.trident.planner

Classes in org.apache.storm.trident.planner that implement IComponent

Modifier and Type	Class and Description
class	SubtopologyBolt

Uses of IComponent in org.apache.storm.trident.spout

Classes in org.apache.storm.trident.spout that implement IComponent

Modifier and Type	Class and Description
class	RichSpoutBatchTriggerer
class	TridentSpoutCoordinator
class	TridentSpoutExecutor

Uses of IComponent in org.apache.storm.trident.topology

Subinterfaces of IComponent in org.apache.storm.trident.topology

Modifier and Type	Interface and Description
interface	ITridentBatchBolt

Classes in org.apache.storm.trident.topology that implement IComponent

Modifier and Type	Class and Description
class	MasterBatchCoordinator
class	TridentBoltExecutor

Uses of IComponent in org.apache.storm.trident.util

Methods in org.apache.storm.trident.util with parameters of type IComponent

Modifier and Type	Method and Description
static Fields	TridentUtils.getSingleOutputStreamFields(IComponent component)

Uses of IComponent in storm.starter

Classes in storm.starter that implement IComponent

Modifier and Type	Class and Description
static class	StatefulTopology.PrinterBolt