public class RedisStoreBolt extends AbstractRedisBolt
Basic bolt for writing to Redis.
Various data types are supported: STRING, LIST, HASH, SET, SORTED_SET, HYPER_LOG_LOG, GEO
collector| Constructor and Description |
|---|
RedisStoreBolt(JedisClusterConfig config,
RedisStoreMapper storeMapper)
Constructor for Redis Cluster environment (JedisCluster).
|
RedisStoreBolt(JedisPoolConfig config,
RedisStoreMapper storeMapper)
Constructor for single Redis environment (JedisPool).
|
| Modifier and Type | Method and Description |
|---|---|
void |
declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
void |
process(Tuple input)
Process a single non-tick tuple of input.
|
cleanup, getInstance, prepare, returnInstanceexecute, onTickTuplegetComponentConfigurationclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetComponentConfigurationpublic RedisStoreBolt(JedisPoolConfig config, RedisStoreMapper storeMapper)
Constructor for single Redis environment (JedisPool).
config - configuration for initializing JedisPoolstoreMapper - mapper containing which datatype, storing value’s key that Bolt usespublic RedisStoreBolt(JedisClusterConfig config, RedisStoreMapper storeMapper)
Constructor for Redis Cluster environment (JedisCluster).
config - configuration for initializing JedisClusterstoreMapper - mapper containing which datatype, storing value’s key that Bolt usespublic void process(Tuple input)
Process a single non-tick tuple of input. Implementation needs to handle ack manually. More details on IBolt.execute(Tuple).
process in class BaseTickTupleAwareRichBoltinput - The input tuple to be processed.public void declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
declarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct streamCopyright © 2021 The Apache Software Foundation. All rights reserved.