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

Interface ReactiveBulkWriter

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

BulkExecutor, BulkWriter, ReactiveBulkExecutor, ReactorBulkExecutor, ReactorBulkWriter

All Known Implementing Classes:

AbstractBulkExecutor, ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface ReactiveBulkWriter
extends AutoCloseable

A reactive execution unit for bulk write operations.

Methods of this interface all return a Publisher of write results.

Method Summary

Modifier and Type	Method and Description
Publisher<WriteResult>	writeReactive(Iterable<? extends Statement<?>> statements) Executes the given iterable of write statements reactively.
Publisher<WriteResult>	writeReactive(Publisher<? extends Statement<?>> statements) Executes the given publisher of write statements reactively.
Publisher<WriteResult>	writeReactive(Statement<?> statement) Executes the given write statement reactively.
Publisher<WriteResult>	writeReactive(Stream<? extends Statement<?>> statements) Executes the given stream of write statements reactively.
default Publisher<WriteResult>	writeReactive(String statement) Executes the given write statement reactively.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

writeReactive

default Publisher<WriteResult> writeReactive(String statement)
                                      throws BulkExecutionException

Executes the given write statement reactively. The returned publisher is guaranteed to only ever emit one item, or throw an error if the execution failed.

Parameters:

statement - The statement to execute.

Returns:

A publisher that will emit one single write result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeReactive

Publisher<WriteResult> writeReactive(Statement<?> statement)
                              throws BulkExecutionException

Executes the given write statement reactively. The returned publisher is guaranteed to only ever emit one item, or throw an error if the execution failed.

Parameters:

statement - The statement to execute.

Returns:

A publisher that will emit one single write result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeReactive

Publisher<WriteResult> writeReactive(Stream<? extends Statement<?>> statements)
                              throws BulkExecutionException

Executes the given stream of write statements reactively.

Parameters:

statements - The statements to execute.

Returns:

A publisher of write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeReactive

Publisher<WriteResult> writeReactive(Iterable<? extends Statement<?>> statements)
                              throws BulkExecutionException

Executes the given iterable of write statements reactively.

Parameters:

statements - The statements to execute.

Returns:

A publisher of write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeReactive

Publisher<WriteResult> writeReactive(Publisher<? extends Statement<?>> statements)
                              throws BulkExecutionException

Executes the given publisher of write statements reactively.

Parameters:

statements - The statements to execute.

Returns:

A publisher of write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.