| Modifier and Type | Class and Description | 
|---|---|
class  | 
BaseCassandraBolt<T>
A base cassandra bolt. 
 | 
class  | 
BatchCassandraWriterBolt  | 
class  | 
CassandraWriterBolt  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
JoinResult  | 
class  | 
ReturnResults  | 
| 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. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractEsBolt  | 
class  | 
EsIndexBolt
Basic bolt for storing tuple to ES document. 
 | 
class  | 
EsLookupBolt  | 
class  | 
EsPercolateBolt
Basic bolt for retrieve matched percolate queries. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
EventHubBolt
A bolt that writes event message to EventHub. 
 | 
| 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  | 
AvroGenericRecordBolt  | 
class  | 
HdfsBolt  | 
static class  | 
HdfsFileTopology.MyBolt  | 
class  | 
SequenceFileBolt  | 
static class  | 
SequenceFileTopology.MyBolt  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
HdfsSpoutTopology.ConstBolt  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
HiveBolt  | 
| 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. 
 | 
| 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). | 
| 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. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KafkaBolt<K,V>
Deprecated. 
 
Please use the KafkaBolt in storm-kafka-client 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractMongoBolt  | 
class  | 
MongoInsertBolt
Basic bolt for writing to MongoDB. 
 | 
class  | 
MongoUpdateBolt
Basic bolt for updating from MongoDB. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
MqttBolt  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
OpenTsdbBolt
Basic bolt implementation for storing timeseries datapoints to OpenTSDB. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DevNullBolt  | 
class  | 
IdBolt  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
IdentityBolt  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
PMMLPredictorBolt  | 
| 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 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
LookupWordCount.PrintWordTotalCountBolt  | 
static class  | 
WhitelistWordCount.PrintWordTotalCountBolt  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SolrUpdateBolt  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
ExclamationTopology.ExclamationBolt  | 
static class  | 
MultipleLoggerTopology.ExclamationLoggingBolt  | 
static class  | 
ResourceAwareExampleTopology.ExclamationBolt  | 
| 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 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TestAggregatesCounter  | 
class  | 
TestEventOrderCheckBolt  | 
class  | 
TestGlobalCount  | 
class  | 
TestPlannerBolt  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BaseTickTupleAwareRichBolt
This class is based on BaseRichBolt, but is aware of tick tuple. 
 | 
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.