Uses of Interface
com.datastax.oss.dsbulk.batcher.api.ReactiveStatementBatcher

Packages that use ReactiveStatementBatcher

Package	Description
com.datastax.oss.dsbulk.batcher.api
com.datastax.oss.dsbulk.batcher.reactor
com.datastax.oss.dsbulk.workflow.commons.settings

Uses of ReactiveStatementBatcher in com.datastax.oss.dsbulk.batcher.api

Methods in com.datastax.oss.dsbulk.batcher.api that return ReactiveStatementBatcher

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).

Uses of ReactiveStatementBatcher in com.datastax.oss.dsbulk.batcher.reactor

Classes in com.datastax.oss.dsbulk.batcher.reactor that implement ReactiveStatementBatcher

Modifier and Type	Class and Description
class	ReactorStatementBatcher

Methods in com.datastax.oss.dsbulk.batcher.reactor that return ReactiveStatementBatcher

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)

Uses of ReactiveStatementBatcher in com.datastax.oss.dsbulk.workflow.commons.settings

Methods in com.datastax.oss.dsbulk.workflow.commons.settings that return ReactiveStatementBatcher

Modifier and Type	Method and Description
ReactiveStatementBatcher	BatchSettings.newStatementBatcher(CqlSession session)