Uses of Interface
org.apache.storm.task.IBolt

Packages that use IBolt

Package	Description
org.apache.storm
org.apache.storm.cassandra.bolt
org.apache.storm.clojure
org.apache.storm.coordination
org.apache.storm.daemon
org.apache.storm.drpc
org.apache.storm.elasticsearch.bolt	ElasticSearch examples classes.
org.apache.storm.eventhubs.bolt
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.kafka.bolt
org.apache.storm.kafka.spout
org.apache.storm.loadgen
org.apache.storm.metric
org.apache.storm.mongodb.bolt
org.apache.storm.mqtt.bolt
org.apache.storm.opentsdb.bolt
org.apache.storm.perf.bolt
org.apache.storm.perf.utils
org.apache.storm.planner
org.apache.storm.pmml
org.apache.storm.redis.bolt
org.apache.storm.redis.topology
org.apache.storm.rocketmq.bolt
org.apache.storm.solr.bolt
org.apache.storm.sql.runtime.datasource.socket.bolt
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.trident.topology

Uses of IBolt in org.apache.storm

Classes in org.apache.storm that implement IBolt

Modifier and Type	Class and Description
static class	ExclamationTopology.ExclamationBolt

Methods in org.apache.storm with parameters of type IBolt

Modifier and Type	Method and Description
static Bolt	Thrift.prepareSerializedBoltDetails(Map<GlobalStreamId,Grouping> inputs, IBolt bolt, Map<String,StreamInfo> outputs, Integer parallelismHint, Map<String,Object> conf)

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

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

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

Uses of IBolt in org.apache.storm.clojure

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

Modifier and Type	Class and Description
class	ClojureBolt
class	RichShellBolt

Uses of IBolt in org.apache.storm.coordination

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

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

Uses of IBolt in org.apache.storm.daemon

Classes in org.apache.storm.daemon that implement IBolt

Modifier and Type	Class and Description
class	Acker

Methods in org.apache.storm.daemon that return IBolt

Modifier and Type	Method and Description
static IBolt	StormCommon.makeAckerBolt()
IBolt	StormCommon.makeAckerBoltImpl()

Uses of IBolt in org.apache.storm.drpc

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

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

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

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

Modifier and Type	Class and Description
class	AbstractEsBolt
class	EsIndexBolt Basic bolt for storing tuple to ES document.
class	EsLookupBolt Basic bolt for looking up document in ES.
class	EsPercolateBolt Basic bolt for retrieve matched percolate queries.

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

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

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

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

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

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.

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

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

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

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

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

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

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

Modifier and Type	Class and Description
static class	HdfsSpoutTopology.ConstBolt

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

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

Modifier and Type	Class and Description
class	HiveBolt

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

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

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

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

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

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

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

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

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

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

Classes in org.apache.storm.kafka.spout that implement IBolt

Modifier and Type	Class and Description
class	KafkaSpoutTestBolt

Uses of IBolt in org.apache.storm.loadgen

Classes in org.apache.storm.loadgen that implement IBolt

Modifier and Type	Class and Description
class	LoadBolt A bolt that simulates a real world bolt based off of statistics about it.

Uses of IBolt in org.apache.storm.metric

Classes in org.apache.storm.metric that implement IBolt

Modifier and Type	Class and Description
class	EventLoggerBolt
class	MetricsConsumerBolt
class	SystemBolt

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

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

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 IBolt in org.apache.storm.mqtt.bolt

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

Modifier and Type	Class and Description
class	MqttBolt

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

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

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

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

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

Modifier and Type	Class and Description
class	DevNullBolt
class	IdBolt

Uses of IBolt in org.apache.storm.perf.utils

Classes in org.apache.storm.perf.utils that implement IBolt

Modifier and Type	Class and Description
class	IdentityBolt

Uses of IBolt in org.apache.storm.planner

Fields in org.apache.storm.planner declared as IBolt

Modifier and Type	Field and Description
IBolt	TaskBundle.task

Constructors in org.apache.storm.planner with parameters of type IBolt

Constructor and Description
TaskBundle(IBolt task, int componentId)

Uses of IBolt in org.apache.storm.pmml

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

Modifier and Type	Class and Description
class	PMMLPredictorBolt

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

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

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 IBolt in org.apache.storm.redis.topology

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

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

Uses of IBolt in org.apache.storm.rocketmq.bolt

Classes in org.apache.storm.rocketmq.bolt that implement IBolt

Modifier and Type	Class and Description
class	RocketMqBolt

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

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

Modifier and Type	Class and Description
class	SolrUpdateBolt

Uses of IBolt in org.apache.storm.sql.runtime.datasource.socket.bolt

Classes in org.apache.storm.sql.runtime.datasource.socket.bolt that implement IBolt

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

Uses of IBolt in org.apache.storm.starter

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

Modifier and Type	Class and Description
static class	BlobStoreAPIWordCountTopology.SplitSentence
static class	MultipleLoggerTopology.ExclamationLoggingBolt
static class	ResourceAwareExampleTopology.ExclamationBolt
static class	WordCountTopology.SplitSentence
static class	WordCountTopologyNode.SplitSentence

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

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

Modifier and Type	Class and Description
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

Uses of IBolt in org.apache.storm.task

Classes in org.apache.storm.task that implement IBolt

Modifier and Type	Class and Description
class	ShellBolt A bolt that shells out to another process to process tuples.

Uses of IBolt in org.apache.storm.testing

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

Modifier and Type	Class and Description
class	BoltTracker
class	NonRichBoltTracker
class	PythonShellMetricsBolt
class	TestAggregatesCounter
class	TestEventOrderCheckBolt
class	TestGlobalCount
class	TestPlannerBolt
class	TupleCaptureBolt

Constructors in org.apache.storm.testing with parameters of type IBolt

Constructor and Description
NonRichBoltTracker(IBolt delegate, String id)

Uses of IBolt in org.apache.storm.topology

Subinterfaces of IBolt in org.apache.storm.topology

Modifier and Type	Interface and Description
interface	IRichBolt When writing topologies using Java, IRichBolt and IRichSpout are the main interfaces to use to implement components of the topology.

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

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	PersistentWindowedBoltExecutor<T extends State> Wraps a IStatefulWindowedBolt and handles the execution.
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 IBolt in org.apache.storm.topology.base

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

Modifier and Type	Class and Description
class	BaseRichBolt
class	BaseTickTupleAwareRichBolt This class is based on BaseRichBolt, but is aware of tick tuple.

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

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

Modifier and Type	Class and Description
class	TridentBoltExecutor