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 SummaryFields inherited from class org.apache.storm.redis.bolt.AbstractRedisBoltcollector
- 
Constructor SummaryConstructorsConstructorDescriptionRedisStoreBolt(JedisClusterConfig config, RedisStoreMapper storeMapper) Constructor for Redis Cluster environment (JedisCluster).RedisStoreBolt(JedisPoolConfig config, RedisStoreMapper storeMapper) Constructor for single Redis environment (JedisPool).
- 
Method SummaryModifier 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.AbstractRedisBoltcleanup, getInstance, prepareMethods inherited from class org.apache.storm.topology.base.BaseTickTupleAwareRichBoltexecute, onTickTupleMethods inherited from class org.apache.storm.topology.base.BaseComponentgetComponentConfigurationMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.topology.IComponentgetComponentConfiguration
- 
Constructor Details- 
RedisStoreBoltConstructor for single Redis environment (JedisPool).- Parameters:
- config- configuration for initializing JedisPool
- storeMapper- mapper containing which datatype, storing value's key that Bolt uses
 
- 
RedisStoreBoltConstructor for Redis Cluster environment (JedisCluster).- Parameters:
- config- configuration for initializing JedisCluster
- storeMapper- mapper containing which datatype, storing value's key that Bolt uses
 
 
- 
- 
Method Details- 
processProcess a single non-tick tuple of input. Implementation needs to handle ack manually. More details onIBolt.execute(Tuple).- Specified by:
- processin class- BaseTickTupleAwareRichBolt
- Parameters:
- input- The input tuple to be processed.
 
- 
declareOutputFieldsDeclare 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
 
 
-