public class ReactorStatementBatcherFactory extends Object implements ReactiveStatementBatcherFactory
DEFAULT_MAX_BATCH_STATEMENTS, DEFAULT_MAX_SIZE_BYTES| Constructor and Description |
|---|
ReactorStatementBatcherFactory() |
| 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). |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreate, create, createpublic ReactiveStatementBatcher create()
ReactiveStatementBatcherFactoryReactiveStatementBatcher 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 in interface ReactiveStatementBatcherFactorypublic ReactiveStatementBatcher create(int maxBatchStatements)
ReactiveStatementBatcherFactoryReactiveStatementBatcher 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.create in interface ReactiveStatementBatcherFactorymaxBatchStatements - The maximum number of statements in a batch. If set to zero or any
negative value, the number of statements is considered unlimited.public ReactiveStatementBatcher create(long maxSizeInBytes)
ReactiveStatementBatcherFactoryReactiveStatementBatcher 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.create in interface ReactiveStatementBatcherFactorymaxSizeInBytes - The maximum number of bytes of data in one batch. If set to zero or any
negative value, the data size is considered unlimited.public ReactiveStatementBatcher create(int maxBatchStatements, long maxSizeInBytes)
ReactiveStatementBatcherFactoryReactiveStatementBatcher 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.create in interface ReactiveStatementBatcherFactorymaxBatchStatements - 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.public ReactiveStatementBatcher create(@NonNull CqlSession session, @NonNull BatchMode batchMode, @NonNull BatchType batchType, int maxBatchStatements, long maxSizeInBytes)
ReactiveStatementBatcherFactoryReactiveStatementBatcher 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.create in interface ReactiveStatementBatcherFactorysession - 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.Copyright © 2017–2021 DataStax. All rights reserved.