Uses of Interface
com.datastax.oss.dsbulk.executor.api.result.WriteResult

Packages that use WriteResult

Package	Description
com.datastax.oss.dsbulk.executor.api.publisher
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.writer
com.datastax.oss.dsbulk.workflow.commons.log

Uses of WriteResult in com.datastax.oss.dsbulk.executor.api.publisher

Method parameters in com.datastax.oss.dsbulk.executor.api.publisher with type arguments of type WriteResult

Modifier and Type	Method and Description
void	WriteResultPublisher.subscribe(Subscriber<? super WriteResult> subscriber)

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

Classes in com.datastax.oss.dsbulk.executor.api.result that implement WriteResult

Modifier and Type	Class and Description
class	DefaultWriteResult
class	EmptyWriteResult

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

Constructor parameters in com.datastax.oss.dsbulk.executor.api.subscription with type arguments of type WriteResult

Constructor and Description
WriteResultSubscription(Subscriber<? super WriteResult> subscriber, Statement<?> statement, ExecutionListener listener, Semaphore maxConcurrentRequests, com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter, boolean failFast)

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

Methods in com.datastax.oss.dsbulk.executor.api.writer that return WriteResult

Modifier and Type	Method and Description
WriteResult	SyncBulkWriter.writeSync(Statement<?> statement) Executes the given write statement synchronously.
default WriteResult	BulkWriter.writeSync(Statement<?> statement)
default WriteResult	SyncBulkWriter.writeSync(String statement) Executes the given write statement synchronously.

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

Modifier and Type	Method and Description
CompletableFuture<WriteResult>	AsyncBulkWriter.writeAsync(Statement<?> statement) Executes the given write statement asynchronously.
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.

Method parameters in com.datastax.oss.dsbulk.executor.api.writer with type arguments of type WriteResult

Modifier and Type	Method and Description
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.
CompletableFuture<Void>	AsyncBulkWriter.writeAsync(Publisher<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer) Executes the given flow of write statements asynchronously, notifying the given consumer of every write result.
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.
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.
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)
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.

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

Methods in com.datastax.oss.dsbulk.executor.reactor that return types with arguments of type WriteResult

Modifier and Type	Method and Description
CompletableFuture<WriteResult>	DefaultReactorBulkExecutor.writeAsync(Statement<?> statement)
Flux<WriteResult>	DefaultReactorBulkExecutor.writeReactive(Iterable<? extends Statement<?>> statements)
Flux<WriteResult>	DefaultReactorBulkExecutor.writeReactive(Publisher<? extends Statement<?>> statements)
Mono<WriteResult>	DefaultReactorBulkExecutor.writeReactive(Statement<?> statement)
Flux<WriteResult>	DefaultReactorBulkExecutor.writeReactive(Stream<? extends Statement<?>> statements)

Method parameters in com.datastax.oss.dsbulk.executor.reactor with type arguments of type WriteResult

Modifier and Type	Method and Description
CompletableFuture<Void>	DefaultReactorBulkExecutor.writeAsync(Iterable<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)
CompletableFuture<Void>	DefaultReactorBulkExecutor.writeAsync(Publisher<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)
CompletableFuture<Void>	DefaultReactorBulkExecutor.writeAsync(Stream<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)
void	DefaultReactorBulkExecutor.writeSync(Iterable<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)
void	DefaultReactorBulkExecutor.writeSync(Stream<? extends Statement<?>> statements, Consumer<? super WriteResult> consumer)

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

Methods in com.datastax.oss.dsbulk.executor.reactor.writer that return types with arguments of type WriteResult

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.

Uses of WriteResult in com.datastax.oss.dsbulk.workflow.commons.log

Methods in com.datastax.oss.dsbulk.workflow.commons.log that return types with arguments of type WriteResult

Modifier and Type	Method and Description
Function<Flux<WriteResult>,Flux<WriteResult>>	LogManager.newFailedWritesHandler() Handler for unsuccessful WriteResults.
Function<Flux<WriteResult>,Flux<WriteResult>>	LogManager.newFailedWritesHandler() Handler for unsuccessful WriteResults.
Function<Flux<WriteResult>,Flux<Void>>	LogManager.newResultPositionsHandler() Handler for result positions.