Uses of Class
com.datastax.oss.dsbulk.executor.api.exception.BulkExecutionException

Packages that use BulkExecutionException

Package	Description
com.datastax.oss.dsbulk.executor.api.listener
com.datastax.oss.dsbulk.executor.api.reader
com.datastax.oss.dsbulk.executor.api.result
com.datastax.oss.dsbulk.executor.api.subscription
com.datastax.oss.dsbulk.executor.api.writer
com.datastax.oss.dsbulk.executor.reactor
com.datastax.oss.dsbulk.executor.reactor.reader
com.datastax.oss.dsbulk.executor.reactor.writer

Uses of BulkExecutionException in com.datastax.oss.dsbulk.executor.api.listener

Methods in com.datastax.oss.dsbulk.executor.api.listener with parameters of type BulkExecutionException

Modifier and Type	Method and Description
void	MetricsCollectingExecutionListener.onExecutionFailed(BulkExecutionException exception, ExecutionContext context)
default void	ExecutionListener.onExecutionFailed(BulkExecutionException exception, ExecutionContext context) Called when a statement execution has failed.
void	CompositeExecutionListener.onExecutionFailed(BulkExecutionException exception, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onExecutionFailed(BulkExecutionException exception, ExecutionContext context)

Uses of BulkExecutionException in com.datastax.oss.dsbulk.executor.api.reader

Methods in com.datastax.oss.dsbulk.executor.api.reader that throw BulkExecutionException

Modifier and Type	Method and Description
CompletableFuture<Void>	AsyncBulkReader.readAsync(Iterable<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given stream of read statements asynchronously, notifying the given consumer of every read result.
CompletableFuture<Void>	AsyncBulkReader.readAsync(Publisher<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given iterable of read statements asynchronously, notifying the given consumer of every read result.
CompletableFuture<Void>	AsyncBulkReader.readAsync(Statement<?> statement, Consumer<? super ReadResult> consumer) Executes the given read statement asynchronously, notifying the given consumer of every read result.
CompletableFuture<Void>	AsyncBulkReader.readAsync(Stream<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given stream of read statements asynchronously, notifying the given consumer of every read result.
default CompletableFuture<Void>	AsyncBulkReader.readAsync(String statement, Consumer<? super ReadResult> consumer) Executes the given read statement asynchronously, notifying the given consumer of every read result.
Publisher<ReadResult>	ReactiveBulkReader.readReactive(Iterable<? extends Statement<?>> statements) Executes the given iterable of read statements reactively.
Publisher<ReadResult>	ReactiveBulkReader.readReactive(Publisher<? extends Statement<?>> statements) Executes the given publisher of read statements reactively.
Publisher<ReadResult>	ReactiveBulkReader.readReactive(Statement<?> statement) Executes the given read statement reactively.
Publisher<ReadResult>	ReactiveBulkReader.readReactive(Stream<? extends Statement<?>> statements) Executes the given stream of read statements reactively.
default Publisher<ReadResult>	ReactiveBulkReader.readReactive(String statement) Executes the given read statement reactively.
void	SyncBulkReader.readSync(Iterable<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given stream of read statements synchronously, notifying the given consumer of every read result.
void	SyncBulkReader.readSync(Publisher<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given iterable of read statements asynchronously, notifying the given consumer of every read result.
default void	BulkReader.readSync(Publisher<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer)
void	SyncBulkReader.readSync(Statement<?> statement, Consumer<? super ReadResult> consumer) Executes the given read statement synchronously, notifying the given consumer of every read result.
default void	BulkReader.readSync(Statement<?> statement, Consumer<? super ReadResult> consumer)
void	SyncBulkReader.readSync(Stream<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer) Executes the given stream of read statements synchronously, notifying the given consumer of every read result.
default void	SyncBulkReader.readSync(String statement, Consumer<? super ReadResult> consumer) Executes the given read statement synchronously, notifying the given consumer of every read result.

Uses of BulkExecutionException in com.datastax.oss.dsbulk.executor.api.result

Methods in com.datastax.oss.dsbulk.executor.api.result that return types with arguments of type BulkExecutionException

Modifier and Type	Method and Description
Optional<BulkExecutionException>	Result.getError() Returns an optional BulkExecutionException.
Optional<BulkExecutionException>	EmptyWriteResult.getError()

Method parameters in com.datastax.oss.dsbulk.executor.api.result with type arguments of type BulkExecutionException

Modifier and Type	Method and Description
default void	Result.ifError(Consumer<? super BulkExecutionException> consumer) If an error is present, invoke the specified consumer with the error, otherwise do nothing.

Constructors in com.datastax.oss.dsbulk.executor.api.result with parameters of type BulkExecutionException

Constructor and Description
DefaultReadResult(BulkExecutionException error)
DefaultWriteResult(BulkExecutionException error)

Uses of BulkExecutionException in com.datastax.oss.dsbulk.executor.api.subscription

Methods in com.datastax.oss.dsbulk.executor.api.subscription with parameters of type BulkExecutionException

Modifier and Type	Method and Description
protected ReadResult	ContinuousReadResultSubscription.toErrorResult(BulkExecutionException error)

Uses of BulkExecutionException in com.datastax.oss.dsbulk.executor.api.writer

Methods in com.datastax.oss.dsbulk.executor.api.writer that throw BulkExecutionException

Modifier and Type	Method and Description
default CompletableFuture<Void>	AsyncBulkWriter.writeAsync(Iterable<? extends Statement<?>> statements) Executes the given iterable of write statements asynchronously.
CompletableFuture<Void>	AsyncBulkWriter.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>	AsyncBulkWriter.writeAsync(Publisher<? extends Statement<?>> statements) Executes the given flow of write statements asynchronously.
CompletableFuture<WriteResult>	AsyncBulkWriter.writeAsync(Statement<?> statement) Executes the given write statement asynchronously.
default CompletableFuture<Void>	AsyncBulkWriter.writeAsync(Stream<? extends Statement<?>> statements) Executes the given stream of write statements asynchronously.
CompletableFuture<Void>	AsyncBulkWriter.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>	AsyncBulkWriter.writeAsync(String statement) Executes the given write statement asynchronously.
Publisher<WriteResult>	ReactiveBulkWriter.writeReactive(Iterable<? extends Statement<?>> statements) Executes the given iterable of write statements reactively.
Publisher<WriteResult>	ReactiveBulkWriter.writeReactive(Publisher<? extends Statement<?>> statements) Executes the given publisher of write statements reactively.
Publisher<WriteResult>	ReactiveBulkWriter.writeReactive(Statement<?> statement) Executes the given write statement reactively.
Publisher<WriteResult>	ReactiveBulkWriter.writeReactive(Stream<? extends Statement<?>> statements) Executes the given stream of write statements reactively.
default Publisher<WriteResult>	ReactiveBulkWriter.writeReactive(String statement) Executes the given write statement reactively.
default void	SyncBulkWriter.writeSync(Iterable<? extends Statement<?>> statements) Executes the given iterable of write statements synchronously.
void	SyncBulkWriter.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	SyncBulkWriter.writeSync(Publisher<? extends Statement<?>> statements) Executes the given flow of write statements synchronously.
void	SyncBulkWriter.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 void	BulkWriter.writeSync(Publisher<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)
WriteResult	SyncBulkWriter.writeSync(Statement<?> statement) Executes the given write statement synchronously.
default WriteResult	BulkWriter.writeSync(Statement<?> statement)
default void	SyncBulkWriter.writeSync(Stream<? extends Statement<?>> statements) Executes the given stream of write statements synchronously.
void	SyncBulkWriter.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	SyncBulkWriter.writeSync(String statement) Executes the given write statement synchronously.

Uses of BulkExecutionException in com.datastax.oss.dsbulk.executor.reactor

Methods in com.datastax.oss.dsbulk.executor.reactor that throw BulkExecutionException

Modifier and Type	Method and Description
CompletableFuture<Void>	DefaultReactorBulkExecutor.readAsync(Iterable<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer)
CompletableFuture<Void>	DefaultReactorBulkExecutor.readAsync(Statement<?> statement, Consumer<? super ReadResult> consumer)
CompletableFuture<Void>	DefaultReactorBulkExecutor.readAsync(Stream<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer)
Flux<ReadResult>	DefaultReactorBulkExecutor.readReactive(Iterable<? extends Statement<?>> statements)
Flux<ReadResult>	DefaultReactorBulkExecutor.readReactive(Publisher<? extends Statement<?>> statements)
Flux<ReadResult>	DefaultReactorBulkExecutor.readReactive(Stream<? extends Statement<?>> statements)
Flux<ReadResult>	DefaultReactorBulkExecutor.readReactive(String statement)
void	DefaultReactorBulkExecutor.readSync(Iterable<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer)
void	DefaultReactorBulkExecutor.readSync(Stream<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer)
CompletableFuture<Void>	DefaultReactorBulkExecutor.writeAsync(Iterable<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)
CompletableFuture<Void>	DefaultReactorBulkExecutor.writeAsync(Stream<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)
Flux<WriteResult>	DefaultReactorBulkExecutor.writeReactive(Iterable<? extends Statement<?>> statements)
Flux<WriteResult>	DefaultReactorBulkExecutor.writeReactive(Publisher<? extends Statement<?>> statements)
Flux<WriteResult>	DefaultReactorBulkExecutor.writeReactive(Stream<? extends Statement<?>> statements)
void	DefaultReactorBulkExecutor.writeSync(Iterable<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)
void	DefaultReactorBulkExecutor.writeSync(Stream<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)

Uses of BulkExecutionException in com.datastax.oss.dsbulk.executor.reactor.reader

Methods in com.datastax.oss.dsbulk.executor.reactor.reader that throw BulkExecutionException

Modifier and Type	Method and Description
Flux<ReadResult>	ReactorBulkReader.readReactive(Iterable<? extends Statement<?>> statements) Executes the given iterable of read statements reactively.
Flux<ReadResult>	ReactorBulkReader.readReactive(Publisher<? extends Statement<?>> statements) Executes the given Flux of read statements reactively.
Flux<ReadResult>	ReactorBulkReader.readReactive(Statement<?> statement) Executes the given read statement reactively.
Flux<ReadResult>	ReactorBulkReader.readReactive(Stream<? extends Statement<?>> statements) Executes the given stream of read statements reactively.
default Flux<ReadResult>	ReactorBulkReader.readReactive(String statement) Executes the given read statement reactively.

Uses of BulkExecutionException in com.datastax.oss.dsbulk.executor.reactor.writer

Methods in com.datastax.oss.dsbulk.executor.reactor.writer that throw BulkExecutionException

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