com.datastax.oss.dsbulk.executor.reactor.writer

Interface ReactorBulkWriter

All Superinterfaces:

AutoCloseable, ReactiveBulkWriter

All Known Subinterfaces:

ReactorBulkExecutor

All Known Implementing Classes:

ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface ReactorBulkWriter
extends ReactiveBulkWriter

A reactive execution unit for bulk write operations using Reactor.

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

Method Summary

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

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

writeReactive

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

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

Specified by:

writeReactive in interface ReactiveBulkWriter

Parameters:

statement - The statement to execute.

Returns:

A Flux that will emit one single write result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeReactive

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

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

Specified by:

writeReactive in interface ReactiveBulkWriter

Parameters:

statement - The statement to execute.

Returns:

A Flux that will emit one single write result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeReactive

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

Executes the given stream of write statements reactively.

Specified by:

writeReactive in interface ReactiveBulkWriter

Parameters:

statements - The statements to execute.

Returns:

A Flux of write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeReactive

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

Executes the given iterable of write statements reactively.

Specified by:

writeReactive in interface ReactiveBulkWriter

Parameters:

statements - The statements to execute.

Returns:

A Flux of write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeReactive

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

Executes the given Flux of write statements reactively.

Specified by:

writeReactive in interface ReactiveBulkWriter

Parameters:

statements - The statements to execute.

Returns:

A Flux of write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.