| Package | Description |
|---|---|
| com.datastax.oss.dsbulk.executor.api | |
| com.datastax.oss.dsbulk.executor.reactor | |
| com.datastax.oss.dsbulk.workflow.commons.settings |
| Modifier and Type | Interface and Description |
|---|---|
interface |
BulkExecutor
An execution unit for
bulk writes and bulk reads that
operates in 3 distinct modes: synchronous (blocking), asynchronous (non-blocking), and reactive. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBulkExecutor
Base class for implementations of
BulkExecutor. |
| 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 |
|---|---|
BulkWriter |
ExecutorSettings.newWriteExecutor(CqlSession session,
ExecutionListener executionListener) |
Copyright © 2017–2021 DataStax. All rights reserved.