com.datastax.oss.dsbulk.executor.api

Class AbstractBulkExecutor

java.lang.Object

com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

All Implemented Interfaces:

AsyncBulkExecutor, BulkExecutor, ReactiveBulkExecutor, AsyncBulkReader, BulkReader, ReactiveBulkReader, SyncBulkReader, SyncBulkExecutor, AsyncBulkWriter, BulkWriter, ReactiveBulkWriter, SyncBulkWriter, AutoCloseable

Direct Known Subclasses:

DefaultReactorBulkExecutor

public abstract class AbstractBulkExecutor
extends Object
implements BulkExecutor, AutoCloseable

Base class for implementations of BulkExecutor.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	failFast
protected ExecutionListener	listener
protected Semaphore	maxConcurrentRequests
protected com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter	rateLimiter
protected CqlSession	session

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractBulkExecutor(AbstractBulkExecutorBuilder<?> builder)
protected	AbstractBulkExecutor(CqlSession session)

Method Summary

Modifier and Type	Method and Description
void	close()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.BulkWriter

writeSync, writeSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.BulkReader

readSync, readSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

writeSync, writeSync, writeSync, writeSync, writeSync, writeSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.SyncBulkReader

readSync, readSync, readSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.AsyncBulkReader

readAsync, readAsync, readAsync, readAsync, readAsync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.ReactiveBulkWriter

writeReactive, writeReactive, writeReactive, writeReactive, writeReactive

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.ReactiveBulkReader

readReactive, readReactive, readReactive, readReactive, readReactive

Field Detail

session

@NonNull
protected final CqlSession session

failFast

protected final boolean failFast

maxConcurrentRequests

@Nullable
protected final Semaphore maxConcurrentRequests

rateLimiter

@Nullable
protected final com.datastax.oss.driver.shaded.guava.common.util.concurrent.RateLimiter rateLimiter

listener

@Nullable
protected final ExecutionListener listener

Constructor Detail

AbstractBulkExecutor

protected AbstractBulkExecutor(CqlSession session)

AbstractBulkExecutor

protected AbstractBulkExecutor(AbstractBulkExecutorBuilder<?> builder)

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable