org.apache.storm.cassandra.client

Class CassandraConf

java.lang.Object

org.apache.storm.cassandra.client.CassandraConf

All Implemented Interfaces:

Serializable

public class CassandraConf
extends Object
implements Serializable

Configuration used by cassandra storm components.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	CASSANDRA_BATCH_SIZE_ROWS
static String	CASSANDRA_CONSISTENCY_LEVEL
static String	CASSANDRA_DATACENTER_NAME
static String	CASSANDRA_HEARTBEAT_INTERVAL_SEC
static String	CASSANDRA_IDLE_TIMEOUT_SEC
static String	CASSANDRA_KEYSPACE
static String	CASSANDRA_LOAD_BALANCING_POLICY
static String	CASSANDRA_MAX_REQUESTS_PER_CON_LOCAL
static String	CASSANDRA_MAX_REQUESTS_PER_CON_REMOTE
static String	CASSANDRA_NODES
static String	CASSANDRA_PASSWORD
static String	CASSANDRA_POOL_MAX_SIZE
static String	CASSANDRA_PORT
static String	CASSANDRA_RECONNECT_POLICY_BASE_MS
static String	CASSANDRA_RECONNECT_POLICY_MAX_MS
static String	CASSANDRA_RETRY_POLICY
static String	CASSANDRA_SOCKET_CONNECT_TIMEOUT_MS
static String	CASSANDRA_SOCKET_READ_TIMEOUT_MS
static String	CASSANDRA_USERNAME

Constructor Summary

Constructors

Constructor and Description
CassandraConf() Creates a new CassandraConf instance.
CassandraConf(Map<String,Object> conf) Creates a new CassandraConf instance.

Method Summary

Modifier and Type	Method and Description
int	getBatchSizeRows()
com.datastax.driver.core.ConsistencyLevel	getConsistencyLevel()
String	getDatacenterName()
int	getHeartbeatIntervalSeconds()
int	getIdleTimeoutSeconds()
static Integer	getInt(Object o, Integer defaultValue)
String	getKeyspace()
com.datastax.driver.core.policies.LoadBalancingPolicy	getLoadBalancingPolicy()
static Long	getLong(Object o, Long defaultValue)
int	getMaxRequestPerConnectionLocal()
int	getMaxRequestPerConnectionRemote()
String[]	getNodes()
String	getPassword()
int	getPoolMaxQueueSize()
int	getPort()
long	getReconnectionPolicyBaseMs()
long	getReconnectionPolicyMaxMs()
com.datastax.driver.core.policies.RetryPolicy	getRetryPolicy()
long	getSocketConnectTimeoutMillis()
long	getSocketReadTimeoutMillis()
String	getUsername()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

CASSANDRA_USERNAME

public static final String CASSANDRA_USERNAME

See Also:

Constant Field Values

CASSANDRA_PASSWORD

public static final String CASSANDRA_PASSWORD

See Also:

Constant Field Values

CASSANDRA_KEYSPACE

public static final String CASSANDRA_KEYSPACE

See Also:

Constant Field Values

CASSANDRA_CONSISTENCY_LEVEL

public static final String CASSANDRA_CONSISTENCY_LEVEL

See Also:

Constant Field Values

CASSANDRA_NODES

public static final String CASSANDRA_NODES

See Also:

Constant Field Values

CASSANDRA_PORT

public static final String CASSANDRA_PORT

See Also:

Constant Field Values

CASSANDRA_BATCH_SIZE_ROWS

public static final String CASSANDRA_BATCH_SIZE_ROWS

See Also:

Constant Field Values

CASSANDRA_RETRY_POLICY

public static final String CASSANDRA_RETRY_POLICY

See Also:

Constant Field Values

CASSANDRA_RECONNECT_POLICY_BASE_MS

public static final String CASSANDRA_RECONNECT_POLICY_BASE_MS

See Also:

Constant Field Values

CASSANDRA_RECONNECT_POLICY_MAX_MS

public static final String CASSANDRA_RECONNECT_POLICY_MAX_MS

See Also:

Constant Field Values

CASSANDRA_POOL_MAX_SIZE

public static final String CASSANDRA_POOL_MAX_SIZE

See Also:

Constant Field Values

CASSANDRA_LOAD_BALANCING_POLICY

public static final String CASSANDRA_LOAD_BALANCING_POLICY

See Also:

Constant Field Values

CASSANDRA_DATACENTER_NAME

public static final String CASSANDRA_DATACENTER_NAME

See Also:

Constant Field Values

CASSANDRA_MAX_REQUESTS_PER_CON_LOCAL

public static final String CASSANDRA_MAX_REQUESTS_PER_CON_LOCAL

See Also:

Constant Field Values

CASSANDRA_MAX_REQUESTS_PER_CON_REMOTE

public static final String CASSANDRA_MAX_REQUESTS_PER_CON_REMOTE

See Also:

Constant Field Values

CASSANDRA_HEARTBEAT_INTERVAL_SEC

public static final String CASSANDRA_HEARTBEAT_INTERVAL_SEC

See Also:

Constant Field Values

CASSANDRA_IDLE_TIMEOUT_SEC

public static final String CASSANDRA_IDLE_TIMEOUT_SEC

See Also:

Constant Field Values

CASSANDRA_SOCKET_READ_TIMEOUT_MS

public static final String CASSANDRA_SOCKET_READ_TIMEOUT_MS

See Also:

Constant Field Values

CASSANDRA_SOCKET_CONNECT_TIMEOUT_MS

public static final String CASSANDRA_SOCKET_CONNECT_TIMEOUT_MS

See Also:

Constant Field Values

Constructor Detail

CassandraConf

public CassandraConf()

Creates a new CassandraConf instance.

CassandraConf

public CassandraConf(Map<String,Object> conf)

Creates a new CassandraConf instance.

Parameters:

conf - The storm configuration.

Method Detail

getUsername

public String getUsername()

getPassword

public String getPassword()

getKeyspace

public String getKeyspace()

getNodes

public String[] getNodes()

getConsistencyLevel

public com.datastax.driver.core.ConsistencyLevel getConsistencyLevel()

getBatchSizeRows

public int getBatchSizeRows()

getPort

public int getPort()

getReconnectionPolicyBaseMs

public long getReconnectionPolicyBaseMs()

getReconnectionPolicyMaxMs

public long getReconnectionPolicyMaxMs()

getRetryPolicy

public com.datastax.driver.core.policies.RetryPolicy getRetryPolicy()

getLoadBalancingPolicy

public com.datastax.driver.core.policies.LoadBalancingPolicy getLoadBalancingPolicy()

getPoolMaxQueueSize

public int getPoolMaxQueueSize()

getDatacenterName

public String getDatacenterName()

getMaxRequestPerConnectionLocal

public int getMaxRequestPerConnectionLocal()

getMaxRequestPerConnectionRemote

public int getMaxRequestPerConnectionRemote()

getHeartbeatIntervalSeconds

public int getHeartbeatIntervalSeconds()

getIdleTimeoutSeconds

public int getIdleTimeoutSeconds()

getSocketReadTimeoutMillis

public long getSocketReadTimeoutMillis()

getSocketConnectTimeoutMillis

public long getSocketConnectTimeoutMillis()

getInt

public static Integer getInt(Object o,
                             Integer defaultValue)

getLong

public static Long getLong(Object o,
                           Long defaultValue)

toString

public String toString()

Overrides:

toString in class Object