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.