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

Interface ContinuousReactiveSession

All Superinterfaces:

AsyncAutoCloseable, AutoCloseable, Session

All Known Subinterfaces:

CqlSession, DseSession

public interface ContinuousReactiveSession
extends Session

A Session that offers utility methods to issue queries using reactive-style programming and continuous paging, combined together.

Methods in this interface all return ContinuousReactiveResultSet instances. All publishers support multiple subscriptions in a unicast fashion: each subscriber triggers an independent request execution and gets its own copy of the results.

Also, note that the publishers may emit items to their subscribers on an internal driver IO thread. Subscriber implementors are encouraged to abide by Reactive Streams Specification rule 2.2 and avoid performing heavy computations or blocking calls inside onNext calls, as doing so could slow down the driver and impact performance. Instead, they should asynchronously dispatch received signals to their processing logic.

See Also:

ReactiveRow

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 ContinuousReactiveResultSet	executeContinuouslyReactive(Statement<?> statement) Returns a Publisher that, once subscribed to, executes the given query continuously and emits all the results.
default ContinuousReactiveResultSet	executeContinuouslyReactive(String query) Returns a Publisher that, once subscribed to, executes the given query continuously and emits all the results.

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

executeContinuouslyReactive

@NonNull
default ContinuousReactiveResultSet executeContinuouslyReactive(@NonNull
                                                                         String query)

Returns a Publisher that, once subscribed to, executes the given query continuously and emits all the results.

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:

query - the query to execute.

Returns:

The Publisher that will publish the returned results.

executeContinuouslyReactive

@NonNull
default ContinuousReactiveResultSet executeContinuouslyReactive(@NonNull
                                                                         Statement<?> statement)

Returns a Publisher that, once subscribed to, executes the given query continuously and emits all the results.

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 statement to execute.

Returns:

The Publisher that will publish the returned results.