@Configuration public abstract class AbstractClusterConfiguration extends Object
| Constructor and Description |
|---|
AbstractClusterConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
CassandraCqlClusterFactoryBean |
cluster()
Creates a
CassandraCqlClusterFactoryBean that provides a Cassandra
Cluster. |
protected com.datastax.driver.core.policies.AddressTranslator |
getAddressTranslator()
Returns the
AddressTranslator. |
protected com.datastax.driver.core.AuthProvider |
getAuthProvider()
Returns the
AuthProvider. |
protected ClusterBuilderConfigurer |
getClusterBuilderConfigurer()
Returns the
ClusterBuilderConfigurer. |
protected String |
getClusterName()
Returns the cluster name.
|
protected CompressionType |
getCompressionType()
Returns the
CompressionType. |
protected String |
getContactPoints()
Returns the Cassandra contact points.
|
protected List<CreateKeyspaceSpecification> |
getKeyspaceCreations()
Returns the list of keyspace creations to be run right after
Cluster
initialization. |
protected List<DropKeyspaceSpecification> |
getKeyspaceDrops()
Returns the list of keyspace drops to be run before
Cluster shutdown. |
protected com.datastax.driver.core.policies.LoadBalancingPolicy |
getLoadBalancingPolicy()
Returns the
LoadBalancingPolicy. |
protected int |
getMaxSchemaAgreementWaitSeconds()
Returns the maximum schema agreement wait in seconds.
|
protected boolean |
getMetricsEnabled()
Returns the whether to enable metrics.
|
protected com.datastax.driver.core.NettyOptions |
getNettyOptions()
Returns the
NettyOptions. |
protected com.datastax.driver.core.PoolingOptions |
getPoolingOptions()
Returns the
PoolingOptions. |
protected int |
getPort()
Returns the Cassandra port.
|
protected com.datastax.driver.core.ProtocolVersion |
getProtocolVersion()
Returns the
ProtocolVersion. |
protected com.datastax.driver.core.QueryOptions |
getQueryOptions()
Returns the
QueryOptions. |
protected com.datastax.driver.core.policies.ReconnectionPolicy |
getReconnectionPolicy()
Returns the
ReconnectionPolicy. |
protected com.datastax.driver.core.policies.RetryPolicy |
getRetryPolicy()
Returns the
RetryPolicy. |
protected List<String> |
getShutdownScripts()
Returns the list of shutdown scripts to be run after
keyspace drops and right before
Cluster shutdown. |
protected com.datastax.driver.core.SocketOptions |
getSocketOptions()
Returns the
SocketOptions. |
protected com.datastax.driver.core.policies.SpeculativeExecutionPolicy |
getSpeculativeExecutionPolicy()
Returns the
SpeculativeExecutionPolicy. |
protected List<String> |
getStartupScripts()
Returns the list of startup scripts to be run after
keyspace creations and after
Cluster initialization. |
protected com.datastax.driver.core.TimestampGenerator |
getTimestampGenerator()
Returns the
TimestampGenerator. |
@Bean public CassandraCqlClusterFactoryBean cluster()
CassandraCqlClusterFactoryBean that provides a Cassandra
Cluster. The lifecycle of CassandraCqlClusterFactoryBean executes
startup and shutdown scripts.CassandraCqlClusterFactoryBean.cluster(),
getStartupScripts(),
getShutdownScripts()protected com.datastax.driver.core.policies.AddressTranslator getAddressTranslator()
AddressTranslator.AddressTranslator; may be null.protected com.datastax.driver.core.AuthProvider getAuthProvider()
AuthProvider.AuthProvider, may be null.protected ClusterBuilderConfigurer getClusterBuilderConfigurer()
ClusterBuilderConfigurer.ClusterBuilderConfigurer; may be null.protected String getClusterName()
protected CompressionType getCompressionType()
CompressionType.CompressionType, may be null.protected String getContactPoints()
localhostCassandraCqlClusterFactoryBean.DEFAULT_CONTACT_POINTSprotected com.datastax.driver.core.policies.LoadBalancingPolicy getLoadBalancingPolicy()
LoadBalancingPolicy.LoadBalancingPolicy, may be null.protected int getMaxSchemaAgreementWaitSeconds()
protected boolean getMetricsEnabled()
CassandraCqlClusterFactoryBean.DEFAULT_METRICS_ENABLEDprotected com.datastax.driver.core.NettyOptions getNettyOptions()
NettyOptions. Defaults to NettyOptions.DEFAULT_INSTANCE.protected com.datastax.driver.core.PoolingOptions getPoolingOptions()
PoolingOptions.PoolingOptions, may be null.protected int getPort()
9042CassandraCqlClusterFactoryBean.DEFAULT_PORTprotected com.datastax.driver.core.ProtocolVersion getProtocolVersion()
ProtocolVersion.ProtocolVersion, may be null.protected com.datastax.driver.core.QueryOptions getQueryOptions()
QueryOptions.QueryOptions, may be null.protected com.datastax.driver.core.policies.ReconnectionPolicy getReconnectionPolicy()
ReconnectionPolicy.ReconnectionPolicy, may be null.protected com.datastax.driver.core.policies.RetryPolicy getRetryPolicy()
RetryPolicy.RetryPolicy, may be null.protected com.datastax.driver.core.policies.SpeculativeExecutionPolicy getSpeculativeExecutionPolicy()
SpeculativeExecutionPolicy.SpeculativeExecutionPolicy; may be null.protected com.datastax.driver.core.SocketOptions getSocketOptions()
SocketOptions.SocketOptions, may be null.protected com.datastax.driver.core.TimestampGenerator getTimestampGenerator()
TimestampGenerator.TimestampGenerator; may be null.protected List<CreateKeyspaceSpecification> getKeyspaceCreations()
Cluster
initialization.nullprotected List<DropKeyspaceSpecification> getKeyspaceDrops()
Cluster shutdown.nullprotected List<String> getStartupScripts()
keyspace creations and after
Cluster initialization.nullprotected List<String> getShutdownScripts()
keyspace drops and right before
Cluster shutdown.nullCopyright © 2011–2017 Pivotal Software, Inc.. All rights reserved.