com.datastax.oss.dsbulk.batcher.reactor

Class ReactorStatementBatcherFactory

java.lang.Object

com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcherFactory

All Implemented Interfaces:

ReactiveStatementBatcherFactory

public class ReactorStatementBatcherFactory
extends Object
implements ReactiveStatementBatcherFactory

Field Summary

Fields inherited from interface com.datastax.oss.dsbulk.batcher.api.ReactiveStatementBatcherFactory

DEFAULT_MAX_BATCH_STATEMENTS, DEFAULT_MAX_SIZE_BYTES

Constructor Summary

Constructors

Constructor and Description
ReactorStatementBatcherFactory()

Method Summary

Modifier and Type	Method and Description
ReactiveStatementBatcher	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.
ReactiveStatementBatcher	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	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	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	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).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.datastax.oss.dsbulk.batcher.api.ReactiveStatementBatcherFactory

create, create, create

Constructor Detail

ReactorStatementBatcherFactory

public ReactorStatementBatcherFactory()

Method Detail

create

public ReactiveStatementBatcher create()

Description copied from interface: ReactiveStatementBatcherFactory

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. It also uses the default maximum number of statements (100) and the default maximum data size in bytes (unlimited).

Specified by:

create in interface ReactiveStatementBatcherFactory

create

public ReactiveStatementBatcher create(int maxBatchStatements)

Description copied from interface: ReactiveStatementBatcherFactory

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). It uses the given maximum number of statements.

Specified by:

create in interface ReactiveStatementBatcherFactory

Parameters:

maxBatchStatements - The maximum number of statements in a batch. If set to zero or any negative value, the number of statements is considered unlimited.

create

public ReactiveStatementBatcher create(long maxSizeInBytes)

Description copied from interface: ReactiveStatementBatcherFactory

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). It uses the given maximum data size in bytes.

Specified by:

create in interface ReactiveStatementBatcherFactory

Parameters:

maxSizeInBytes - The maximum number of bytes of data in one batch. If set to zero or any negative value, the data size is considered unlimited.

create

public ReactiveStatementBatcher create(int maxBatchStatements,
                                       long maxSizeInBytes)

Description copied from interface: ReactiveStatementBatcherFactory

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. It uses the given maximum number of statements and the maximum data size in bytes.

Specified by:

create in interface ReactiveStatementBatcherFactory

Parameters:

maxBatchStatements - The maximum number of statements in a batch. If set to zero or any negative value, the number of statements is considered unlimited.

maxSizeInBytes - The maximum number of bytes of data in one batch. If set to zero or any negative value, the data size is considered unlimited.

create

public ReactiveStatementBatcher create(@NonNull
                                       CqlSession session,
                                       @NonNull
                                       BatchMode batchMode,
                                       @NonNull
                                       BatchType batchType,
                                       int maxBatchStatements,
                                       long maxSizeInBytes)

Description copied from interface: ReactiveStatementBatcherFactory

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. It uses the given maximum number of statements and the maximum data size in bytes.

Specified by:

create in interface ReactiveStatementBatcherFactory

Parameters:

session - The session to use; cannot be null.

batchMode - The batch mode to use; cannot be null.

batchType - The batch type to use; cannot be null.

maxBatchStatements - The maximum number of statements in a batch. If set to zero or any negative value, the number of statements is considered unlimited.

maxSizeInBytes - The maximum number of bytes of data in one batch. If set to zero or any negative value, the data size is considered unlimited.