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

Interface AsyncBulkReader

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

AsyncBulkExecutor, BulkExecutor, BulkReader, ReactorBulkExecutor

All Known Implementing Classes:

AbstractBulkExecutor, ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface AsyncBulkReader
extends AutoCloseable

An asynchronous execution unit for bulk read operations.

Methods of this interface all return completable futures that will complete when the whole read operation completes.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	readAsync(Iterable<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given stream of read statements asynchronously, notifying the given consumer of every read result.
CompletableFuture<Void>	readAsync(Publisher<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given iterable of read statements asynchronously, notifying the given consumer of every read result.
CompletableFuture<Void>	readAsync(Statement<?> statement, Consumer<? super ReadResult> consumer) Executes the given read statement asynchronously, notifying the given consumer of every read result.
CompletableFuture<Void>	readAsync(Stream<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given stream of read statements asynchronously, notifying the given consumer of every read result.
default CompletableFuture<Void>	readAsync(String statement, Consumer<? super ReadResult> consumer) Executes the given read statement asynchronously, notifying the given consumer of every read result.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

readAsync

default CompletableFuture<Void> readAsync(String statement,
                                          Consumer<? super ReadResult> consumer)
                                   throws BulkExecutionException

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

Parameters:

statement - The statement to execute.

consumer - A consumer for ReadResults.

Returns:

A completable future that will complete when the whole read operation completes.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readAsync

CompletableFuture<Void> readAsync(Statement<?> statement,
                                  Consumer<? super ReadResult> consumer)
                           throws BulkExecutionException

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

Parameters:

statement - The statement to execute.

consumer - A consumer for ReadResults.

Returns:

A completable future that will complete when the whole read operation completes.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readAsync

CompletableFuture<Void> readAsync(Stream<? extends Statement<?>> statements,
                                  Consumer<? super ReadResult> consumer)
                           throws BulkExecutionException

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

Parameters:

statements - The statements to execute.

consumer - A consumer for ReadResults.

Returns:

A completable future that will complete when the whole read operation completes.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readAsync

CompletableFuture<Void> readAsync(Iterable<? extends Statement<?>> statements,
                                  Consumer<? super ReadResult> consumer)
                           throws BulkExecutionException

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

Parameters:

statements - The statements to execute.

consumer - A consumer for ReadResults.

Returns:

A completable future that will complete when the whole read operation completes.

Throws:

BulkExecutionException - if the operation cannot complete normally.

readAsync

CompletableFuture<Void> readAsync(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 ReadResults.

Returns:

A completable future that will complete when the whole read operation completes.

Throws:

BulkExecutionException - if the operation cannot complete normally.