com.datastax.dse.driver.api.core.cql.continuous

Interface ContinuousSession

All Superinterfaces:

AsyncAutoCloseable, AutoCloseable, Session

All Known Subinterfaces:

CqlSession, DseSession

public interface ContinuousSession
extends Session

A session that has the ability to execute continuous paging queries.

Continuous paging is a new method of streaming bulk amounts of records from Datastax Enterprise (DSE) to the Datastax Java Driver, available since DSE 5.1. It is mainly intended to be leveraged by DSE Analytics and Apache Spark™, or by any similar analytics tool that needs to read large portions of a table in one single operation, as quick and reliably as possible.

Continuous paging provides the best performance improvement against regular paging when the following conditions are met:

1. The statement must target a single partition or a token range owned by one single replica; in practice, this means that the statement must have either a routing key or a routing token set;
2. The coordinator must be a replica; in practice, this is usually achieved by using token-aware routing (if you are using the driver's default LoadBalancingPolicy, then this condition is met);
3. The consistency level must be ONE (or LOCAL_ONE).

If the above conditions are met, the coordinator will be able to optimize the read path and serve results from local data, thus significantly improving response times; if however these conditions cannot be met, continuous paging would still work, but response times wouldn't be significantly better than those of regular paging anymore.

See Also:

Continuous paging options in cassandra.yaml configuration file, DSE Continuous Paging Tuning and Support Guide

Field Summary

Fields inherited from interface com.datastax.oss.driver.api.core.session.Session

OSS_DRIVER_COORDINATES

Method Summary

Modifier and Type	Method and Description
default ContinuousResultSet	executeContinuously(Statement<?> statement) Executes the provided query with continuous paging synchronously.
default CompletionStage<ContinuousAsyncResultSet>	executeContinuouslyAsync(Statement<?> statement) Executes the provided query with continuous paging asynchronously.

Methods inherited from interface com.datastax.oss.driver.api.core.session.Session

checkSchemaAgreement, checkSchemaAgreementAsync, execute, getContext, getKeyspace, getMetadata, getMetrics, getName, isSchemaMetadataEnabled, refreshSchema, refreshSchemaAsync, setSchemaMetadataEnabled

Methods inherited from interface com.datastax.oss.driver.api.core.AsyncAutoCloseable

close, closeAsync, closeFuture, forceCloseAsync, isClosed

Method Detail

executeContinuously

@NonNull
default ContinuousResultSet executeContinuously(@NonNull
                                                         Statement<?> statement)

Executes the provided query with continuous paging synchronously.

This method takes care of chaining the successive results into a convenient iterable, provided that you always access the result from the same thread. For more flexibility, consider using the asynchronous variant of this method instead.

See ContinuousSession for more explanations about continuous paging.

This feature is only available with Datastax Enterprise. Executing continuous queries against an Apache Cassandra© cluster will result in a runtime error.

Parameters:

statement - the query to execute.

Returns:

a synchronous iterable on the results.

executeContinuouslyAsync

@NonNull
default CompletionStage<ContinuousAsyncResultSet> executeContinuouslyAsync(@NonNull
                                                                                    Statement<?> statement)

Executes the provided query with continuous paging asynchronously.

The server will push all requested pages asynchronously, according to the options defined in the current execution profile. The client should consume all pages as quickly as possible, to avoid blocking the server for too long. The server will adjust the rate according to the client speed, but it will give up if the client does not consume any pages in a period of time equal to the read request timeout.

See ContinuousSession for more explanations about continuous paging.

This feature is only available with Datastax Enterprise. Executing continuous queries against an Apache Cassandra© cluster will result in a runtime error.

Parameters:

statement - the query to execute.

Returns:

a future to the first asynchronous result.