Package | Description |
---|---|
org.apache.storm.cassandra.bolt | |
org.apache.storm.elasticsearch.bolt |
ElasticSearch examples classes.
|
org.apache.storm.jdbc.bolt | |
org.apache.storm.jms.bolt | |
org.apache.storm.kafka.bolt | |
org.apache.storm.mqtt.bolt | |
org.apache.storm.pmml | |
org.apache.storm.redis.bolt | |
org.apache.storm.solr.bolt |
Modifier and Type | Class and Description |
---|---|
class |
BaseCassandraBolt<T>
A base cassandra bolt.
|
class |
BatchCassandraWriterBolt |
class |
CassandraWriterBolt |
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.
|
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 |
KafkaBolt<K,V>
Bolt implementation that can send Tuple data to Kafka.
|
Modifier and Type | Class and Description |
---|---|
class |
MqttBolt |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
SolrUpdateBolt |
Copyright © 2019 The Apache Software Foundation. All rights reserved.