| Package | Description |
|---|---|
| com.datastax.oss.dsbulk.executor.api | |
| com.datastax.oss.dsbulk.executor.reactor |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBulkExecutorBuilder<T extends BulkExecutor> |
| Modifier and Type | Method and Description |
|---|---|
BulkExecutorBuilder<? extends BulkExecutor> |
BulkExecutorBuilderFactory.create(CqlSession session,
boolean useContinuousPagingForReads)
Creates a new
BulkExecutorBuilder for the given session. |
BulkExecutorBuilder<T> |
BulkExecutorBuilder.failSafe()
Switches on fail-safe mode.
|
BulkExecutorBuilder<T> |
BulkExecutorBuilder.withExecutionListener(ExecutionListener listener)
Sets an optional
ExecutionListener. |
BulkExecutorBuilder<T> |
BulkExecutorBuilder.withMaxInFlightRequests(int maxInFlightRequests)
Sets the maximum number of in-flight requests.
|
BulkExecutorBuilder<T> |
BulkExecutorBuilder.withMaxRequestsPerSecond(int maxRequestsPerSecond)
Sets the maximum number of concurrent requests per second.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ContinuousReactorBulkExecutorBuilder
A builder for
ContinuousReactorBulkExecutor instances. |
class |
DefaultReactorBulkExecutorBuilder
A builder for
DefaultReactorBulkExecutor instances. |
| Modifier and Type | Method and Description |
|---|---|
BulkExecutorBuilder<? extends ReactorBulkExecutor> |
ReactorBulkExecutorBuilderFactory.create(CqlSession session,
boolean useContinuousPagingForReads) |
Copyright © 2017–2021 DataStax. All rights reserved.