com.datastax.oss.dsbulk.executor.reactor.reader

Interface ReactorBulkReader

All Superinterfaces:

AutoCloseable, ReactiveBulkReader

All Known Subinterfaces:

ReactorBulkExecutor

All Known Implementing Classes:

ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface ReactorBulkReader
extends ReactiveBulkReader

A reactive execution unit for bulk read operations using Reactor.

Methods of this interface all return a Flux of read results.

Method Summary

Modifier and Type	Method and Description
Flux<ReadResult>	readReactive(Iterable<? extends Statement<?>> statements) Executes the given iterable of read statements reactively.
Flux<ReadResult>	readReactive(Publisher<? extends Statement<?>> statements) Executes the given Flux of read statements reactively.
Flux<ReadResult>	readReactive(Statement<?> statement) Executes the given read statement reactively.
Flux<ReadResult>	readReactive(Stream<? extends Statement<?>> statements) Executes the given stream of read statements reactively.
default Flux<ReadResult>	readReactive(String statement) Executes the given read statement reactively.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

readReactive

default Flux<ReadResult> readReactive(String statement)
                               throws BulkExecutionException

Executes the given read statement reactively.

Specified by:

readReactive in interface ReactiveBulkReader

Parameters:

statement - The statement to execute.

Returns:

A Flux that will emit one single read result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readReactive

Flux<ReadResult> readReactive(Statement<?> statement)
                       throws BulkExecutionException

Executes the given read statement reactively.

Specified by:

readReactive in interface ReactiveBulkReader

Parameters:

statement - The statement to execute.

Returns:

A Flux that will emit one single read result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readReactive

Flux<ReadResult> readReactive(Stream<? extends Statement<?>> statements)
                       throws BulkExecutionException

Executes the given stream of read statements reactively.

Specified by:

readReactive in interface ReactiveBulkReader

Parameters:

statements - The statements to execute.

Returns:

A Flux of read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readReactive

Flux<ReadResult> readReactive(Iterable<? extends Statement<?>> statements)
                       throws BulkExecutionException

Executes the given iterable of read statements reactively.

Specified by:

readReactive in interface ReactiveBulkReader

Parameters:

statements - The statements to execute.

Returns:

A Flux of read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readReactive

Flux<ReadResult> readReactive(Publisher<? extends Statement<?>> statements)
                       throws BulkExecutionException

Executes the given Flux of read statements reactively.

Specified by:

readReactive in interface ReactiveBulkReader

Parameters:

statements - The statements to execute.

Returns:

A Flux of read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.