Package org.apache.storm.redis.bolt
Class RedisStoreBolt
- All Implemented Interfaces:
Serializable,IBolt,IComponent,IRichBolt
Basic bolt for writing to Redis.
Various data types are supported: STRING, LIST, HASH, SET, SORTED_SET, HYPER_LOG_LOG, GEO
- See Also:
-
Field Summary
Fields inherited from class org.apache.storm.redis.bolt.AbstractRedisBolt
collector -
Constructor Summary
ConstructorsConstructorDescriptionRedisStoreBolt(JedisClusterConfig config, RedisStoreMapper storeMapper) Constructor for Redis Cluster environment (JedisCluster).RedisStoreBolt(JedisPoolConfig config, RedisStoreMapper storeMapper) Constructor for single Redis environment (JedisPool). -
Method Summary
Modifier and TypeMethodDescriptionvoiddeclareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.voidProcess a single non-tick tuple of input.Methods inherited from class org.apache.storm.redis.bolt.AbstractRedisBolt
cleanup, getInstance, prepareMethods inherited from class org.apache.storm.topology.base.BaseTickTupleAwareRichBolt
execute, onTickTupleMethods inherited from class org.apache.storm.topology.base.BaseComponent
getComponentConfigurationMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.topology.IComponent
getComponentConfiguration
-
Constructor Details
-
RedisStoreBolt
Constructor for single Redis environment (JedisPool).- Parameters:
config- configuration for initializing JedisPoolstoreMapper- mapper containing which datatype, storing value's key that Bolt uses
-
RedisStoreBolt
Constructor for Redis Cluster environment (JedisCluster).- Parameters:
config- configuration for initializing JedisClusterstoreMapper- mapper containing which datatype, storing value's key that Bolt uses
-
-
Method Details
-
process
Process a single non-tick tuple of input. Implementation needs to handle ack manually. More details onIBolt.execute(Tuple).- Specified by:
processin classBaseTickTupleAwareRichBolt- Parameters:
input- The input tuple to be processed.
-
declareOutputFields
Declare the output schema for all the streams of this topology.- Parameters:
declarer- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
-