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

Class WriteResultPublisher

java.lang.Object

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

All Implemented Interfaces:

Publisher<WriteResult>

public class WriteResultPublisher
extends Object
implements Publisher<WriteResult>

A Publisher for WriteResults.

See Also:

ReactiveBulkWriter.writeReactive(Statement)

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

WriteResultPublisher

public WriteResultPublisher(@NonNull
                            Statement<?> statement,
                            @NonNull
                            CqlSession session,
                            boolean failFast)

Creates a new WriteResultPublisher without ExecutionListener and without throughput regulation.

Parameters:

statement - The Statement to execute.

session - The CqlSession to use.

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

WriteResultPublisher

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

Creates a new WriteResultPublisher.

Parameters:

statement - The Statement to execute.

session - The CqlSession 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 WriteResult> subscriber)

Specified by:

subscribe in interface Publisher<WriteResult>