Package | Description |
---|---|
com.datastax.driver.core |
The main package for the DataStax Java driver for Cassandra.
|
com.datastax.driver.core.exceptions |
Exceptions thrown by the DataStax Java driver for Cassandra.
|
com.datastax.driver.core.policies |
Policies that allow to control some of the behavior of the DataStax Java driver for Cassandra.
|
com.datastax.driver.dse.graph |
Modifier and Type | Field and Description |
---|---|
static ConsistencyLevel |
QueryOptions.DEFAULT_CONSISTENCY_LEVEL
The default consistency level for queries:
LOCAL_ONE . |
static ConsistencyLevel |
QueryOptions.DEFAULT_SERIAL_CONSISTENCY_LEVEL
The default serial consistency level for conditional updates:
SERIAL . |
Modifier and Type | Method and Description |
---|---|
ConsistencyLevel |
ExecutionInfo.getAchievedConsistencyLevel()
If the query returned without achieving the requested consistency level
due to the
RetryPolicy , this
return the biggest consistency level that has been actually achieved by
the query. |
ConsistencyLevel |
StatementWrapper.getConsistencyLevel() |
ConsistencyLevel |
Statement.getConsistencyLevel()
The consistency level for this query.
|
ConsistencyLevel |
QueryOptions.getConsistencyLevel()
The default consistency level used by queries.
|
ConsistencyLevel |
PreparedStatement.getConsistencyLevel()
Returns the default consistency level set through
PreparedStatement.setConsistencyLevel(com.datastax.driver.core.ConsistencyLevel) . |
ConsistencyLevel |
DefaultPreparedStatement.getConsistencyLevel() |
ConsistencyLevel |
StatementWrapper.getSerialConsistencyLevel() |
ConsistencyLevel |
Statement.getSerialConsistencyLevel()
The serial consistency level for this query.
|
ConsistencyLevel |
QueryOptions.getSerialConsistencyLevel()
The default serial consistency level used by queries.
|
ConsistencyLevel |
PreparedStatement.getSerialConsistencyLevel()
Returns the default serial consistency level set through
PreparedStatement.setSerialConsistencyLevel(com.datastax.driver.core.ConsistencyLevel) . |
ConsistencyLevel |
DefaultPreparedStatement.getSerialConsistencyLevel() |
static ConsistencyLevel |
ConsistencyLevel.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ConsistencyLevel[] |
ConsistencyLevel.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Statement |
StatementWrapper.setConsistencyLevel(ConsistencyLevel consistency) |
Statement |
Statement.setConsistencyLevel(ConsistencyLevel consistency)
Sets the consistency level for the query.
|
QueryOptions |
QueryOptions.setConsistencyLevel(ConsistencyLevel consistencyLevel)
Sets the default consistency level to use for queries.
|
PreparedStatement |
PreparedStatement.setConsistencyLevel(ConsistencyLevel consistency)
Sets a default consistency level for all bound statements
created from this prepared statement.
|
PreparedStatement |
DefaultPreparedStatement.setConsistencyLevel(ConsistencyLevel consistency) |
Statement |
StatementWrapper.setSerialConsistencyLevel(ConsistencyLevel serialConsistency) |
Statement |
Statement.setSerialConsistencyLevel(ConsistencyLevel serialConsistency)
Sets the serial consistency level for the query.
|
QueryOptions |
QueryOptions.setSerialConsistencyLevel(ConsistencyLevel serialConsistencyLevel)
Sets the default serial consistency level to use for queries.
|
PreparedStatement |
PreparedStatement.setSerialConsistencyLevel(ConsistencyLevel serialConsistency)
Sets a default serial consistency level for all bound statements
created from this prepared statement.
|
PreparedStatement |
DefaultPreparedStatement.setSerialConsistencyLevel(ConsistencyLevel serialConsistency) |
BatchStatement |
BatchStatement.setSerialConsistencyLevel(ConsistencyLevel serialConsistency)
Sets the serial consistency level for the query.
|
Modifier and Type | Method and Description |
---|---|
ConsistencyLevel |
UnavailableException.getConsistencyLevel()
The consistency level of the operation triggering this unavailable exception.
|
ConsistencyLevel |
QueryConsistencyException.getConsistencyLevel()
The consistency level of the operation that failed.
|
Constructor and Description |
---|
QueryConsistencyException(InetSocketAddress address,
String msg,
ConsistencyLevel consistency,
int received,
int required) |
QueryConsistencyException(InetSocketAddress address,
String msg,
Throwable cause,
ConsistencyLevel consistency,
int received,
int required) |
ReadFailureException(ConsistencyLevel consistency,
int received,
int required,
int failed,
boolean dataPresent)
This constructor should only be used internally by the driver
when decoding error responses.
|
ReadFailureException(InetSocketAddress address,
ConsistencyLevel consistency,
int received,
int required,
int failed,
boolean dataPresent) |
ReadTimeoutException(ConsistencyLevel consistency,
int received,
int required,
boolean dataPresent)
This constructor should only be used internally by the driver
when decoding error responses.
|
ReadTimeoutException(InetSocketAddress address,
ConsistencyLevel consistency,
int received,
int required,
boolean dataPresent) |
UnavailableException(ConsistencyLevel consistency,
int required,
int alive)
This constructor should only be used internally by the driver
when decoding error responses.
|
UnavailableException(InetSocketAddress address,
ConsistencyLevel consistency,
int required,
int alive) |
WriteFailureException(ConsistencyLevel consistency,
WriteType writeType,
int received,
int required,
int failed)
This constructor should only be used internally by the driver
when decoding error responses.
|
WriteFailureException(InetSocketAddress address,
ConsistencyLevel consistency,
WriteType writeType,
int received,
int required,
int failed) |
WriteTimeoutException(ConsistencyLevel consistency,
WriteType writeType,
int received,
int required)
This constructor should only be used internally by the driver
when decoding error responses.
|
WriteTimeoutException(InetSocketAddress address,
ConsistencyLevel consistency,
WriteType writeType,
int received,
int required) |
Modifier and Type | Method and Description |
---|---|
ConsistencyLevel |
RetryPolicy.RetryDecision.getRetryConsistencyLevel()
The consistency level for this retry decision.
|
Modifier and Type | Method and Description |
---|---|
RetryPolicy.RetryDecision |
RetryPolicy.onReadTimeout(Statement statement,
ConsistencyLevel cl,
int requiredResponses,
int receivedResponses,
boolean dataRetrieved,
int nbRetry)
Defines whether to retry and at which consistency level on a read timeout.
|
RetryPolicy.RetryDecision |
LoggingRetryPolicy.onReadTimeout(Statement statement,
ConsistencyLevel cl,
int requiredResponses,
int receivedResponses,
boolean dataRetrieved,
int nbRetry) |
RetryPolicy.RetryDecision |
IdempotenceAwareRetryPolicy.onReadTimeout(Statement statement,
ConsistencyLevel cl,
int requiredResponses,
int receivedResponses,
boolean dataRetrieved,
int nbRetry) |
RetryPolicy.RetryDecision |
FallthroughRetryPolicy.onReadTimeout(Statement statement,
ConsistencyLevel cl,
int requiredResponses,
int receivedResponses,
boolean dataRetrieved,
int nbRetry)
Defines whether to retry and at which consistency level on a read timeout.
|
RetryPolicy.RetryDecision |
DowngradingConsistencyRetryPolicy.onReadTimeout(Statement statement,
ConsistencyLevel cl,
int requiredResponses,
int receivedResponses,
boolean dataRetrieved,
int nbRetry)
Defines whether to retry and at which consistency level on a read timeout.
|
RetryPolicy.RetryDecision |
DefaultRetryPolicy.onReadTimeout(Statement statement,
ConsistencyLevel cl,
int requiredResponses,
int receivedResponses,
boolean dataRetrieved,
int nbRetry)
Defines whether to retry and at which consistency level on a read timeout.
|
RetryPolicy.RetryDecision |
RetryPolicy.onRequestError(Statement statement,
ConsistencyLevel cl,
DriverException e,
int nbRetry)
Defines whether to retry and at which consistency level on an
unexpected error.
|
RetryPolicy.RetryDecision |
LoggingRetryPolicy.onRequestError(Statement statement,
ConsistencyLevel cl,
DriverException e,
int nbRetry) |
RetryPolicy.RetryDecision |
IdempotenceAwareRetryPolicy.onRequestError(Statement statement,
ConsistencyLevel cl,
DriverException e,
int nbRetry) |
RetryPolicy.RetryDecision |
FallthroughRetryPolicy.onRequestError(Statement statement,
ConsistencyLevel cl,
DriverException e,
int nbRetry)
Defines whether to retry and at which consistency level on an
unexpected error.
|
RetryPolicy.RetryDecision |
DowngradingConsistencyRetryPolicy.onRequestError(Statement statement,
ConsistencyLevel cl,
DriverException e,
int nbRetry)
Defines whether to retry and at which consistency level on an
unexpected error.
|
RetryPolicy.RetryDecision |
DefaultRetryPolicy.onRequestError(Statement statement,
ConsistencyLevel cl,
DriverException e,
int nbRetry)
Defines whether to retry and at which consistency level on an
unexpected error.
|
RetryPolicy.RetryDecision |
RetryPolicy.onUnavailable(Statement statement,
ConsistencyLevel cl,
int requiredReplica,
int aliveReplica,
int nbRetry)
Defines whether to retry and at which consistency level on an
unavailable exception.
|
RetryPolicy.RetryDecision |
LoggingRetryPolicy.onUnavailable(Statement statement,
ConsistencyLevel cl,
int requiredReplica,
int aliveReplica,
int nbRetry) |
RetryPolicy.RetryDecision |
IdempotenceAwareRetryPolicy.onUnavailable(Statement statement,
ConsistencyLevel cl,
int requiredReplica,
int aliveReplica,
int nbRetry) |
RetryPolicy.RetryDecision |
FallthroughRetryPolicy.onUnavailable(Statement statement,
ConsistencyLevel cl,
int requiredReplica,
int aliveReplica,
int nbRetry)
Defines whether to retry and at which consistency level on an
unavailable exception.
|
RetryPolicy.RetryDecision |
DowngradingConsistencyRetryPolicy.onUnavailable(Statement statement,
ConsistencyLevel cl,
int requiredReplica,
int aliveReplica,
int nbRetry)
Defines whether to retry and at which consistency level on an
unavailable exception.
|
RetryPolicy.RetryDecision |
DefaultRetryPolicy.onUnavailable(Statement statement,
ConsistencyLevel cl,
int requiredReplica,
int aliveReplica,
int nbRetry)
Defines whether to retry and at which consistency level on an
unavailable exception.
|
RetryPolicy.RetryDecision |
RetryPolicy.onWriteTimeout(Statement statement,
ConsistencyLevel cl,
WriteType writeType,
int requiredAcks,
int receivedAcks,
int nbRetry)
Defines whether to retry and at which consistency level on a write timeout.
|
RetryPolicy.RetryDecision |
LoggingRetryPolicy.onWriteTimeout(Statement statement,
ConsistencyLevel cl,
WriteType writeType,
int requiredAcks,
int receivedAcks,
int nbRetry) |
RetryPolicy.RetryDecision |
IdempotenceAwareRetryPolicy.onWriteTimeout(Statement statement,
ConsistencyLevel cl,
WriteType writeType,
int requiredAcks,
int receivedAcks,
int nbRetry) |
RetryPolicy.RetryDecision |
FallthroughRetryPolicy.onWriteTimeout(Statement statement,
ConsistencyLevel cl,
WriteType writeType,
int requiredAcks,
int receivedAcks,
int nbRetry)
Defines whether to retry and at which consistency level on a write timeout.
|
RetryPolicy.RetryDecision |
DowngradingConsistencyRetryPolicy.onWriteTimeout(Statement statement,
ConsistencyLevel cl,
WriteType writeType,
int requiredAcks,
int receivedAcks,
int nbRetry)
Defines whether to retry and at which consistency level on a write timeout.
|
RetryPolicy.RetryDecision |
DefaultRetryPolicy.onWriteTimeout(Statement statement,
ConsistencyLevel cl,
WriteType writeType,
int requiredAcks,
int receivedAcks,
int nbRetry)
Defines whether to retry and at which consistency level on a write timeout.
|
static RetryPolicy.RetryDecision |
RetryPolicy.RetryDecision.retry(ConsistencyLevel consistency)
Creates a
RetryPolicy.RetryDecision.Type.RETRY retry decision using
the same host and the provided consistency level. |
static RetryPolicy.RetryDecision |
RetryPolicy.RetryDecision.tryNextHost(ConsistencyLevel consistency)
Creates a
RetryPolicy.RetryDecision.Type.RETRY retry decision using the next host
in the query plan, and using the provided consistency level. |
Modifier and Type | Method and Description |
---|---|
ConsistencyLevel |
SimpleGraphStatement.getConsistencyLevel() |
abstract ConsistencyLevel |
GraphStatement.getConsistencyLevel()
Returns the consistency level to use with this statement.
|
ConsistencyLevel |
GraphStatement.getGraphReadConsistencyLevel()
Returns the read consistency level to use with this statement.
|
ConsistencyLevel |
GraphOptions.getGraphReadConsistencyLevel()
Returns the read consistency level to use in graph queries.
|
ConsistencyLevel |
GraphStatement.getGraphWriteConsistencyLevel()
Returns the write consistency level to use with this statement.
|
ConsistencyLevel |
GraphOptions.getGraphWriteConsistencyLevel()
Returns the write consistency level to use in graph queries.
|
Modifier and Type | Method and Description |
---|---|
GraphStatement |
SimpleGraphStatement.setConsistencyLevel(ConsistencyLevel consistencyLevel) |
abstract GraphStatement |
GraphStatement.setConsistencyLevel(ConsistencyLevel consistencyLevel)
Sets the consistency level to use for this statement.
|
GraphStatement |
GraphStatement.setGraphReadConsistencyLevel(ConsistencyLevel consistencyLevel)
Sets the read consistency level to use for this statement.
|
GraphOptions |
GraphOptions.setGraphReadConsistencyLevel(ConsistencyLevel cl)
Sets the read consistency level to use for graph queries.
|
GraphStatement |
GraphStatement.setGraphWriteConsistencyLevel(ConsistencyLevel consistencyLevel)
Sets the write consistency level to use for this statement.
|
GraphOptions |
GraphOptions.setGraphWriteConsistencyLevel(ConsistencyLevel cl)
Sets the write consistency level to use for graph queries.
|