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, returnInstance
execute, onTickTuple
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getComponentConfiguration
public 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 BaseTickTupleAwareRichBolt
input
- 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 © 2022 The Apache Software Foundation. All rights reserved.