Modifier and Type | Interface and Description |
---|---|
interface |
BatchGraphStatement
A graph statement that groups multiple mutating traversals together, to be executed in the
same transaction.
|
interface |
FluentGraphStatement
A graph statement that uses a TinkerPop
GraphTraversal as the query. |
interface |
GraphStatement<SelfT extends GraphStatement<SelfT>>
A request to execute a DSE Graph query.
|
interface |
ScriptGraphStatement
A graph statement that uses a Gremlin-groovy script the query.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BatchableStatement<SelfT extends BatchableStatement<SelfT>>
A statement that can be added to a CQL batch.
|
interface |
BatchStatement
A statement that groups a number of other statements, so that they can be executed as a batch
(i.e.
|
interface |
BoundStatement
A prepared statement in its executable form, with values bound to the variables.
|
interface |
PrepareRequest
A request to prepare a CQL query.
|
interface |
SimpleStatement
A one-off CQL statement consisting of a query string with optional placeholders, and a set of
values for these placeholders.
|
interface |
Statement<SelfT extends Statement<SelfT>>
A request to execute a CQL query.
|
Modifier and Type | Method and Description |
---|---|
default Request |
ExecutionInfo.getRequest() |
Modifier and Type | Method and Description |
---|---|
Queue<Node> |
LoadBalancingPolicy.newQueryPlan(Request request,
Session session)
Returns the coordinators to use for a new query.
|
Modifier and Type | Method and Description |
---|---|
default <RequestT extends Request> |
RetryVerdict.getRetryRequest(RequestT previous)
Returns the request to retry, based on the request that was just executed (and failed).
|
Modifier and Type | Method and Description |
---|---|
RetryDecision |
RetryPolicy.onErrorResponse(Request request,
CoordinatorException error,
int retryCount)
Deprecated.
As of version 4.10, use
RetryPolicy.onErrorResponseVerdict(Request,
CoordinatorException, int) instead. |
default RetryVerdict |
RetryPolicy.onErrorResponseVerdict(Request request,
CoordinatorException error,
int retryCount)
Whether to retry when the server replied with a recoverable error (other than
READ_TIMEOUT , WRITE_TIMEOUT or UNAVAILABLE ). |
RetryDecision |
RetryPolicy.onReadTimeout(Request request,
ConsistencyLevel cl,
int blockFor,
int received,
boolean dataPresent,
int retryCount)
Deprecated.
As of version 4.10, use
RetryPolicy.onReadTimeoutVerdict(Request, ConsistencyLevel,
int, int, boolean, int) instead. |
default RetryVerdict |
RetryPolicy.onReadTimeoutVerdict(Request request,
ConsistencyLevel cl,
int blockFor,
int received,
boolean dataPresent,
int retryCount)
Whether to retry when the server replied with a
READ_TIMEOUT error; this indicates a
server-side timeout during a read query, i.e. |
RetryDecision |
RetryPolicy.onRequestAborted(Request request,
Throwable error,
int retryCount)
Deprecated.
As of version 4.10, use
RetryPolicy.onRequestAbortedVerdict(Request, Throwable, int)
instead. |
default RetryVerdict |
RetryPolicy.onRequestAbortedVerdict(Request request,
Throwable error,
int retryCount)
Whether to retry when a request was aborted before we could get a response from the server.
|
RetryDecision |
RetryPolicy.onUnavailable(Request request,
ConsistencyLevel cl,
int required,
int alive,
int retryCount)
Deprecated.
As of version 4.10, use
RetryPolicy.onUnavailableVerdict(Request, ConsistencyLevel,
int, int, int) instead. |
default RetryVerdict |
RetryPolicy.onUnavailableVerdict(Request request,
ConsistencyLevel cl,
int required,
int alive,
int retryCount)
Whether to retry when the server replied with an
UNAVAILABLE error; this indicates that
the coordinator determined that there were not enough replicas alive to perform a query with
the requested consistency level. |
RetryDecision |
RetryPolicy.onWriteTimeout(Request request,
ConsistencyLevel cl,
WriteType writeType,
int blockFor,
int received,
int retryCount)
Deprecated.
As of version 4.10, use
RetryPolicy.onWriteTimeoutVerdict(Request, ConsistencyLevel,
WriteType, int, int, int) instead. |
default RetryVerdict |
RetryPolicy.onWriteTimeoutVerdict(Request request,
ConsistencyLevel cl,
WriteType writeType,
int blockFor,
int received,
int retryCount)
Whether to retry when the server replied with a
WRITE_TIMEOUT error; this indicates a
server-side timeout during a write query, i.e. |
Modifier and Type | Method and Description |
---|---|
<RequestT extends Request,ResultT> |
Session.execute(RequestT request,
GenericType<ResultT> resultType)
Executes an arbitrary request.
|
Modifier and Type | Method and Description |
---|---|
long |
SpeculativeExecutionPolicy.nextExecution(Node node,
CqlIdentifier keyspace,
Request request,
int runningExecutions) |
Modifier and Type | Method and Description |
---|---|
default void |
RequestTracker.onError(Request request,
Throwable error,
long latencyNanos,
DriverExecutionProfile executionProfile,
Node node)
Deprecated.
This method only exists for backward compatibility. Override
RequestTracker.onError(Request, Throwable, long, DriverExecutionProfile, Node, String) instead. |
default void |
RequestTracker.onError(Request request,
Throwable error,
long latencyNanos,
DriverExecutionProfile executionProfile,
Node node,
String requestLogPrefix)
Invoked each time a request fails.
|
default void |
RequestTracker.onNodeError(Request request,
Throwable error,
long latencyNanos,
DriverExecutionProfile executionProfile,
Node node)
Deprecated.
This method only exists for backward compatibility. Override
RequestTracker.onNodeError(Request, Throwable, long, DriverExecutionProfile, Node, String) instead. |
default void |
RequestTracker.onNodeError(Request request,
Throwable error,
long latencyNanos,
DriverExecutionProfile executionProfile,
Node node,
String requestLogPrefix)
Invoked each time a request fails at the node level.
|
default void |
RequestTracker.onNodeSuccess(Request request,
long latencyNanos,
DriverExecutionProfile executionProfile,
Node node)
Deprecated.
This method only exists for backward compatibility. Override
RequestTracker.onNodeSuccess(Request, long, DriverExecutionProfile, Node, String) instead. |
default void |
RequestTracker.onNodeSuccess(Request request,
long latencyNanos,
DriverExecutionProfile executionProfile,
Node node,
String requestLogPrefix)
Invoked each time a request succeeds at the node level.
|
default void |
RequestTracker.onSuccess(Request request,
long latencyNanos,
DriverExecutionProfile executionProfile,
Node node)
Deprecated.
This method only exists for backward compatibility. Override
RequestTracker.onSuccess(Request, long, DriverExecutionProfile, Node, String) instead. |
default void |
RequestTracker.onSuccess(Request request,
long latencyNanos,
DriverExecutionProfile executionProfile,
Node node,
String requestLogPrefix)
Invoked each time a request succeeds.
|
Copyright © 2017–2023. All rights reserved.