com.datastax.oss.dsbulk.batcher.api

Interface ReactiveStatementBatcherFactory

All Known Implementing Classes:

ReactorStatementBatcherFactory

public interface ReactiveStatementBatcherFactory

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_BATCH_STATEMENTS The default maximum number of statements that a batch can contain.
static long	DEFAULT_MAX_SIZE_BYTES The default maximum data size in bytes that a batch can contain (unlimited).

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

Field Detail

DEFAULT_MAX_BATCH_STATEMENTS

static final int DEFAULT_MAX_BATCH_STATEMENTS

The default maximum number of statements that a batch can contain.

See Also:

Constant Field Values

DEFAULT_MAX_SIZE_BYTES

static final long DEFAULT_MAX_SIZE_BYTES

The default maximum data size in bytes that a batch can contain (unlimited).

See Also:

Constant Field Values

Method Detail

create

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

create

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

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

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

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

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

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

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

Parameters:

session - The session to use; cannot be null.

create

default ReactiveStatementBatcher create(@NonNull
                                        CqlSession session,
                                        @NonNull
                                        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. It also uses the default maximum number of statements (100) and the default maximum data size in bytes (unlimited).

Parameters:

session - The session to use; cannot be null.

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

create

default ReactiveStatementBatcher create(@NonNull
                                        CqlSession session,
                                        @NonNull
                                        BatchMode batchMode,
                                        @NonNull
                                        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. It uses the given maximum number of statements and the default maximum data size in bytes (unlimited).

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.

create

ReactiveStatementBatcher create(@NonNull
                                CqlSession session,
                                @NonNull
                                BatchMode batchMode,
                                @NonNull
                                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. It uses the given maximum number of statements and the maximum data size in bytes.

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.