Constructor and Description |
---|
RedisSink(FlinkJedisConfigBase flinkJedisConfigBase,
RedisMapper<IN> redisSinkMapper)
Creates a new
RedisSink that connects to the Redis server. |
Modifier and Type | Class and Description |
---|---|
class |
FlinkJedisClusterConfig
Configuration for Jedis cluster.
|
class |
FlinkJedisPoolConfig
Configuration for Jedis pool.
|
class |
FlinkJedisSentinelConfig
Configuration for Jedis Sentinel pool.
|
Modifier and Type | Method and Description |
---|---|
static RedisCommandsContainer |
RedisCommandsContainerBuilder.build(FlinkJedisConfigBase flinkJedisConfigBase)
Initialize the
RedisCommandsContainer based on the instance type. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.