com.datastax.oss.dsbulk.executor.reactor

Class ContinuousReactorBulkExecutor

java.lang.Object

com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

com.datastax.oss.dsbulk.executor.reactor.ContinuousReactorBulkExecutor

All Implemented Interfaces:

AsyncBulkExecutor, BulkExecutor, ReactiveBulkExecutor, AsyncBulkReader, BulkReader, ReactiveBulkReader, SyncBulkReader, SyncBulkExecutor, AsyncBulkWriter, BulkWriter, ReactiveBulkWriter, SyncBulkWriter, ReactorBulkExecutor, ReactorBulkReader, ReactorBulkWriter, AutoCloseable

public class ContinuousReactorBulkExecutor
extends DefaultReactorBulkExecutor
implements ReactorBulkExecutor

An implementation of 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.

Field Summary

Fields inherited from class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

failFast, listener, maxConcurrentRequests, rateLimiter, session

Constructor Summary

Constructors

Constructor and Description
ContinuousReactorBulkExecutor(CqlSession cqlSession) Creates a new instance using the given CqlSession and using defaults for all parameters.

Method Summary

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.

Methods inherited from class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

builder, readAsync, readAsync, readAsync, readAsync, readReactive, readReactive, readReactive, readReactive, readSync, readSync, writeAsync, writeAsync, writeAsync, writeAsync, writeReactive, writeReactive, writeReactive, writeReactive, writeSync, writeSync

Methods inherited from class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

close

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.datastax.oss.dsbulk.executor.reactor.writer.ReactorBulkWriter

writeReactive, writeReactive, writeReactive, writeReactive, writeReactive

Methods inherited from interface com.datastax.oss.dsbulk.executor.reactor.reader.ReactorBulkReader

readReactive, readReactive, readReactive, readReactive

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.BulkWriter

writeSync, writeSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.BulkReader

readSync, readSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

writeSync, writeSync, writeSync, writeSync, writeSync, writeSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.SyncBulkReader

readSync, readSync, readSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.AsyncBulkReader

readAsync, readAsync, readAsync, readAsync, readAsync

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

ContinuousReactorBulkExecutor

public ContinuousReactorBulkExecutor(CqlSession cqlSession)

Creates a new instance using the given CqlSession and using defaults for all parameters.

If you need to customize your executor, use the builder method instead.

Parameters:

cqlSession - the CqlSession to use.

Method Detail

continuousPagingBuilder

public static ContinuousReactorBulkExecutorBuilder continuousPagingBuilder(CqlSession session)

Creates a new builder for ContinuousReactorBulkExecutor instances using the given CqlSession.

Parameters:

session - the CqlSession to use.

Returns:

a new builder.

readReactive

public Flux<ReadResult> readReactive(Statement<?> statement)

Description copied from interface: ReactorBulkReader

Executes the given read statement reactively.

Specified by:

readReactive in interface ReactiveBulkReader

Specified by:

readReactive in interface ReactorBulkReader

Overrides:

readReactive in class DefaultReactorBulkExecutor

Parameters:

statement - The statement to execute.

Returns:

A Flux that will emit one single read result.