Class Policies


  • public class Policies
    extends Object
    Policies configured for a Cluster instance.
    • Method Detail

      • builder

        public static Policies.Builder builder()
        Returns a builder to create a new Policies object.
        Returns:
        the builder.
      • defaultLoadBalancingPolicy

        public static LoadBalancingPolicy defaultLoadBalancingPolicy()
        The default load balancing policy.

        The default load balancing policy is DCAwareRoundRobinPolicy with token awareness (so new TokenAwarePolicy(new DCAwareRoundRobinPolicy())).

        Note that this policy shuffles the replicas when token awareness is used, see TokenAwarePolicy(LoadBalancingPolicy, boolean) for an explanation of the tradeoffs.

        Returns:
        the default load balancing policy.
      • defaultReconnectionPolicy

        public static ReconnectionPolicy defaultReconnectionPolicy()
        The default reconnection policy.

        The default reconnection policy is an ExponentialReconnectionPolicy where the base delay is 1 second and the max delay is 10 minutes;

        Returns:
        the default reconnection policy.
      • defaultRetryPolicy

        public static RetryPolicy defaultRetryPolicy()
        The default retry policy.

        The default retry policy is DefaultRetryPolicy.

        Returns:
        the default retry policy.
      • defaultAddressTranslator

        public static AddressTranslator defaultAddressTranslator()
        The default address translator.

        The default address translator is IdentityTranslator.

        Returns:
        the default address translator.
      • defaultSpeculativeExecutionPolicy

        public static SpeculativeExecutionPolicy defaultSpeculativeExecutionPolicy()
        The default speculative retry policy.

        The default speculative retry policy is a NoSpeculativeExecutionPolicy.

        Returns:
        the default speculative retry policy.
      • defaultEndPointFactory

        public static EndPointFactory defaultEndPointFactory()
      • getLoadBalancingPolicy

        public LoadBalancingPolicy getLoadBalancingPolicy()
        The load balancing policy in use.

        The load balancing policy defines how Cassandra hosts are picked for queries.

        Returns:
        the load balancing policy in use.
      • getReconnectionPolicy

        public ReconnectionPolicy getReconnectionPolicy()
        The reconnection policy in use.

        The reconnection policy defines how often the driver tries to reconnect to a dead node.

        Returns:
        the reconnection policy in use.
      • getRetryPolicy

        public RetryPolicy getRetryPolicy()
        The retry policy in use.

        The retry policy defines in which conditions a query should be automatically retries by the driver.

        Returns:
        the retry policy in use.
      • getAddressTranslator

        public AddressTranslator getAddressTranslator()
        The address translator in use.
        Returns:
        the address translator in use.
      • getTimestampGenerator

        public TimestampGenerator getTimestampGenerator()
        The timestamp generator to use.
        Returns:
        the timestamp generator to use.
      • getSpeculativeExecutionPolicy

        public SpeculativeExecutionPolicy getSpeculativeExecutionPolicy()
        The speculative execution policy in use.
        Returns:
        the speculative execution policy in use.