@Configuration public abstract class AbstractClusterConfiguration extends Object
Constructor and Description |
---|
AbstractClusterConfiguration() |
Modifier and Type | Method and Description |
---|---|
CassandraClusterFactoryBean |
cluster()
Creates a
CassandraClusterFactoryBean 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.Cluster |
getRequiredCluster()
Returns the initialized
Cluster instance. |
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 . |
protected com.datastax.driver.core.Cluster getRequiredCluster()
Cluster
instance.Cluster
.IllegalStateException
- if the cluster factory is not initialized.@Bean public CassandraClusterFactoryBean cluster()
CassandraClusterFactoryBean
that provides a Cassandra Cluster
.
The lifecycle of CassandraClusterFactoryBean
executes startup
and
shutdown
scripts.CassandraClusterFactoryBean
.cluster()
,
getStartupScripts()
,
getShutdownScripts()
@Nullable protected com.datastax.driver.core.policies.AddressTranslator getAddressTranslator()
AddressTranslator
.AddressTranslator
; may be null.@Nullable protected com.datastax.driver.core.AuthProvider getAuthProvider()
AuthProvider
.AuthProvider
, may be null.@Nullable protected ClusterBuilderConfigurer getClusterBuilderConfigurer()
ClusterBuilderConfigurer
.ClusterBuilderConfigurer
; may be null.@Nullable protected String getClusterName()
@Nullable protected CompressionType getCompressionType()
CompressionType
.CompressionType
, may be null.protected String getContactPoints()
localhost
CassandraClusterFactoryBean.DEFAULT_CONTACT_POINTS
@Nullable protected com.datastax.driver.core.policies.LoadBalancingPolicy getLoadBalancingPolicy()
LoadBalancingPolicy
.LoadBalancingPolicy
, may be null.protected int getMaxSchemaAgreementWaitSeconds()
protected boolean getMetricsEnabled()
CassandraClusterFactoryBean.DEFAULT_METRICS_ENABLED
protected com.datastax.driver.core.NettyOptions getNettyOptions()
NettyOptions
. Defaults to NettyOptions.DEFAULT_INSTANCE
.NettyOptions
to customize netty behavior.@Nullable protected com.datastax.driver.core.PoolingOptions getPoolingOptions()
PoolingOptions
.PoolingOptions
, may be null.protected int getPort()
9042
.CassandraClusterFactoryBean.DEFAULT_PORT
protected com.datastax.driver.core.ProtocolVersion getProtocolVersion()
ProtocolVersion
. Defaults to ProtocolVersion.NEWEST_SUPPORTED
.ProtocolVersion
.ProtocolVersion#NEWEST_SUPPORTED.
@Nullable protected com.datastax.driver.core.QueryOptions getQueryOptions()
QueryOptions
.QueryOptions
, may be null.@Nullable protected com.datastax.driver.core.policies.ReconnectionPolicy getReconnectionPolicy()
ReconnectionPolicy
.ReconnectionPolicy
, may be null.@Nullable protected com.datastax.driver.core.policies.RetryPolicy getRetryPolicy()
RetryPolicy
.RetryPolicy
, may be null.@Nullable protected com.datastax.driver.core.policies.SpeculativeExecutionPolicy getSpeculativeExecutionPolicy()
SpeculativeExecutionPolicy
.SpeculativeExecutionPolicy
; may be null.@Nullable protected com.datastax.driver.core.SocketOptions getSocketOptions()
SocketOptions
.SocketOptions
, may be null.@Nullable protected com.datastax.driver.core.TimestampGenerator getTimestampGenerator()
TimestampGenerator
.TimestampGenerator
; may be null.protected List<CreateKeyspaceSpecification> getKeyspaceCreations()
Cluster
initialization.null
protected List<DropKeyspaceSpecification> getKeyspaceDrops()
Cluster
shutdown.null
protected List<String> getStartupScripts()
keyspace creations
and after
Cluster
initialization.null
protected List<String> getShutdownScripts()
keyspace drops
and right before
Cluster
shutdown.null
Copyright © 2011–2018 Pivotal Software, Inc.. All rights reserved.