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

Interface BulkReader

All Superinterfaces:

AsyncBulkReader, AutoCloseable, ReactiveBulkReader, SyncBulkReader

All Known Subinterfaces:

BulkExecutor, ReactorBulkExecutor

All Known Implementing Classes:

AbstractBulkExecutor, ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface BulkReader
extends SyncBulkReader, AsyncBulkReader, ReactiveBulkReader

A bulk reader that operates in 3 distinct modes:

1. Synchronous;
2. Asynchronous;
3. Reactive.

Method Summary

Modifier and Type	Method and Description
default void	readSync(Publisher<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given iterable of read statements asynchronously, notifying the given consumer of every read result.
default void	readSync(Statement<?> statement, Consumer<? super ReadResult> consumer) Executes the given read statement synchronously, notifying the given consumer of every read result.

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.reader.AsyncBulkReader

readAsync, readAsync, readAsync, readAsync, readAsync

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

readReactive, readReactive, readReactive, readReactive, readReactive

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

readSync

default void readSync(Statement<?> statement,
                      Consumer<? super ReadResult> consumer)
               throws BulkExecutionException

Description copied from interface: SyncBulkReader

Executes the given read statement synchronously, notifying the given consumer of every read result.

Specified by:

readSync in interface SyncBulkReader

Parameters:

statement - The statement to execute.

consumer - A consumer for read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readSync

default void readSync(Publisher<? extends Statement<?>> statements,
                      Consumer<? super ReadResult> consumer)
               throws BulkExecutionException

Description copied from interface: SyncBulkReader

Executes the given iterable of read statements asynchronously, notifying the given consumer of every read result.

Specified by:

readSync in interface SyncBulkReader

Parameters:

statements - The statements to execute.

consumer - A consumer for read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.