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

Packages that use ReadResult

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

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

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

Modifier and Type	Method and Description
void	ReadResultPublisher.subscribe(Subscriber<? super ReadResult> subscriber)
void	ContinuousReadResultPublisher.subscribe(Subscriber<? super ReadResult> subscriber)

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

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

Modifier and Type	Method and Description
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.

Method parameters in com.datastax.oss.dsbulk.executor.api.reader with type arguments of type ReadResult

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.
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 ReadResult in com.datastax.oss.dsbulk.executor.api.result

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

Modifier and Type	Class and Description
class	DefaultReadResult

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

Methods in com.datastax.oss.dsbulk.executor.api.subscription that return ReadResult

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

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

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

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

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

Modifier and Type	Method and Description
Flux<ReadResult>	DefaultReactorBulkExecutor.readReactive(Iterable<? extends Statement<?>> statements)
Flux<ReadResult>	DefaultReactorBulkExecutor.readReactive(Publisher<? extends Statement<?>> statements)
Flux<ReadResult>	DefaultReactorBulkExecutor.readReactive(Statement<?> statement)
Flux<ReadResult>	ContinuousReactorBulkExecutor.readReactive(Statement<?> statement)
Flux<ReadResult>	DefaultReactorBulkExecutor.readReactive(Stream<? extends Statement<?>> statements)
Flux<ReadResult>	DefaultReactorBulkExecutor.readReactive(String statement)

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

Modifier and Type	Method and Description
CompletableFuture<Void>	DefaultReactorBulkExecutor.readAsync(Iterable<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer)
CompletableFuture<Void>	DefaultReactorBulkExecutor.readAsync(Publisher<? 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)
void	DefaultReactorBulkExecutor.readSync(Iterable<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer)
void	DefaultReactorBulkExecutor.readSync(Stream<? extends Statement<?>> statements, Consumer<? super ReadResult> consumer)

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

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

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 ReadResult in com.datastax.oss.dsbulk.workflow.commons.log

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

Modifier and Type	Method and Description
Function<Flux<ReadResult>,Flux<ReadResult>>	LogManager.newFailedReadsHandler() Handler for unsuccessful ReadResults.
Function<Flux<ReadResult>,Flux<ReadResult>>	LogManager.newFailedReadsHandler() Handler for unsuccessful ReadResults.

Uses of ReadResult in com.datastax.oss.dsbulk.workflow.commons.schema

Methods in com.datastax.oss.dsbulk.workflow.commons.schema with parameters of type ReadResult

Modifier and Type	Method and Description
Record	ReadResultMapper.map(ReadResult result)
Record	DefaultReadResultMapper.map(ReadResult result)
void	ReadResultCounter.CountingUnit.update(ReadResult result)