public class ContinuousReactorBulkExecutor extends DefaultReactorBulkExecutor implements ReactorBulkExecutor
BulkExecutor using Reactor,
that executes all reads using continuous paging. This executor can achieve significant
performance improvements for reads, provided that the read statements to be executed can be
properly routed to a replica.failFast, listener, maxConcurrentRequests, rateLimiter, session| Constructor and Description |
|---|
ContinuousReactorBulkExecutor(CqlSession cqlSession)
Creates a new instance using the given
CqlSession and using defaults for all
parameters. |
| Modifier and Type | Method and Description |
|---|---|
static ContinuousReactorBulkExecutorBuilder |
continuousPagingBuilder(CqlSession session)
Creates a new builder for
ContinuousReactorBulkExecutor instances using the given
CqlSession. |
Flux<ReadResult> |
readReactive(Statement<?> statement)
Executes the given read statement reactively.
|
builder, readAsync, readAsync, readAsync, readAsync, readReactive, readReactive, readReactive, readReactive, readSync, readSync, writeAsync, writeAsync, writeAsync, writeAsync, writeReactive, writeReactive, writeReactive, writeReactive, writeSync, writeSynccloseclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitwriteReactive, writeReactive, writeReactive, writeReactive, writeReactivereadReactive, readReactive, readReactive, readReactivewriteSync, writeSyncreadSync, readSyncwriteSync, writeSync, writeSync, writeSync, writeSync, writeSyncreadSync, readSync, readSyncwriteAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsyncreadAsync, readAsync, readAsync, readAsync, readAsyncclosepublic ContinuousReactorBulkExecutor(CqlSession cqlSession)
CqlSession and using defaults for all
parameters.
If you need to customize your executor, use the builder method
instead.
cqlSession - the CqlSession to use.public static ContinuousReactorBulkExecutorBuilder continuousPagingBuilder(CqlSession session)
ContinuousReactorBulkExecutor instances using the given
CqlSession.session - the CqlSession to use.public Flux<ReadResult> readReactive(Statement<?> statement)
ReactorBulkReaderreadReactive in interface ReactiveBulkReaderreadReactive in interface ReactorBulkReaderreadReactive in class DefaultReactorBulkExecutorstatement - The statement to execute.Flux that will emit one single read result.Copyright © 2017–2021 DataStax. All rights reserved.