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

Interface SyncBulkReader

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

BulkExecutor, BulkReader, ReactorBulkExecutor, SyncBulkExecutor

All Known Implementing Classes:

AbstractBulkExecutor, ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface SyncBulkReader
extends AutoCloseable

An asynchronous execution unit for bulk read operations.

Methods of this interface are expected to block until the whole read operation completes.

Method Summary

Modifier and Type	Method and Description
void	readSync(Iterable<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given stream of read statements synchronously, notifying the given consumer of every read result.
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.
void	readSync(Statement<?> statement, Consumer<? super ReadResult> consumer) Executes the given read statement synchronously, notifying the given consumer of every read result.
void	readSync(Stream<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given stream of read statements synchronously, notifying the given consumer of every read result.
default void	readSync(String statement, Consumer<? super ReadResult> consumer) Executes the given read statement synchronously, notifying the given consumer of every read result.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

readSync

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

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

Parameters:

statement - The statement to execute.

consumer - A consumer for read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readSync

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

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

Parameters:

statement - The statement to execute.

consumer - A consumer for read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readSync

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

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

Parameters:

statements - The statements to execute.

consumer - A consumer for read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readSync

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

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

Parameters:

statements - The statements to execute.

consumer - A consumer for read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readSync

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

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

Parameters:

statements - The statements to execute.

consumer - A consumer for read results.

Throws:

BulkExecutionException - if the operation cannot complete normally.