| Package | Description |
|---|---|
| com.datastax.oss.dsbulk.executor.api | |
| com.datastax.oss.dsbulk.executor.reactor | |
| com.datastax.oss.dsbulk.workflow.commons.settings |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBulkExecutorBuilder<T extends BulkExecutor> |
interface |
BulkExecutorBuilder<T extends BulkExecutor>
A builder for
BulkExecutor instances. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBulkExecutor
Base class for implementations of
BulkExecutor. |
| Modifier and Type | Method and Description |
|---|---|
BulkExecutorBuilder<? extends BulkExecutor> |
BulkExecutorBuilderFactory.create(CqlSession session,
boolean useContinuousPagingForReads)
Creates a new
BulkExecutorBuilder for the given session. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ReactorBulkExecutor
|
| Modifier and Type | Class and Description |
|---|---|
class |
ContinuousReactorBulkExecutor
An implementation of
BulkExecutor using Reactor,
that executes all reads using continuous paging. |
class |
DefaultReactorBulkExecutor
An implementation of
BulkExecutor using Reactor. |
| Modifier and Type | Method and Description |
|---|---|
protected BulkExecutor |
ExecutorSettings.newBulkExecutor(CqlSession session,
ExecutionListener executionListener,
boolean read,
boolean searchQuery) |
Copyright © 2017–2021 DataStax. All rights reserved.