com.datastax.oss.dsbulk.executor.api.publisher

Class ContinuousReadResultPublisher

java.lang.Object

com.datastax.oss.dsbulk.executor.api.publisher.ContinuousReadResultPublisher

All Implemented Interfaces:

Publisher<ReadResult>

public class ContinuousReadResultPublisher
extends Object
implements Publisher<ReadResult>

A Publisher for ReadResults that uses continuous paging.

See Also:

ReactiveBulkReader.readReactive(Statement)

Constructor Summary

Constructors

Constructor and Description
ContinuousReadResultPublisher(Statement<?> statement, ContinuousSession session, boolean failFast) Creates a new ContinuousReadResultPublisher with default paging options, without ExecutionListener and without throughput regulation.
ContinuousReadResultPublisher(Statement<?> statement, ContinuousSession session, boolean failFast, ExecutionListener listener, Semaphore maxConcurrentRequests, com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter) Creates a new ContinuousReadResultPublisher.

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ContinuousReadResultPublisher

public ContinuousReadResultPublisher(@NonNull
                                     Statement<?> statement,
                                     @NonNull
                                     ContinuousSession session,
                                     boolean failFast)

Creates a new ContinuousReadResultPublisher with default paging options, without ExecutionListener and without throughput regulation.

Parameters:

statement - The Statement to execute.

session - The ContinuousSession to use.

failFast - whether to fail-fast in case of error.

ContinuousReadResultPublisher

public ContinuousReadResultPublisher(@NonNull
                                     Statement<?> statement,
                                     @NonNull
                                     ContinuousSession session,
                                     boolean failFast,
                                     @Nullable
                                     ExecutionListener listener,
                                     @Nullable
                                     Semaphore maxConcurrentRequests,
                                     @Nullable
                                     com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter)

Creates a new ContinuousReadResultPublisher.

Parameters:

statement - The Statement to execute.

session - The ContinuousSession to use.

failFast - whether to fail-fast in case of error.

listener - The ExecutionListener to use.

maxConcurrentRequests - The Semaphore to use to regulate the amount of in-flight requests.

rateLimiter - The RateLimiter to use to regulate throughput.

Method Detail

subscribe

public void subscribe(Subscriber<? super ReadResult> subscriber)

Specified by:

subscribe in interface Publisher<ReadResult>