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

Interface BulkWriter

All Superinterfaces:

AsyncBulkWriter, AutoCloseable, ReactiveBulkWriter, SyncBulkWriter

All Known Subinterfaces:

BulkExecutor, ReactorBulkExecutor

All Known Implementing Classes:

AbstractBulkExecutor, ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface BulkWriter
extends SyncBulkWriter, AsyncBulkWriter, ReactiveBulkWriter

A bulk writer that operates in 3 distinct modes:

1. Synchronous;
2. Asynchronous;
3. Reactive.

Method Summary

Modifier and Type	Method and Description
default void	writeSync(Publisher<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer) Executes the given flow of write statements synchronously, notifying the given consumer of every write result.
default WriteResult	writeSync(Statement<?> statement) Executes the given write statement synchronously.

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

writeSync, writeSync, writeSync, writeSync, writeSync, writeSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.ReactiveBulkWriter

writeReactive, writeReactive, writeReactive, writeReactive, writeReactive

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

writeSync

default WriteResult writeSync(Statement<?> statement)
                       throws BulkExecutionException

Description copied from interface: SyncBulkWriter

Executes the given write statement synchronously.

Specified by:

writeSync in interface SyncBulkWriter

Parameters:

statement - The statement to execute.

Returns:

The write result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeSync

default void writeSync(Publisher<? extends Statement<?>> statements,
                       Consumer<? super WriteResult> consumer)
                throws BulkExecutionException

Description copied from interface: SyncBulkWriter

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

Specified by:

writeSync in interface SyncBulkWriter

Parameters:

statements - The statements to execute.

consumer - A consumer for write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.