com.datastax.oss.dsbulk.executor.api.writer

Interface AsyncBulkWriter

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

AsyncBulkExecutor, BulkExecutor, BulkWriter, ReactorBulkExecutor

All Known Implementing Classes:

AbstractBulkExecutor, ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface AsyncBulkWriter
extends AutoCloseable

An asynchronous execution unit for bulk write operations.

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

Method Summary

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

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

writeAsync

default CompletableFuture<WriteResult> writeAsync(String statement)
                                           throws BulkExecutionException

Executes the given write statement asynchronously.

Parameters:

statement - The statement to execute.

Returns:

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

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeAsync

CompletableFuture<WriteResult> writeAsync(Statement<?> statement)
                                   throws BulkExecutionException

Executes the given write statement asynchronously.

Parameters:

statement - The statement to execute.

Returns:

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

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeAsync

default CompletableFuture<Void> writeAsync(Stream<? extends Statement<?>> statements)
                                    throws BulkExecutionException

Executes the given stream of write statements asynchronously.

This method operates in a "fire and forget" mode. If you need to consume write results, consider using writeAsync(Stream, Consumer) instead.

Parameters:

statements - The statements to execute.

Returns:

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

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeAsync

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

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

Parameters:

statements - The statements to execute.

consumer - A consumer for write results.

Returns:

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

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeAsync

default CompletableFuture<Void> writeAsync(Iterable<? extends Statement<?>> statements)
                                    throws BulkExecutionException

Executes the given iterable of write statements asynchronously.

This method operates in a "fire and forget" mode. If you need to consume write results, consider using writeAsync(Iterable, Consumer) instead.

Parameters:

statements - The statements to execute.

Returns:

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

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeAsync

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

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

Parameters:

statements - The statements to execute.

consumer - A consumer for write results.

Returns:

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

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeAsync

default CompletableFuture<Void> writeAsync(Publisher<? extends Statement<?>> statements)
                                    throws BulkExecutionException

Executes the given flow of write statements asynchronously.

This method operates in a "fire and forget" mode. If you need to consume write results, consider using writeAsync(Publisher, Consumer) instead.

Parameters:

statements - The statements to execute.

Returns:

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

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeAsync

CompletableFuture<Void> writeAsync(Publisher<? extends Statement<?>> statements,
                                   Consumer<? super WriteResult> consumer)

Executes the given flow of write statements asynchronously, notifying the given consumer of every write result.

Parameters:

statements - The statements to execute.

consumer - A consumer for write results.

Returns:

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

Throws:

BulkExecutionException - if the operation cannot complete normally.