com.datastax.oss.dsbulk.executor.api.reader

Interface ReactiveBulkReader

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

BulkExecutor, BulkReader, ReactiveBulkExecutor, ReactorBulkExecutor, ReactorBulkReader

All Known Implementing Classes:

AbstractBulkExecutor, ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface ReactiveBulkReader
extends AutoCloseable

A reactive execution unit for bulk read operations.

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

Method Summary

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

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

readReactive

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

Executes the given read statement reactively.

Parameters:

statement - The statement to execute.

Returns:

A publisher that will emit one single read result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readReactive

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

Executes the given read statement reactively.

Parameters:

statement - The statement to execute.

Returns:

A publisher that will emit one single read result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readReactive

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

Executes the given stream of read statements reactively.

Parameters:

statements - The statements to execute.

Returns:

A publisher of read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readReactive

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

Executes the given iterable of read statements reactively.

Parameters:

statements - The statements to execute.

Returns:

A publisher of read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readReactive

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

Executes the given publisher of read statements reactively.

Parameters:

statements - The statements to execute.

Returns:

A publisher of read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.