org.apache.beam.sdk.io.redis

Class RedisConnectionConfiguration

java.lang.Object

org.apache.beam.sdk.io.redis.RedisConnectionConfiguration

All Implemented Interfaces:

java.io.Serializable

public abstract class RedisConnectionConfiguration
extends java.lang.Object
implements java.io.Serializable

RedisConnectionConfiguration describes and wraps a connectionConfiguration to Redis server or cluster.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RedisConnectionConfiguration()

Method Summary

Modifier and Type	Method and Description
redis.clients.jedis.Jedis	connect() Connect to the Redis instance.
static RedisConnectionConfiguration	create()
static RedisConnectionConfiguration	create(java.lang.String host, int port)
RedisConnectionConfiguration	enableSSL() Enable SSL connection to Redis server.
void	populateDisplayData(DisplayData.Builder builder) Populate the display data with connectionConfiguration details.
RedisConnectionConfiguration	withAuth(java.lang.String auth) Define the password to authenticate on the Redis server.
RedisConnectionConfiguration	withHost(java.lang.String host) Define the host name of the Redis server.
RedisConnectionConfiguration	withPort(int port) Define the port number of the Redis server.
RedisConnectionConfiguration	withTimeout(int timeout) Define the Redis connection timeout.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedisConnectionConfiguration

public RedisConnectionConfiguration()

Method Detail

create

public static RedisConnectionConfiguration create()

create

public static RedisConnectionConfiguration create(java.lang.String host,
                                                  int port)

withHost

public RedisConnectionConfiguration withHost(java.lang.String host)

Define the host name of the Redis server.

withPort

public RedisConnectionConfiguration withPort(int port)

Define the port number of the Redis server.

withAuth

public RedisConnectionConfiguration withAuth(java.lang.String auth)

Define the password to authenticate on the Redis server.

withTimeout

public RedisConnectionConfiguration withTimeout(int timeout)

Define the Redis connection timeout. A timeout of zero is interpreted as an infinite timeout.

enableSSL

public RedisConnectionConfiguration enableSSL()

Enable SSL connection to Redis server.

connect

public redis.clients.jedis.Jedis connect()

Connect to the Redis instance.

populateDisplayData

public void populateDisplayData(DisplayData.Builder builder)

Populate the display data with connectionConfiguration details.