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

Interface SyncBulkWriter

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

BulkExecutor, BulkWriter, ReactorBulkExecutor, SyncBulkExecutor

All Known Implementing Classes:

AbstractBulkExecutor, ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface SyncBulkWriter
extends AutoCloseable

A synchronous execution unit for bulk write operations.

Methods of this interface are expected to block until the whole write operation completes.

Method Summary

Modifier and Type	Method and Description
default void	writeSync(Iterable<? extends Statement<?>> statements) Executes the given iterable of write statements synchronously.
void	writeSync(Iterable<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer) Executes the given iterable of write statements synchronously, notifying the given consumer of every write result.
default void	writeSync(Publisher<? extends Statement<?>> statements) Executes the given flow of write statements synchronously.
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.
WriteResult	writeSync(Statement<?> statement) Executes the given write statement synchronously.
default void	writeSync(Stream<? extends Statement<?>> statements) Executes the given stream of write statements synchronously.
void	writeSync(Stream<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer) Executes the given stream of write statements synchronously, notifying the given consumer of every write result.
default WriteResult	writeSync(String statement) Executes the given write statement synchronously.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

writeSync

default WriteResult writeSync(String statement)
                       throws BulkExecutionException

Executes the given write statement synchronously.

Parameters:

statement - The statement to execute.

Returns:

The write result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeSync

WriteResult writeSync(Statement<?> statement)
               throws BulkExecutionException

Executes the given write statement synchronously.

Parameters:

statement - The statement to execute.

Returns:

The write result.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeSync

default void writeSync(Stream<? extends Statement<?>> statements)
                throws BulkExecutionException

Executes the given stream of write statements synchronously.

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

Parameters:

statements - The statements to execute.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeSync

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

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

Parameters:

statements - The statements to execute.

consumer - A consumer for write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeSync

default void writeSync(Iterable<? extends Statement<?>> statements)
                throws BulkExecutionException

Executes the given iterable of write statements synchronously.

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

Parameters:

statements - The statements to execute.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeSync

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

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

Parameters:

statements - The statements to execute.

consumer - A consumer for write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeSync

default void writeSync(Publisher<? extends Statement<?>> statements)
                throws BulkExecutionException

Executes the given flow of write statements synchronously.

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

Parameters:

statements - The statements to execute.

Throws:

BulkExecutionException - if the operation cannot complete normally.

writeSync

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

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

Parameters:

statements - The statements to execute.

consumer - A consumer for write results.

Throws:

BulkExecutionException - if the operation cannot complete normally.