| Package | Description |
|---|---|
| com.datastax.oss.dsbulk.batcher.api | |
| com.datastax.oss.dsbulk.batcher.reactor |
| Modifier and Type | Field and Description |
|---|---|
protected BatchMode |
DefaultStatementBatcher.batchMode |
| Modifier and Type | Method and Description |
|---|---|
static BatchMode |
BatchMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static BatchMode[] |
BatchMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
default ReactiveStatementBatcher |
ReactiveStatementBatcherFactory.create(CqlSession session,
BatchMode batchMode)
Creates a new
ReactiveStatementBatcher that produces unlogged batches, operates in the specified batch mode and uses the given session as its source for the
protocol version and the CodecRegistry instance to use. |
default ReactiveStatementBatcher |
ReactiveStatementBatcherFactory.create(CqlSession session,
BatchMode batchMode,
BatchType batchType,
int maxBatchStatements)
Creates a new
ReactiveStatementBatcher that produces batches of the given batchType, operates in the specified batchMode and uses the given session as its source for the protocol version and the
CodecRegistry instance to use. |
ReactiveStatementBatcher |
ReactiveStatementBatcherFactory.create(CqlSession session,
BatchMode batchMode,
BatchType batchType,
int maxBatchStatements,
long maxSizeInBytes)
Creates a new
ReactiveStatementBatcher that produces batches of the given batchType, operates in the specified batchMode and uses the given session as its source for the protocol version and the
CodecRegistry instance to use. |
| Constructor and Description |
|---|
DefaultStatementBatcher(CqlSession session,
BatchMode batchMode)
Creates a new
DefaultStatementBatcher that produces unlogged batches, operates in the specified batch mode and uses the given session as its source for the
protocol version and the CodecRegistry instance to use. |
DefaultStatementBatcher(CqlSession session,
BatchMode batchMode,
BatchType batchType,
int maxBatchStatements)
Creates a new
DefaultStatementBatcher that produces batches of the given batchType, operates in the specified batchMode and uses the given session as its source for the protocol version and the
CodecRegistry instance to use. |
DefaultStatementBatcher(CqlSession session,
BatchMode batchMode,
BatchType batchType,
int maxBatchStatements,
long maxSizeInBytes)
Creates a new
DefaultStatementBatcher that produces batches of the given batchType, operates in the specified batchMode and uses the given session as its source for the protocol version and the
CodecRegistry instance to use. |
| Modifier and Type | Method and Description |
|---|---|
ReactiveStatementBatcher |
ReactorStatementBatcherFactory.create(CqlSession session,
BatchMode batchMode,
BatchType batchType,
int maxBatchStatements,
long maxSizeInBytes) |
| Constructor and Description |
|---|
ReactorStatementBatcher(CqlSession session,
BatchMode batchMode)
Creates a new
ReactorStatementBatcher that produces unlogged batches, operates in the specified batch mode and uses the given session as its source for the
protocol version and the CodecRegistry instance to use. |
ReactorStatementBatcher(CqlSession session,
BatchMode batchMode,
BatchType batchType,
int maxBatchStatements)
Creates a new
ReactorStatementBatcher that produces batches of the given batchType, operates in the specified batchMode and uses the given session as its source for the protocol version and the
CodecRegistry instance to use. |
ReactorStatementBatcher(CqlSession session,
BatchMode batchMode,
BatchType batchType,
int maxBatchStatements,
long maxSizeInBytes)
Creates a new
ReactorStatementBatcher that produces batches of the given batchType, operates in the specified batchMode and uses the given session as its source for the protocol version and the
CodecRegistry instance to use. |
Copyright © 2017–2021 DataStax. All rights reserved.