com.datastax.driver.core.policies

Class Policies

java.lang.Object

com.datastax.driver.core.policies.Policies

public class Policies
extends Object

Policies configured for a Cluster instance.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Policies.Builder A builder to create a new Policies object.

Constructor Summary

Constructors

Constructor and Description
Policies() Deprecated. this constructor is provided for backward compatibility. Use builder() instead.
Policies(LoadBalancingPolicy loadBalancingPolicy, ReconnectionPolicy reconnectionPolicy, RetryPolicy retryPolicy) Deprecated. this constructor is provided for backward compatibility. Use builder() instead.
Policies(LoadBalancingPolicy loadBalancingPolicy, ReconnectionPolicy reconnectionPolicy, RetryPolicy retryPolicy, AddressTranslater addressTranslater) Deprecated. this constructor is provided for backward compatibility. Use builder() instead.
Policies(LoadBalancingPolicy loadBalancingPolicy, ReconnectionPolicy reconnectionPolicy, RetryPolicy retryPolicy, AddressTranslater addressTranslater, SpeculativeExecutionPolicy speculativeExecutionPolicy) Deprecated. this constructor is provided for backward compatibility. Use builder() instead.
Policies(LoadBalancingPolicy loadBalancingPolicy, ReconnectionPolicy reconnectionPolicy, RetryPolicy retryPolicy, AddressTranslater addressTranslater, TimestampGenerator timestampGenerator) Deprecated. this constructor is provided for backward compatibility. Use builder() instead.
Policies(LoadBalancingPolicy loadBalancingPolicy, ReconnectionPolicy reconnectionPolicy, RetryPolicy retryPolicy, AddressTranslater addressTranslater, TimestampGenerator timestampGenerator, SpeculativeExecutionPolicy speculativeExecutionPolicy) Deprecated. this constructor is exposed for backward compatibility. Use builder() instead.
Policies(LoadBalancingPolicy loadBalancingPolicy, ReconnectionPolicy reconnectionPolicy, RetryPolicy retryPolicy, SpeculativeExecutionPolicy speculativeExecutionPolicy) Deprecated. this constructor is provided for backward compatibility. Use builder() instead.

Method Summary

Modifier and Type	Method and Description
static Policies.Builder	builder() Returns a builder to create a new Policies object.
static AddressTranslater	defaultAddressTranslater() The default address translater.
static LoadBalancingPolicy	defaultLoadBalancingPolicy() The default load balancing policy.
static ReconnectionPolicy	defaultReconnectionPolicy() The default reconnection policy.
static RetryPolicy	defaultRetryPolicy() The default retry policy.
static SpeculativeExecutionPolicy	defaultSpeculativeExecutionPolicy() The default speculative retry policy.
static TimestampGenerator	defaultTimestampGenerator() The default timestamp generator.
AddressTranslater	getAddressTranslater() The address translater in use.
LoadBalancingPolicy	getLoadBalancingPolicy() The load balancing policy in use.
ReconnectionPolicy	getReconnectionPolicy() The reconnection policy in use.
RetryPolicy	getRetryPolicy() The retry policy in use.
SpeculativeExecutionPolicy	getSpeculativeExecutionPolicy() The speculative execution policy in use.
TimestampGenerator	getTimestampGenerator() The timestamp generator to use.

Methods inherited from class java.lang.Object

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

Constructor Detail

Policies

@Deprecated
public Policies(LoadBalancingPolicy loadBalancingPolicy,
                            ReconnectionPolicy reconnectionPolicy,
                            RetryPolicy retryPolicy,
                            AddressTranslater addressTranslater,
                            TimestampGenerator timestampGenerator,
                            SpeculativeExecutionPolicy speculativeExecutionPolicy)

Deprecated. this constructor is exposed for backward compatibility. Use builder() instead.

Policies

@Deprecated
public Policies()

Deprecated. this constructor is provided for backward compatibility. Use builder() instead.

Policies

public Policies(LoadBalancingPolicy loadBalancingPolicy,
                ReconnectionPolicy reconnectionPolicy,
                RetryPolicy retryPolicy)

Deprecated. this constructor is provided for backward compatibility. Use builder() instead.

Policies

public Policies(LoadBalancingPolicy loadBalancingPolicy,
                ReconnectionPolicy reconnectionPolicy,
                RetryPolicy retryPolicy,
                AddressTranslater addressTranslater)

Deprecated. this constructor is provided for backward compatibility. Use builder() instead.

Policies

public Policies(LoadBalancingPolicy loadBalancingPolicy,
                ReconnectionPolicy reconnectionPolicy,
                RetryPolicy retryPolicy,
                SpeculativeExecutionPolicy speculativeExecutionPolicy)

Deprecated. this constructor is provided for backward compatibility. Use builder() instead.

Policies

public Policies(LoadBalancingPolicy loadBalancingPolicy,
                ReconnectionPolicy reconnectionPolicy,
                RetryPolicy retryPolicy,
                AddressTranslater addressTranslater,
                TimestampGenerator timestampGenerator)

Deprecated. this constructor is provided for backward compatibility. Use builder() instead.

Policies

public Policies(LoadBalancingPolicy loadBalancingPolicy,
                ReconnectionPolicy reconnectionPolicy,
                RetryPolicy retryPolicy,
                AddressTranslater addressTranslater,
                SpeculativeExecutionPolicy speculativeExecutionPolicy)

Deprecated. this constructor is provided for backward compatibility. Use builder() instead.

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.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.

defaultAddressTranslater

public static AddressTranslater defaultAddressTranslater()

The default address translater.

The default address translater is IdentityTranslater.

Returns:

the default address translater.

defaultTimestampGenerator

public static TimestampGenerator defaultTimestampGenerator()

The default timestamp generator.

This is an instance of ServerSideTimestampGenerator.

Returns:

the default timestamp generator.

defaultSpeculativeExecutionPolicy

public static SpeculativeExecutionPolicy defaultSpeculativeExecutionPolicy()

The default speculative retry policy.

The default speculative retry policy is a NoSpeculativeExecutionPolicy.

Returns:

the default speculative retry policy.

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.

getAddressTranslater

public AddressTranslater getAddressTranslater()

The address translater in use.

Returns:

the address translater 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.