Uses of Class
org.apache.storm.topology.base.BaseComponent

Packages that use BaseComponent

Package	Description
org.apache.storm
org.apache.storm.cassandra.bolt
org.apache.storm.drpc
org.apache.storm.elasticsearch.bolt	ElasticSearch examples classes.
org.apache.storm.eventhubs.bolt
org.apache.storm.eventhubs.spout
org.apache.storm.flux.examples
org.apache.storm.flux.wrappers.bolts
org.apache.storm.hbase.bolt
org.apache.storm.hdfs.bolt
org.apache.storm.hdfs.spout
org.apache.storm.hive.bolt
org.apache.storm.jdbc.bolt
org.apache.storm.jms.bolt
org.apache.storm.jms.example
org.apache.storm.jms.spout
org.apache.storm.kafka.bolt
org.apache.storm.kafka.spout
org.apache.storm.kinesis.spout
org.apache.storm.lambda
org.apache.storm.loadgen
org.apache.storm.mongodb.bolt
org.apache.storm.mqtt.bolt
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.sql.runtime.datasource.socket.bolt
org.apache.storm.st.topology.window
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.starter.spout
org.apache.storm.testing
org.apache.storm.topology.base
org.apache.storm.trident.topology

Uses of BaseComponent in org.apache.storm

Subclasses of BaseComponent in org.apache.storm

Modifier and Type	Class and Description
static class	ExclamationTopology.ExclamationBolt
static class	ExclamationTopology.FixedOrderWordSpout

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

Subclasses of BaseComponent in org.apache.storm.cassandra.bolt

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

Uses of BaseComponent in org.apache.storm.drpc

Subclasses of BaseComponent in org.apache.storm.drpc

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

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

Subclasses of BaseComponent in org.apache.storm.elasticsearch.bolt

Modifier and Type	Class and Description
class	AbstractEsBolt
class	EsIndexBolt Basic bolt for storing tuple to ES document.
static class	EsIndexTopology.UserDataSpout The user data spout.
class	EsLookupBolt Basic bolt for looking up document in ES.
class	EsPercolateBolt Basic bolt for retrieve matched percolate queries.

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

Subclasses of BaseComponent in org.apache.storm.eventhubs.bolt

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

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

Subclasses of BaseComponent in org.apache.storm.eventhubs.spout

Modifier and Type	Class and Description
class	EventHubSpout

Uses of BaseComponent in org.apache.storm.flux.examples

Subclasses of BaseComponent in org.apache.storm.flux.examples

Modifier and Type	Class and Description
class	TestPrintBolt Prints the tuples to stdout.
class	WordCounter This bolt is used by the HBase example.

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

Subclasses of BaseComponent in org.apache.storm.flux.wrappers.bolts

Modifier and Type	Class and Description
class	LogInfoBolt Simple bolt that does nothing other than LOG.info() every tuple recieveed.

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

Subclasses of BaseComponent in org.apache.storm.hbase.bolt

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 BaseComponent in org.apache.storm.hdfs.bolt

Subclasses of BaseComponent in org.apache.storm.hdfs.bolt

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 BaseComponent in org.apache.storm.hdfs.spout

Subclasses of BaseComponent in org.apache.storm.hdfs.spout

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

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

Subclasses of BaseComponent in org.apache.storm.hive.bolt

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

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

Subclasses of BaseComponent in org.apache.storm.jdbc.bolt

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 BaseComponent in org.apache.storm.jms.bolt

Subclasses of BaseComponent in org.apache.storm.jms.bolt

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 BaseComponent in org.apache.storm.jms.example

Subclasses of BaseComponent in org.apache.storm.jms.example

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 BaseComponent in org.apache.storm.jms.spout

Subclasses of BaseComponent in org.apache.storm.jms.spout

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 BaseComponent in org.apache.storm.kafka.bolt

Subclasses of BaseComponent in org.apache.storm.kafka.bolt

Modifier and Type	Class and Description
class	KafkaBolt<K,V> Bolt implementation that can send Tuple data to Kafka.

Uses of BaseComponent in org.apache.storm.kafka.spout

Subclasses of BaseComponent in org.apache.storm.kafka.spout

Modifier and Type	Class and Description
class	KafkaSpout<K,V>
class	KafkaSpoutTestBolt

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

