| Package | Description |
|---|---|
| com.datastax.oss.dsbulk.batcher.api | |
| com.datastax.oss.dsbulk.batcher.reactor | |
| com.datastax.oss.dsbulk.workflow.commons.settings |
| Modifier and Type | Method and Description |
|---|---|
ReactiveStatementBatcher |
ReactiveStatementBatcherFactory.create()
Creates a new
ReactiveStatementBatcher that produces unlogged batches, operates in partition key mode and uses the latest stable protocol
version and the default CodecRegistry instance. |
default ReactiveStatementBatcher |
ReactiveStatementBatcherFactory.create(CqlSession session)
Creates a new
ReactiveStatementBatcher that produces unlogged batches, operates in partition key 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)
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. |
ReactiveStatementBatcher |
ReactiveStatementBatcherFactory.create(int maxBatchStatements)
Creates a new
ReactiveStatementBatcher that produces unlogged batches, operates in partition key mode and uses the latest stable protocol
version and the default CodecRegistry instance and the default
maximum data size in bytes (unlimited). |
ReactiveStatementBatcher |
ReactiveStatementBatcherFactory.create(int maxBatchStatements,
long maxSizeInBytes)
Creates a new
ReactiveStatementBatcher that produces unlogged batches, operates in partition key mode and uses the latest stable protocol
version and the default CodecRegistry instance. |
ReactiveStatementBatcher |
ReactiveStatementBatcherFactory.create(long maxSizeInBytes)
Creates a new
ReactiveStatementBatcher that produces unlogged batches, operates in partition key mode and uses the latest stable protocol
version and the default CodecRegistry instance and the default
maximum number of statements (100). |
| Modifier and Type | Class and Description |
|---|---|
class |
ReactorStatementBatcher |
| Modifier and Type | Method and Description |
|---|---|
ReactiveStatementBatcher |
ReactorStatementBatcherFactory.create() |
ReactiveStatementBatcher |
ReactorStatementBatcherFactory.create(CqlSession session,
BatchMode batchMode,
BatchType batchType,
int maxBatchStatements,
long maxSizeInBytes) |
ReactiveStatementBatcher |
ReactorStatementBatcherFactory.create(int maxBatchStatements) |
ReactiveStatementBatcher |
ReactorStatementBatcherFactory.create(int maxBatchStatements,
long maxSizeInBytes) |
ReactiveStatementBatcher |
ReactorStatementBatcherFactory.create(long maxSizeInBytes) |
| Modifier and Type | Method and Description |
|---|---|
ReactiveStatementBatcher |
BatchSettings.newStatementBatcher(CqlSession session) |
Copyright © 2017–2021 DataStax. All rights reserved.