public class CassandraConf extends Object implements Serializable
Configuration used by cassandra storm components.
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 and Description |
---|
CassandraConf()
Creates a new
CassandraConf instance. |
CassandraConf(Map<String,Object> conf)
Creates a new
CassandraConf instance. |
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() |
public static final String CASSANDRA_USERNAME
public static final String CASSANDRA_PASSWORD
public static final String CASSANDRA_KEYSPACE
public static final String CASSANDRA_CONSISTENCY_LEVEL
public static final String CASSANDRA_NODES
public static final String CASSANDRA_PORT
public static final String CASSANDRA_BATCH_SIZE_ROWS
public static final String CASSANDRA_RETRY_POLICY
public static final String CASSANDRA_RECONNECT_POLICY_BASE_MS
public static final String CASSANDRA_RECONNECT_POLICY_MAX_MS
public static final String CASSANDRA_POOL_MAX_SIZE
public static final String CASSANDRA_LOAD_BALANCING_POLICY
public static final String CASSANDRA_DATACENTER_NAME
public static final String CASSANDRA_MAX_REQUESTS_PER_CON_LOCAL
public static final String CASSANDRA_MAX_REQUESTS_PER_CON_REMOTE
public static final String CASSANDRA_HEARTBEAT_INTERVAL_SEC
public static final String CASSANDRA_IDLE_TIMEOUT_SEC
public static final String CASSANDRA_SOCKET_READ_TIMEOUT_MS
public static final String CASSANDRA_SOCKET_CONNECT_TIMEOUT_MS
public CassandraConf()
Creates a new CassandraConf
instance.
public CassandraConf(Map<String,Object> conf)
Creates a new CassandraConf
instance.
conf
- The storm configuration.public String getUsername()
public String getPassword()
public String getKeyspace()
public String[] getNodes()
public com.datastax.driver.core.ConsistencyLevel getConsistencyLevel()
public int getBatchSizeRows()
public int getPort()
public long getReconnectionPolicyBaseMs()
public long getReconnectionPolicyMaxMs()
public com.datastax.driver.core.policies.RetryPolicy getRetryPolicy()
public com.datastax.driver.core.policies.LoadBalancingPolicy getLoadBalancingPolicy()
public int getPoolMaxQueueSize()
public String getDatacenterName()
public int getMaxRequestPerConnectionLocal()
public int getMaxRequestPerConnectionRemote()
public int getHeartbeatIntervalSeconds()
public int getIdleTimeoutSeconds()
public long getSocketReadTimeoutMillis()
public long getSocketConnectTimeoutMillis()
Copyright © 2022 The Apache Software Foundation. All rights reserved.