Subclasses of BaseComponent in org.apache.storm.kinesis.spout

Modifier and Type	Class and Description
class	KinesisSpout

Uses of BaseComponent in org.apache.storm.lambda

Subclasses of BaseComponent in org.apache.storm.lambda

Modifier and Type	Class and Description
class	LambdaBiConsumerBolt
class	LambdaConsumerBolt
class	LambdaSpout

Uses of BaseComponent in org.apache.storm.loadgen

Subclasses of BaseComponent in org.apache.storm.loadgen

Modifier and Type	Class and Description
class	LoadBolt A bolt that simulates a real world bolt based off of statistics about it.
class	LoadSpout A spout that simulates a real world spout based off of statistics about it.
static class	ThroughputVsLatency.FastRandomSentenceSpout
static class	ThroughputVsLatency.SplitSentence
static class	ThroughputVsLatency.WordCount

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

Subclasses of BaseComponent in org.apache.storm.mongodb.bolt

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

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

Subclasses of BaseComponent in org.apache.storm.mqtt.bolt

Modifier and Type	Class and Description
class	MqttBolt

Uses of BaseComponent in org.apache.storm.opentsdb

Subclasses of BaseComponent in org.apache.storm.opentsdb

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

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

Subclasses of BaseComponent in org.apache.storm.opentsdb.bolt

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

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

Subclasses of BaseComponent in org.apache.storm.perf.bolt

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

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

Subclasses of BaseComponent in org.apache.storm.perf.spout

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

Uses of BaseComponent in org.apache.storm.pmml

Subclasses of BaseComponent in org.apache.storm.pmml

Modifier and Type	Class and Description
class	PMMLPredictorBolt
class	RawInputFromCSVSpout

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

Subclasses of BaseComponent in org.apache.storm.redis.bolt

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.

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

Subclasses of BaseComponent in org.apache.storm.redis.topology

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

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

Subclasses of BaseComponent in org.apache.storm.solr.bolt

Modifier and Type	Class and Description
class	SolrUpdateBolt

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

Subclasses of BaseComponent in org.apache.storm.solr.spout

Modifier and Type	Class and Description
class	SolrFieldsSpout
class	SolrJsonSpout

Uses of BaseComponent in org.apache.storm.spout

Subclasses of BaseComponent in org.apache.storm.spout

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 BaseComponent in org.apache.storm.sql.runtime.datasource.socket.bolt

Subclasses of BaseComponent in org.apache.storm.sql.runtime.datasource.socket.bolt

Modifier and Type	Class and Description
class	SocketBolt The Bolt implementation for Socket.

Uses of BaseComponent in org.apache.storm.st.topology.window

Subclasses of BaseComponent in org.apache.storm.st.topology.window

Modifier and Type	Class and Description
class	IncrementingSpout
class	TimeDataIncrementingSpout

Uses of BaseComponent in org.apache.storm.starter

Subclasses of BaseComponent in org.apache.storm.starter

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	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	StatefulTopology.PrinterBolt
static class	WordCountTopology.WordCount
static class	WordCountTopologyNode.WordCount

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

Subclasses of BaseComponent in org.apache.storm.starter.bolt

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.
class	TotalRankingsBolt This bolt merges incoming Rankings.

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

Subclasses of BaseComponent in org.apache.storm.starter.spout

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 BaseComponent in org.apache.storm.testing

Subclasses of BaseComponent in org.apache.storm.testing

Modifier and Type	Class and Description
class	FeederSpout
class	IdentityBolt
class	PrepareBatchBolt
class	SpoutTracker
class	TestAggregatesCounter
class	TestConfBolt
class	TestEventLogSpout
class	TestEventOrderCheckBolt
class	TestGlobalCount
class	TestPlannerBolt
class	TestPlannerSpout
class	TestWordBytesCounter
class	TestWordCounter
class	TestWordSpout

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

Subclasses of BaseComponent in org.apache.storm.topology.base

Modifier and Type	Class and Description
class	BaseBasicBolt
class	BaseBatchBolt<T>
class	BaseRichBolt
class	BaseRichSpout
class	BaseTickTupleAwareRichBolt This class is based on BaseRichBolt, but is aware of tick tuple.

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

Subclasses of BaseComponent in org.apache.storm.trident.topology

Modifier and Type	Class and Description
class	MasterBatchCoordinator