public interface AsyncBulkReader extends AutoCloseable
Methods of this interface all return completable futures that will
complete when the whole read operation completes.
| 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.
|
closedefault CompletableFuture<Void> readAsync(String statement, Consumer<? super ReadResult> consumer) throws BulkExecutionException
statement - The statement to execute.consumer - A consumer for ReadResults.completable future that will complete when the whole read
operation completes.BulkExecutionException - if the operation cannot complete normally.CompletableFuture<Void> readAsync(Statement<?> statement, Consumer<? super ReadResult> consumer) throws BulkExecutionException
statement - The statement to execute.consumer - A consumer for ReadResults.completable future that will complete when the whole read
operation completes.BulkExecutionException - if the operation cannot complete normally.CompletableFuture<Void> readAsync(Stream<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) throws BulkExecutionException
statements - The statements to execute.consumer - A consumer for ReadResults.completable future that will complete when the whole read
operation completes.BulkExecutionException - if the operation cannot complete normally.CompletableFuture<Void> readAsync(Iterable<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) throws BulkExecutionException
statements - The statements to execute.consumer - A consumer for ReadResults.completable future that will complete when the whole read
operation completes.BulkExecutionException - if the operation cannot complete normally.CompletableFuture<Void> readAsync(Publisher<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) throws BulkExecutionException
statements - The statements to execute.consumer - A consumer for ReadResults.completable future that will complete when the whole read
operation completes.BulkExecutionException - if the operation cannot complete normally.Copyright © 2017–2021 DataStax. All rights reserved.