Package | Description |
---|---|
org.apache.flink.streaming.connectors.redis.common.container |
Modifier and Type | Class and Description |
---|---|
class |
RedisClusterContainer
Redis command container if we want to connect to a Redis cluster.
|
class |
RedisContainer
Redis command container if we want to connect to a single Redis server or to Redis sentinels
If want to connect to a single Redis server, please use the first constructor
RedisContainer.RedisContainer(JedisPool) . |
Modifier and Type | Method and Description |
---|---|
static RedisCommandsContainer |
RedisCommandsContainerBuilder.build(FlinkJedisClusterConfig jedisClusterConfig)
Builds container for Redis Cluster environment.
|
static RedisCommandsContainer |
RedisCommandsContainerBuilder.build(FlinkJedisConfigBase flinkJedisConfigBase)
Initialize the
RedisCommandsContainer based on the instance type. |
static RedisCommandsContainer |
RedisCommandsContainerBuilder.build(FlinkJedisPoolConfig jedisPoolConfig)
Builds container for single Redis environment.
|
static RedisCommandsContainer |
RedisCommandsContainerBuilder.build(FlinkJedisSentinelConfig jedisSentinelConfig)
Builds container for Redis Sentinel environment.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.