A B C D E F G H I J L M N O P Q R S T U V W X Z

A

AbsoluteErrorThreshold - Class in com.datastax.oss.dsbulk.workflow.api.error

AbstractBulkExecutor - Class in com.datastax.oss.dsbulk.executor.api

Base class for implementations of BulkExecutor.

AbstractBulkExecutor(CqlSession) - Constructor for class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

AbstractBulkExecutor(AbstractBulkExecutorBuilder<?>) - Constructor for class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

AbstractBulkExecutorBuilder<T extends BulkExecutor> - Class in com.datastax.oss.dsbulk.executor.api

AbstractBulkExecutorBuilder(CqlSession) - Constructor for class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

AbstractFileBasedConnector - Class in com.datastax.oss.dsbulk.connectors.commons

A parent class for connectors that read from and write to text-based files.

AbstractFileBasedConnector() - Constructor for class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

AbstractFileBasedConnector.RecordReader - Interface in com.datastax.oss.dsbulk.connectors.commons

A reader for Records.

AbstractFileBasedConnector.RecordWriter - Interface in com.datastax.oss.dsbulk.connectors.commons

A writer for Records.

AbstractMetricsReportingExecutionListener - Class in com.datastax.oss.dsbulk.executor.api.listener

An ExecutionListener that reports useful metrics about ongoing bulk read and write operations.

AbstractMetricsReportingExecutionListener(MetricsCollectingExecutionListener, String, MetricFilter, TimeUnit, TimeUnit) - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

AbstractMetricsReportingExecutionListener(MetricsCollectingExecutionListener, String, MetricFilter, TimeUnit, TimeUnit, ScheduledExecutorService) - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

AbstractMetricsReportingExecutionListenerBuilder<T extends AbstractMetricsReportingExecutionListener> - Class in com.datastax.oss.dsbulk.executor.api.listener

A builder for AbstractMetricsReportingExecutionListener.

accept(String, Object...) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.LogSink

Process the given message by (possibly) logging it.

AdaptiveSizingBatchPredicate() - Constructor for class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher.AdaptiveSizingBatchPredicate

addAttribute(String, Object) - Method in class com.datastax.oss.dsbulk.codecs.api.ConversionContext

AddressUtils - Class in com.datastax.oss.dsbulk.workflow.commons.utils

AddressUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.utils.AddressUtils

addSetting(String) - Method in interface com.datastax.oss.dsbulk.config.model.SettingsGroup

addStatementPrinters(StatementPrinter<?>...) - Method in class com.datastax.oss.dsbulk.format.statement.StatementFormatter.Builder

Adds the given StatementPrinters to the list of available statement printers.

ALLOW_EXTRA_FIELDS - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

ALLOW_MISSING_FIELDS - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

AnsiConfigurator - Class in com.datastax.oss.dsbulk.runner.cli

AnsiConfigurator() - Constructor for class com.datastax.oss.dsbulk.runner.cli.AnsiConfigurator

append(CharSequence) - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

append(CharSequence, int, int) - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

append(char) - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

append(Object) - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

append(String) - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

append(CharSequence) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

append(CharSequence, int, int) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

append(char) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

append(Object) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

append(String) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

appendBoundValue(int, Object, DataType) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

appendBoundValue(String, Object, DataType) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

appendClassNameAndHashCode(Row) - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

Appends the row's class name and hash code, as done by Object.toString().

appendClassNameAndHashCode(Statement<?>) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

Appends the statement's class name and hash code, as done by Object.toString().

appendQueryStringFragment(String) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

Appends the given fragment as a query string fragment.

appendRecord(MappedStatement, StatementWriter) - Method in interface com.datastax.oss.dsbulk.workflow.commons.format.statement.MappedStatementPrinter

appendUnsetBoundValue(String) - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

appendValue(String, Object, DataType) - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

apply(Number, ArithmeticException, Class<? extends Number>, RoundingMode) - Method in enum com.datastax.oss.dsbulk.codecs.api.util.OverflowStrategy

applyPerFileLimits(Flux<Record>) - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Applies per-file limits to a stream of records coming from AbstractFileBasedConnector.readSingleFile(java.net.URL).

asIdentifier() - Method in class com.datastax.oss.dsbulk.mapping.CQLWord

assertAccessibleFile(Path, String) - Static method in class com.datastax.oss.dsbulk.io.IOUtils

AsyncBulkExecutor - Interface in com.datastax.oss.dsbulk.executor.api

An execution unit for bulk writes and bulk reads that operates in asynchronous mode.

AsyncBulkReader - Interface in com.datastax.oss.dsbulk.executor.api.reader

An asynchronous execution unit for bulk read operations.

AsyncBulkWriter - Interface in com.datastax.oss.dsbulk.executor.api.writer

An asynchronous execution unit for bulk write operations.

AuthProviderFactory - Class in com.datastax.oss.dsbulk.workflow.commons.auth

AuthProviderFactory() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.auth.AuthProviderFactory

AuthProviderFactory.KeyTabConfiguration - Class in com.datastax.oss.dsbulk.workflow.commons.auth

AuthProviderFactory.TicketCacheConfiguration - Class in com.datastax.oss.dsbulk.workflow.commons.auth

B

BASE64_INSTANCE - Static variable in class com.datastax.oss.dsbulk.codecs.api.format.geo.WellKnownBinaryGeoFormat

Base64BinaryFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.binary

batchAll(Collection<BatchableStatement<?>>) - Method in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

batchAll(Publisher<BatchableStatement<?>>) - Method in interface com.datastax.oss.dsbulk.batcher.api.ReactiveStatementBatcher

Batches together all the given statements into groups of statements, regardless of their grouping key.

batchAll(BatchableStatement<?>...) - Method in interface com.datastax.oss.dsbulk.batcher.api.StatementBatcher

Batches together all the given statements into one or more BatchStatements, regardless of their grouping key.

batchAll(Collection<BatchableStatement<?>>) - Method in interface com.datastax.oss.dsbulk.batcher.api.StatementBatcher

Batches together all the given statements into one or more BatchStatements, regardless of their grouping key.

batchAll(Publisher<BatchableStatement<?>>) - Method in class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

batchByGroupingKey(Iterable<BatchableStatement<?>>) - Method in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

batchByGroupingKey(Publisher<BatchableStatement<?>>) - Method in interface com.datastax.oss.dsbulk.batcher.api.ReactiveStatementBatcher

Batches together the given statements into groups of statements having the same grouping key.

batchByGroupingKey(BatchableStatement<?>...) - Method in interface com.datastax.oss.dsbulk.batcher.api.StatementBatcher

Batches together the given statements into groups of statements having the same grouping key.

batchByGroupingKey(Iterable<BatchableStatement<?>>) - Method in interface com.datastax.oss.dsbulk.batcher.api.StatementBatcher

Batches together the given statements into groups of statements having the same grouping key.

batchByGroupingKey(Publisher<BatchableStatement<?>>) - Method in class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

BatchMode - Enum in com.datastax.oss.dsbulk.batcher.api

Available batch modes.

batchMode - Variable in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

BatchReporter - Class in com.datastax.oss.dsbulk.workflow.commons.metrics

BatchSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

BatchSettings(Config) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.BatchSettings

BatchStatementPrinter - Class in com.datastax.oss.dsbulk.format.statement

BatchStatementPrinter() - Constructor for class com.datastax.oss.dsbulk.format.statement.BatchStatementPrinter

batchType - Variable in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

BINARY_FORMAT - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

BinaryFormat - Interface in com.datastax.oss.dsbulk.codecs.api.format.binary

An utility for parsing and formatting binary data.

BOOLEAN_INPUT_WORDS - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

BOOLEAN_NUMBERS - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

BOOLEAN_OUTPUT_WORDS - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

BooleanConvertingCodecsProvider - Class in com.datastax.oss.dsbulk.codecs.jdk.bool

BooleanConvertingCodecsProvider() - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.bool.BooleanConvertingCodecsProvider

BooleanToNumberCodec<INTERNAL extends Number> - Class in com.datastax.oss.dsbulk.codecs.jdk.bool

BooleanToNumberCodec(TypeCodec<INTERNAL>, List<BigDecimal>) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.bool.BooleanToNumberCodec

BooleanToStringCodec - Class in com.datastax.oss.dsbulk.codecs.jdk.bool

BooleanToStringCodec() - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.bool.BooleanToStringCodec

BoundStatementPrinter - Class in com.datastax.oss.dsbulk.format.statement

BoundStatementPrinter() - Constructor for class com.datastax.oss.dsbulk.format.statement.BoundStatementPrinter

boundValuesCount - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

BROTLI_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

build() - Method in interface com.datastax.oss.dsbulk.executor.api.BulkExecutorBuilder

Builds a new instance.

build() - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListenerBuilder

Builds a new instance of AbstractMetricsReportingExecutionListener.

build() - Method in class com.datastax.oss.dsbulk.executor.reactor.ContinuousReactorBulkExecutorBuilder

build() - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutorBuilder

build() - Method in class com.datastax.oss.dsbulk.format.statement.StatementFormatter.Builder

Builds the StatementFormatter instance.

builder() - Static method in class com.datastax.oss.dsbulk.executor.api.listener.ReadsAndWritesReportingExecutionListener

Creates a new builder for this class.

builder() - Static method in class com.datastax.oss.dsbulk.executor.api.listener.ReadsReportingExecutionListener

Creates a new builder for this class.

builder() - Static method in class com.datastax.oss.dsbulk.executor.api.listener.StatementsReportingExecutionListener

Creates a new builder for this class.

builder() - Static method in class com.datastax.oss.dsbulk.executor.api.listener.WritesReportingExecutionListener

Creates a new builder for this class.

builder(CqlSession) - Static method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

Creates a new builder of DefaultReactorBulkExecutor instances.

builder() - Static method in class com.datastax.oss.dsbulk.format.statement.StatementFormatter

Creates a new StatementFormatter.Builder instance.

buildFrom(Supplier<Boolean>, BiConsumer<String, Object[]>) - Static method in interface com.datastax.oss.dsbulk.executor.api.listener.LogSink

Creates a new sink with the given enablement supplier and given message consumer.

BULK_LOADER_APPLICATION_NAME - Static variable in class com.datastax.oss.dsbulk.workflow.api.utils.WorkflowUtils

BULK_LOADER_NAMESPACE - Static variable in class com.datastax.oss.dsbulk.workflow.api.utils.WorkflowUtils

BulkDriverOption - Enum in com.datastax.oss.dsbulk.workflow.commons.settings

Driver options that are defined by DSBulk.

BulkExecutionException - Exception in com.datastax.oss.dsbulk.executor.api.exception

Thrown when a BulkExecutor fails to execute a Statement.

BulkExecutionException(Throwable, Statement<?>) - Constructor for exception com.datastax.oss.dsbulk.executor.api.exception.BulkExecutionException

BulkExecutor - Interface in com.datastax.oss.dsbulk.executor.api

An execution unit for bulk writes and bulk reads that operates in 3 distinct modes: synchronous (blocking), asynchronous (non-blocking), and reactive.

BulkExecutorBuilder<T extends BulkExecutor> - Interface in com.datastax.oss.dsbulk.executor.api

A builder for BulkExecutor instances.

BulkExecutorBuilderFactory - Interface in com.datastax.oss.dsbulk.executor.api

A factory for BulkExecutorBuilder instances.

BulkGssApiAuthProvider - Class in com.datastax.oss.dsbulk.workflow.commons.auth

BulkGssApiAuthProvider(DseGssApiAuthProviderBase.GssApiOptions) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.auth.BulkGssApiAuthProvider

BulkLoaderURLStreamHandlerFactory - Class in com.datastax.oss.dsbulk.url

The main factory for URL stream handlers used by DSBulk.

BulkReader - Interface in com.datastax.oss.dsbulk.executor.api.reader

A bulk reader that operates in 3 distinct modes: Synchronous; Asynchronous; Reactive.

BulkTokenFactory - Interface in com.datastax.oss.dsbulk.partitioner

BulkTokenRange - Interface in com.datastax.oss.dsbulk.partitioner

BulkWriter - Interface in com.datastax.oss.dsbulk.executor.api.writer

A bulk writer that operates in 3 distinct modes: Synchronous; Asynchronous; Reactive.

BYTES_PER_KB - Static variable in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

BYTES_PER_MB - Static variable in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

BZIP2_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

C

cancel() - Method in class com.datastax.oss.dsbulk.executor.api.subscription.ContinuousReadResultSubscription

cancel() - Method in class com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription

checkContinuousPaging(CqlSession, boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ExecutorSettings

checkGraphCompatibility(Session) - Static method in class com.datastax.oss.dsbulk.workflow.commons.utils.GraphUtils

checkThresholdExceeded(long, Number) - Method in class com.datastax.oss.dsbulk.workflow.api.error.AbsoluteErrorThreshold

checkThresholdExceeded(long, Number) - Method in interface com.datastax.oss.dsbulk.workflow.api.error.ErrorThreshold

Checks whether the error threshold was exceeded.

checkThresholdExceeded(long, Number) - Method in class com.datastax.oss.dsbulk.workflow.api.error.RatioErrorThreshold

checkThresholdExceeded(long, Number) - Method in class com.datastax.oss.dsbulk.workflow.api.error.UnlimitedErrorThreshold

CleanupThread - Class in com.datastax.oss.dsbulk.runner

A shutdown hook responsible for interrupting the workflow thread in the event of a user interruption via SIGINT (CTLR + C), and for closing the workflow.

CleanupThread(Workflow, WorkflowThread) - Constructor for class com.datastax.oss.dsbulk.runner.CleanupThread

clear() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultErrorRecord

clear() - Method in interface com.datastax.oss.dsbulk.connectors.api.Record

Clear all fields in this record.

clientId(String) - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.WorkflowUtils

close() - Method in interface com.datastax.oss.dsbulk.connectors.api.Connector

Closes the connector.

close() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

close() - Method in interface com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector.RecordReader

Closes the underlying file being read.

close() - Method in interface com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector.RecordWriter

Closes the underlying file being written.

close() - Method in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

close() - Method in class com.datastax.oss.dsbulk.url.UncloseableInputStream

close() - Method in class com.datastax.oss.dsbulk.url.UncloseableOutputStream

close() - Method in interface com.datastax.oss.dsbulk.workflow.api.Workflow

Closes the workflow and releases all open resources (file descriptors, socket connections, etc.).

close() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

close() - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

close() - Method in class com.datastax.oss.dsbulk.workflow.commons.policies.retry.MultipleRetryPolicy

close() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.DefaultReadResultCounter

close() - Method in class com.datastax.oss.dsbulk.workflow.commons.ssl.NettySslHandlerFactory

close() - Method in class com.datastax.oss.dsbulk.workflow.count.CountWorkflow

close() - Method in class com.datastax.oss.dsbulk.workflow.load.LoadWorkflow

close() - Method in class com.datastax.oss.dsbulk.workflow.unload.UnloadWorkflow

CloseableUtils - Class in com.datastax.oss.dsbulk.workflow.commons.utils

CloseableUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.utils.CloseableUtils

closeQuietly(AutoCloseable, Exception) - Static method in class com.datastax.oss.dsbulk.workflow.commons.utils.CloseableUtils

closeQuietly(Disposable, Exception) - Static method in class com.datastax.oss.dsbulk.workflow.commons.utils.CloseableUtils

clusterer() - Method in interface com.datastax.oss.dsbulk.partitioner.BulkTokenFactory

Returns a TokenRangeClusterer for the type of tokens managed by this token factory.

clusterer() - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenFactory

clusterer() - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenFactory

ClusterInformationUtils - Class in com.datastax.oss.dsbulk.workflow.commons.utils

ClusterInformationUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.utils.ClusterInformationUtils

codec(CQLWord, DataType, GenericType<? extends T>) - Method in class com.datastax.oss.dsbulk.mapping.DefaultMapping

codec(CQLWord, DataType, GenericType<? extends T>) - Method in interface com.datastax.oss.dsbulk.mapping.Mapping

Returns the codec to use for the given bound statement or row variable.

codecRegistry - Variable in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

codecRegistry() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

CodecSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

CodecSettings(Config) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.CodecSettings

CodecUtils - Class in com.datastax.oss.dsbulk.codecs.api.util

CodecUtils() - Constructor for class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

CollectionConvertingCodecsProvider - Class in com.datastax.oss.dsbulk.codecs.jdk.collection

CollectionConvertingCodecsProvider() - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.collection.CollectionConvertingCodecsProvider

CollectionToCollectionCodec<EXTERNAL extends Collection<Object>,INTERNAL extends Collection<Object>> - Class in com.datastax.oss.dsbulk.codecs.jdk.collection

CollectionToCollectionCodec(Class<EXTERNAL>, TypeCodec<INTERNAL>, ConvertingCodec<Object, Object>, Supplier<INTERNAL>) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.collection.CollectionToCollectionCodec

collectStatementProperties(BoundStatement, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.BoundStatementPrinter

collectStatementProperties(SimpleStatement, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.SimpleStatementPrinter

collectStatementProperties(S, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.StatementPrinterBase

com.datastax.oss.dsbulk.batcher.api - package com.datastax.oss.dsbulk.batcher.api

com.datastax.oss.dsbulk.batcher.reactor - package com.datastax.oss.dsbulk.batcher.reactor

com.datastax.oss.dsbulk.codecs.api - package com.datastax.oss.dsbulk.codecs.api

com.datastax.oss.dsbulk.codecs.api.format.binary - package com.datastax.oss.dsbulk.codecs.api.format.binary

com.datastax.oss.dsbulk.codecs.api.format.geo - package com.datastax.oss.dsbulk.codecs.api.format.geo

com.datastax.oss.dsbulk.codecs.api.format.number - package com.datastax.oss.dsbulk.codecs.api.format.number

com.datastax.oss.dsbulk.codecs.api.format.temporal - package com.datastax.oss.dsbulk.codecs.api.format.temporal

com.datastax.oss.dsbulk.codecs.api.util - package com.datastax.oss.dsbulk.codecs.api.util

com.datastax.oss.dsbulk.codecs.api.writetime - package com.datastax.oss.dsbulk.codecs.api.writetime

com.datastax.oss.dsbulk.codecs.jdk - package com.datastax.oss.dsbulk.codecs.jdk

com.datastax.oss.dsbulk.codecs.jdk.bool - package com.datastax.oss.dsbulk.codecs.jdk.bool

com.datastax.oss.dsbulk.codecs.jdk.collection - package com.datastax.oss.dsbulk.codecs.jdk.collection

com.datastax.oss.dsbulk.codecs.jdk.map - package com.datastax.oss.dsbulk.codecs.jdk.map

com.datastax.oss.dsbulk.codecs.jdk.number - package com.datastax.oss.dsbulk.codecs.jdk.number

com.datastax.oss.dsbulk.codecs.jdk.temporal - package com.datastax.oss.dsbulk.codecs.jdk.temporal

com.datastax.oss.dsbulk.codecs.text - package com.datastax.oss.dsbulk.codecs.text

com.datastax.oss.dsbulk.codecs.text.json - package com.datastax.oss.dsbulk.codecs.text.json

com.datastax.oss.dsbulk.codecs.text.json.dse - package com.datastax.oss.dsbulk.codecs.text.json.dse

com.datastax.oss.dsbulk.codecs.text.string - package com.datastax.oss.dsbulk.codecs.text.string

com.datastax.oss.dsbulk.codecs.text.string.dse - package com.datastax.oss.dsbulk.codecs.text.string.dse

com.datastax.oss.dsbulk.codecs.text.utils - package com.datastax.oss.dsbulk.codecs.text.utils

com.datastax.oss.dsbulk.config - package com.datastax.oss.dsbulk.config

com.datastax.oss.dsbulk.config.model - package com.datastax.oss.dsbulk.config.model

com.datastax.oss.dsbulk.config.shortcuts - package com.datastax.oss.dsbulk.config.shortcuts

com.datastax.oss.dsbulk.connectors.api - package com.datastax.oss.dsbulk.connectors.api

com.datastax.oss.dsbulk.connectors.commons - package com.datastax.oss.dsbulk.connectors.commons

com.datastax.oss.dsbulk.connectors.csv - package com.datastax.oss.dsbulk.connectors.csv

com.datastax.oss.dsbulk.connectors.json - package com.datastax.oss.dsbulk.connectors.json

com.datastax.oss.dsbulk.docs.utils - package com.datastax.oss.dsbulk.docs.utils

com.datastax.oss.dsbulk.executor.api - package com.datastax.oss.dsbulk.executor.api

com.datastax.oss.dsbulk.executor.api.exception - package com.datastax.oss.dsbulk.executor.api.exception

com.datastax.oss.dsbulk.executor.api.histogram - package com.datastax.oss.dsbulk.executor.api.histogram

com.datastax.oss.dsbulk.executor.api.listener - package com.datastax.oss.dsbulk.executor.api.listener

com.datastax.oss.dsbulk.executor.api.publisher - package com.datastax.oss.dsbulk.executor.api.publisher

com.datastax.oss.dsbulk.executor.api.reader - package com.datastax.oss.dsbulk.executor.api.reader

com.datastax.oss.dsbulk.executor.api.result - package com.datastax.oss.dsbulk.executor.api.result

com.datastax.oss.dsbulk.executor.api.subscription - package com.datastax.oss.dsbulk.executor.api.subscription

com.datastax.oss.dsbulk.executor.api.writer - package com.datastax.oss.dsbulk.executor.api.writer

com.datastax.oss.dsbulk.executor.reactor - package com.datastax.oss.dsbulk.executor.reactor

com.datastax.oss.dsbulk.executor.reactor.reader - package com.datastax.oss.dsbulk.executor.reactor.reader

com.datastax.oss.dsbulk.executor.reactor.writer - package com.datastax.oss.dsbulk.executor.reactor.writer

com.datastax.oss.dsbulk.format.row - package com.datastax.oss.dsbulk.format.row

com.datastax.oss.dsbulk.format.statement - package com.datastax.oss.dsbulk.format.statement

com.datastax.oss.dsbulk.io - package com.datastax.oss.dsbulk.io

com.datastax.oss.dsbulk.mapping - package com.datastax.oss.dsbulk.mapping

com.datastax.oss.dsbulk.partitioner - package com.datastax.oss.dsbulk.partitioner

com.datastax.oss.dsbulk.partitioner.murmur3 - package com.datastax.oss.dsbulk.partitioner.murmur3

com.datastax.oss.dsbulk.partitioner.random - package com.datastax.oss.dsbulk.partitioner.random

com.datastax.oss.dsbulk.partitioner.utils - package com.datastax.oss.dsbulk.partitioner.utils

com.datastax.oss.dsbulk.runner - package com.datastax.oss.dsbulk.runner

com.datastax.oss.dsbulk.runner.cli - package com.datastax.oss.dsbulk.runner.cli

com.datastax.oss.dsbulk.runner.help - package com.datastax.oss.dsbulk.runner.help

com.datastax.oss.dsbulk.runner.utils - package com.datastax.oss.dsbulk.runner.utils

com.datastax.oss.dsbulk.sampler - package com.datastax.oss.dsbulk.sampler

com.datastax.oss.dsbulk.url - package com.datastax.oss.dsbulk.url

com.datastax.oss.dsbulk.workflow.api - package com.datastax.oss.dsbulk.workflow.api

com.datastax.oss.dsbulk.workflow.api.config - package com.datastax.oss.dsbulk.workflow.api.config

com.datastax.oss.dsbulk.workflow.api.error - package com.datastax.oss.dsbulk.workflow.api.error

com.datastax.oss.dsbulk.workflow.api.log - package com.datastax.oss.dsbulk.workflow.api.log

com.datastax.oss.dsbulk.workflow.api.utils - package com.datastax.oss.dsbulk.workflow.api.utils

com.datastax.oss.dsbulk.workflow.commons.auth - package com.datastax.oss.dsbulk.workflow.commons.auth

com.datastax.oss.dsbulk.workflow.commons.format.statement - package com.datastax.oss.dsbulk.workflow.commons.format.statement

com.datastax.oss.dsbulk.workflow.commons.log - package com.datastax.oss.dsbulk.workflow.commons.log

com.datastax.oss.dsbulk.workflow.commons.metrics - package com.datastax.oss.dsbulk.workflow.commons.metrics

com.datastax.oss.dsbulk.workflow.commons.policies.lbp - package com.datastax.oss.dsbulk.workflow.commons.policies.lbp

com.datastax.oss.dsbulk.workflow.commons.policies.retry - package com.datastax.oss.dsbulk.workflow.commons.policies.retry

com.datastax.oss.dsbulk.workflow.commons.schema - package com.datastax.oss.dsbulk.workflow.commons.schema

com.datastax.oss.dsbulk.workflow.commons.settings - package com.datastax.oss.dsbulk.workflow.commons.settings

com.datastax.oss.dsbulk.workflow.commons.ssl - package com.datastax.oss.dsbulk.workflow.commons.ssl

com.datastax.oss.dsbulk.workflow.commons.statement - package com.datastax.oss.dsbulk.workflow.commons.statement

com.datastax.oss.dsbulk.workflow.commons.utils - package com.datastax.oss.dsbulk.workflow.commons.utils

com.datastax.oss.dsbulk.workflow.count - package com.datastax.oss.dsbulk.workflow.count

com.datastax.oss.dsbulk.workflow.load - package com.datastax.oss.dsbulk.workflow.load

com.datastax.oss.dsbulk.workflow.unload - package com.datastax.oss.dsbulk.workflow.unload

CommandLineParser - Class in com.datastax.oss.dsbulk.runner.cli

CommandLineParser(String...) - Constructor for class com.datastax.oss.dsbulk.runner.cli.CommandLineParser

CommonConnectorFeature - Enum in com.datastax.oss.dsbulk.connectors.api

CommonConversionContext - Class in com.datastax.oss.dsbulk.codecs.api

A collection of most common conversion context attributes used in DSBulk and other projects.

CommonConversionContext() - Constructor for class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

compare(Node, Node) - Method in class com.datastax.oss.dsbulk.workflow.commons.utils.NodeComparator

CompositeExecutionListener - Class in com.datastax.oss.dsbulk.executor.api.listener

A composite ExecutionListener that forwards all received calls to its child listeners.

CompositeExecutionListener(ExecutionListener...) - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

CompositeExecutionListener(Iterable<ExecutionListener>) - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

CompressedIOUtils - Class in com.datastax.oss.dsbulk.io

CompressedIOUtils() - Constructor for class com.datastax.oss.dsbulk.io.CompressedIOUtils

COMPRESSION - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

compression - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

computeSizeInBytes(DriverContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

CONFIG_FILE_OPTION - Static variable in class com.datastax.oss.dsbulk.runner.help.HelpEntryFactory

ConfigPostProcessor - Interface in com.datastax.oss.dsbulk.workflow.api.config

A post-processor for Config objects.

configure(Config, boolean, boolean) - Method in interface com.datastax.oss.dsbulk.connectors.api.Connector

Configures the connector.

configure(Config, boolean, boolean) - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

configure(Config, boolean, boolean) - Method in class com.datastax.oss.dsbulk.connectors.csv.CSVConnector

configure(Config, boolean, boolean) - Method in class com.datastax.oss.dsbulk.connectors.json.JsonConnector

configureAnsi(String...) - Static method in class com.datastax.oss.dsbulk.runner.cli.AnsiConfigurator

ConfigUtils - Class in com.datastax.oss.dsbulk.config

ConfigUtils() - Constructor for class com.datastax.oss.dsbulk.config.ConfigUtils

Connector - Interface in com.datastax.oss.dsbulk.connectors.api

A Connector is a component capable of reading from and writing to a datasource.

ConnectorFeature - Interface in com.datastax.oss.dsbulk.connectors.api

A marker interface for connector features.

ConnectorSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

ConnectorSettings(Config, boolean) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.ConnectorSettings

consistencyLevel - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

ConsoleReporter - Class in com.datastax.oss.dsbulk.workflow.commons.metrics

An ScheduledReporter that reports useful metrics about ongoing operations to the standard error channel, using ANSI escape codes.

ConsoleUtils - Class in com.datastax.oss.dsbulk.workflow.api.utils

ConsoleUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.api.utils.ConsoleUtils

contains(long) - Method in class com.datastax.oss.dsbulk.workflow.commons.log.Range

continuousPagingAvailable(CqlSession) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ExecutorSettings

continuousPagingBuilder(CqlSession) - Static method in class com.datastax.oss.dsbulk.executor.reactor.ContinuousReactorBulkExecutor

Creates a new builder for ContinuousReactorBulkExecutor instances using the given CqlSession.

ContinuousReactorBulkExecutor - Class in com.datastax.oss.dsbulk.executor.reactor

An implementation of BulkExecutor using Reactor, that executes all reads using continuous paging.

ContinuousReactorBulkExecutor(CqlSession) - Constructor for class com.datastax.oss.dsbulk.executor.reactor.ContinuousReactorBulkExecutor

Creates a new instance using the given CqlSession and using defaults for all parameters.

ContinuousReactorBulkExecutorBuilder - Class in com.datastax.oss.dsbulk.executor.reactor

A builder for ContinuousReactorBulkExecutor instances.

ContinuousReadResultPublisher - Class in com.datastax.oss.dsbulk.executor.api.publisher

A Publisher for ReadResults that uses continuous paging.

ContinuousReadResultPublisher(Statement<?>, ContinuousSession, boolean) - Constructor for class com.datastax.oss.dsbulk.executor.api.publisher.ContinuousReadResultPublisher

Creates a new ContinuousReadResultPublisher with default paging options, without ExecutionListener and without throughput regulation.

ContinuousReadResultPublisher(Statement<?>, ContinuousSession, boolean, ExecutionListener, Semaphore, RateLimiter) - Constructor for class com.datastax.oss.dsbulk.executor.api.publisher.ContinuousReadResultPublisher

Creates a new ContinuousReadResultPublisher.

ContinuousReadResultSubscription - Class in com.datastax.oss.dsbulk.executor.api.subscription

ContinuousReadResultSubscription(Subscriber<? super ReadResult>, Statement<?>, ExecutionListener, Semaphore, RateLimiter, boolean) - Constructor for class com.datastax.oss.dsbulk.executor.api.subscription.ContinuousReadResultSubscription

ConversionContext - Class in com.datastax.oss.dsbulk.codecs.api

ConversionContext() - Constructor for class com.datastax.oss.dsbulk.codecs.api.ConversionContext

convert(ILoggingEvent) - Method in class com.datastax.oss.dsbulk.workflow.commons.log.HighlightingMessageConverter

convertConfigException(ConfigException, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Creates a IllegalArgumentException from a ConfigException, sanitizing the error message for better user experience.

convertDurationsTo(TimeUnit) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListenerBuilder

Convert durations to the given time unit.

ConvertingCodec<EXTERNAL,INTERNAL> - Class in com.datastax.oss.dsbulk.codecs.api

A codec that converts to and from an external representation of a value (i.e., the value, as produced by a connector) and its internal representation (i.e., the Java type that matches the target CQL type).

ConvertingCodec(TypeCodec<INTERNAL>, Class<EXTERNAL>) - Constructor for class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

ConvertingCodec(TypeCodec<INTERNAL>, GenericType<EXTERNAL>) - Constructor for class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

ConvertingCodecFactory - Class in com.datastax.oss.dsbulk.codecs.api

A factory for ConvertingCodecs.

ConvertingCodecFactory() - Constructor for class com.datastax.oss.dsbulk.codecs.api.ConvertingCodecFactory

ConvertingCodecFactory(ConversionContext) - Constructor for class com.datastax.oss.dsbulk.codecs.api.ConvertingCodecFactory

ConvertingCodecFactory(MutableCodecRegistry, ConversionContext) - Constructor for class com.datastax.oss.dsbulk.codecs.api.ConvertingCodecFactory

ConvertingCodecProvider - Interface in com.datastax.oss.dsbulk.codecs.api

A provider for ConvertingCodecs.

convertNumber(Number, Class<? extends N>) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number to the given class, applying loss-less conversions.

convertRatesTo(TimeUnit) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListenerBuilder

Convert rates to the given time unit.

convertTemporal(TemporalAccessor, Class<? extends T>, ZoneId, LocalDate) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given temporal into a temporal of the target class.

countReadableFiles(Path, boolean) - Static method in class com.datastax.oss.dsbulk.io.IOUtils

CountWorkflow - Class in com.datastax.oss.dsbulk.workflow.count

The main class for count workflows.

CountWorkflowProvider - Class in com.datastax.oss.dsbulk.workflow.count

CountWorkflowProvider() - Constructor for class com.datastax.oss.dsbulk.workflow.count.CountWorkflowProvider

CQLFragment - Interface in com.datastax.oss.dsbulk.mapping

A fragment of CQL language included in a mapping definition or in a CQL query.

CQLLiteral - Class in com.datastax.oss.dsbulk.mapping

A CQL literal, such as an integer, float, UUID, hex number, boolean, or string literal.

CQLLiteral(String) - Constructor for class com.datastax.oss.dsbulk.mapping.CQLLiteral

CQLRenderMode - Enum in com.datastax.oss.dsbulk.mapping

CqlTemporalFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.temporal

A special zoned temporal format that recognizes all valid CQL input formats when parsing.

CqlTemporalFormat(ZoneId) - Constructor for class com.datastax.oss.dsbulk.codecs.api.format.temporal.CqlTemporalFormat

CQLWord - Class in com.datastax.oss.dsbulk.mapping

A CQL identifier (keyspace, table, column, named bound variable, etc).

create() - Method in interface com.datastax.oss.dsbulk.batcher.api.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.

create(int) - Method in interface com.datastax.oss.dsbulk.batcher.api.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).

create(long) - Method in interface com.datastax.oss.dsbulk.batcher.api.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).

create(int, long) - Method in interface com.datastax.oss.dsbulk.batcher.api.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.

create(CqlSession) - Method in interface com.datastax.oss.dsbulk.batcher.api.ReactiveStatementBatcherFactory

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.

create(CqlSession, BatchMode) - Method in interface com.datastax.oss.dsbulk.batcher.api.ReactiveStatementBatcherFactory

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.

create(CqlSession, BatchMode, BatchType, int) - Method in interface com.datastax.oss.dsbulk.batcher.api.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.

create(CqlSession, BatchMode, BatchType, int, long) - Method in interface com.datastax.oss.dsbulk.batcher.api.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.

create() - Method in class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcherFactory

create(int) - Method in class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcherFactory

create(long) - Method in class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcherFactory

create(int, long) - Method in class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcherFactory

create(CqlSession, BatchMode, BatchType, int, long) - Method in class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcherFactory

create(CqlSession, boolean) - Method in interface com.datastax.oss.dsbulk.executor.api.BulkExecutorBuilderFactory

Creates a new BulkExecutorBuilder for the given session.

create(CqlSession, boolean) - Method in class com.datastax.oss.dsbulk.executor.reactor.ReactorBulkExecutorBuilderFactory

createApplicationConfig(Path) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Creates an unresolved application config for DSBulk, optionally pulling application settings from the given alternate location.

createAuthProvider(Config) - Static method in class com.datastax.oss.dsbulk.workflow.commons.auth.AuthProviderFactory

createChildWriter() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

Creates and returns a child StatementWriter.

createCodecFactory(boolean, boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.CodecSettings

createConvertingCodec(DataType, GenericType<EXTERNAL>, boolean) - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodecFactory

createDSBulkConfigurationGroups(boolean) - Static method in class com.datastax.oss.dsbulk.config.model.SettingsGroupFactory

Creates the configuration sections for DSBulk.

createMainLogFileAppender(Path) - Static method in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

createReadResultCounter(CqlSession, ConvertingCodecFactory, EnumSet<StatsSettings.StatisticsMode>, int) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

createReadResultMapper(CqlSession, RecordMetadata, ConvertingCodecFactory, boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

Creates a new ReadResultMapper.

createReadStatements(CqlSession) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

createRecordMapper(CqlSession, RecordMetadata, ConvertingCodecFactory) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

createReferenceConfig() - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Creates an unresolved reference config for DSBulk.

createShortcutsMap() - Static method in class com.datastax.oss.dsbulk.config.shortcuts.ShortcutsFactory

Creates a BiMap where keys are shortcuts and values are settings, using the default reference config and not favoring any particular connector.

createShortcutsMap(Config, String) - Static method in class com.datastax.oss.dsbulk.config.shortcuts.ShortcutsFactory

Creates a BiMap where keys are shortcuts and values are settings.

createSslHandlerFactory(Config) - Static method in class com.datastax.oss.dsbulk.workflow.commons.ssl.SslHandlerFactoryFactory

createURLStreamHandler(String) - Method in class com.datastax.oss.dsbulk.url.BulkLoaderURLStreamHandlerFactory

CSVConnector - Class in com.datastax.oss.dsbulk.connectors.csv

A connector for CSV files.

CSVConnector() - Constructor for class com.datastax.oss.dsbulk.connectors.csv.CSVConnector

D

DataSizes - Class in com.datastax.oss.dsbulk.sampler

DataSizes() - Constructor for class com.datastax.oss.dsbulk.sampler.DataSizes

DataSizeSampler - Class in com.datastax.oss.dsbulk.sampler

DataSizeSampler() - Constructor for class com.datastax.oss.dsbulk.sampler.DataSizeSampler

DataStaxBulkLoader - Class in com.datastax.oss.dsbulk.runner

The main entry point for command line invocations of DSBulk.

DataStaxBulkLoader(String...) - Constructor for class com.datastax.oss.dsbulk.runner.DataStaxBulkLoader

DATE_PATTERN - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

DateToTemporalCodec<EXTERNAL extends Date,INTERNAL extends TemporalAccessor> - Class in com.datastax.oss.dsbulk.codecs.jdk.temporal

DateToTemporalCodec(Class<EXTERNAL>, TypeCodec<INTERNAL>, ZoneId) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.temporal.DateToTemporalCodec

DateToUUIDCodec<EXTERNAL extends Date> - Class in com.datastax.oss.dsbulk.codecs.jdk.temporal

DateToUUIDCodec(TypeCodec<UUID>, DateToTemporalCodec<EXTERNAL, Instant>, TimeUUIDGenerator) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.temporal.DateToUUIDCodec

decode(ByteBuffer, ProtocolVersion) - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

DEFAULT_INSTANCE - Static variable in class com.datastax.oss.dsbulk.codecs.api.format.temporal.CqlTemporalFormat

DEFAULT_MAX_BATCH_STATEMENTS - Static variable in interface com.datastax.oss.dsbulk.batcher.api.ReactiveStatementBatcherFactory

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

DEFAULT_MAX_SIZE_BYTES - Static variable in interface com.datastax.oss.dsbulk.batcher.api.ReactiveStatementBatcherFactory

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

DEFAULT_MAX_VALUE_LENGTH - Static variable in class com.datastax.oss.dsbulk.format.row.RowFormatter

DEFAULT_MAX_VALUES - Static variable in class com.datastax.oss.dsbulk.format.row.RowFormatter

DefaultErrorRecord - Class in com.datastax.oss.dsbulk.connectors.api

A record that could not be fully parsed from its source.

DefaultErrorRecord(Object, URI, long, Throwable) - Constructor for class com.datastax.oss.dsbulk.connectors.api.DefaultErrorRecord

Creates a new error record.

DefaultExecutionContext - Class in com.datastax.oss.dsbulk.executor.api.listener

DefaultExecutionContext() - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.DefaultExecutionContext

DefaultIndexedField - Class in com.datastax.oss.dsbulk.connectors.api

DefaultIndexedField(int) - Constructor for class com.datastax.oss.dsbulk.connectors.api.DefaultIndexedField

DefaultMappedField - Class in com.datastax.oss.dsbulk.connectors.api

DefaultMappedField(String) - Constructor for class com.datastax.oss.dsbulk.connectors.api.DefaultMappedField

DefaultMapping - Class in com.datastax.oss.dsbulk.mapping

DefaultMapping(ImmutableSetMultimap<Field, CQLWord>, ConvertingCodecFactory, ImmutableSet<CQLWord>) - Constructor for class com.datastax.oss.dsbulk.mapping.DefaultMapping

DefaultReactorBulkExecutor - Class in com.datastax.oss.dsbulk.executor.reactor

An implementation of BulkExecutor using Reactor.

DefaultReactorBulkExecutor(CqlSession) - Constructor for class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

Creates a new instance using the given CqlSession and using defaults for all parameters.

DefaultReactorBulkExecutorBuilder - Class in com.datastax.oss.dsbulk.executor.reactor

A builder for DefaultReactorBulkExecutor instances.

DefaultReadResult - Class in com.datastax.oss.dsbulk.executor.api.result

DefaultReadResult(Statement<?>, ExecutionInfo, Row) - Constructor for class com.datastax.oss.dsbulk.executor.api.result.DefaultReadResult

DefaultReadResult(BulkExecutionException) - Constructor for class com.datastax.oss.dsbulk.executor.api.result.DefaultReadResult

DefaultReadResultCounter - Class in com.datastax.oss.dsbulk.workflow.commons.schema

DefaultReadResultCounter(CqlIdentifier, Metadata, EnumSet<StatsSettings.StatisticsMode>, int, ProtocolVersion, ConvertingCodecFactory) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.schema.DefaultReadResultCounter

DefaultReadResultMapper - Class in com.datastax.oss.dsbulk.workflow.commons.schema

DefaultReadResultMapper(Mapping, RecordMetadata, URI, boolean) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.schema.DefaultReadResultMapper

DefaultRecord - Class in com.datastax.oss.dsbulk.connectors.api

DefaultRecord(Object, URI, long) - Constructor for class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

Creates an empty record.

DefaultRecordMapper - Class in com.datastax.oss.dsbulk.workflow.commons.schema

DefaultRecordMapper(PreparedStatement, Set<CQLWord>, Set<CQLWord>, ProtocolVersion, Mapping, RecordMetadata, boolean, boolean, boolean) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.schema.DefaultRecordMapper

DefaultStatementBatcher - Class in com.datastax.oss.dsbulk.batcher.api

DefaultStatementBatcher() - Constructor for class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

Creates a new DefaultStatementBatcher that produces unlogged batches, operates in partition key mode and uses the default maximum number of statements (100) and the default maximum data size in bytes (unlimited).

DefaultStatementBatcher(int) - Constructor for class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

Creates a new DefaultStatementBatcher that produces unlogged batches, operates in partition key mode and uses the default maximum data size in bytes (unlimited).

DefaultStatementBatcher(long) - Constructor for class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

Creates a new DefaultStatementBatcher that produces unlogged batches, operates in partition key mode and uses the default maximum number of statements (100).

DefaultStatementBatcher(int, long) - Constructor for class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

Creates a new DefaultStatementBatcher that produces unlogged batches, operates in partition key mode and uses the given maximum number of statements and the maximum data size in bytes.

DefaultStatementBatcher(CqlSession) - Constructor for class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

Creates a new DefaultStatementBatcher that produces unlogged batches, operates in partition key mode and uses the default maximum number of statements (100) and the default maximum data size in bytes (unlimited).

DefaultStatementBatcher(CqlSession, BatchMode) - Constructor for class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

Creates a new DefaultStatementBatcher 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.

DefaultStatementBatcher(CqlSession, BatchMode, BatchType, int) - Constructor for class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

Creates a new DefaultStatementBatcher 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.

DefaultStatementBatcher(CqlSession, BatchMode, BatchType, int, long) - Constructor for class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

Creates a new DefaultStatementBatcher 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.

DefaultStatementBatcher.AdaptiveSizingBatchPredicate - Class in com.datastax.oss.dsbulk.batcher.api

DefaultStatementPrinter - Class in com.datastax.oss.dsbulk.format.statement

DefaultStatementPrinter() - Constructor for class com.datastax.oss.dsbulk.format.statement.DefaultStatementPrinter

DefaultWriteResult - Class in com.datastax.oss.dsbulk.executor.api.result

DefaultWriteResult(Statement<?>, AsyncResultSet) - Constructor for class com.datastax.oss.dsbulk.executor.api.result.DefaultWriteResult

DefaultWriteResult(BulkExecutionException) - Constructor for class com.datastax.oss.dsbulk.executor.api.result.DefaultWriteResult

DEFLATE64_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

DEFLATE_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

doOnError(Throwable) - Method in class com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription

DriverSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

DriverSettings(Config, Config, Config) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.DriverSettings

DurationUtils - Class in com.datastax.oss.dsbulk.workflow.api.utils

DurationUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.api.utils.DurationUtils

E

elapsedTimeNanos() - Method in class com.datastax.oss.dsbulk.executor.api.listener.DefaultExecutionContext

elapsedTimeNanos() - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionContext

Returns the elapsed time, in nanoseconds, between start and end of execution.

emitGlobalHelp(String) - Static method in class com.datastax.oss.dsbulk.runner.help.HelpEmitter

emitSectionHelp(String, String) - Static method in class com.datastax.oss.dsbulk.runner.help.HelpEmitter

emptyPrimaryKey(CQLWord) - Static method in exception com.datastax.oss.dsbulk.workflow.commons.schema.InvalidMappingException

EmptyWriteResult - Class in com.datastax.oss.dsbulk.executor.api.result

EmptyWriteResult(Statement<?>) - Constructor for class com.datastax.oss.dsbulk.executor.api.result.EmptyWriteResult

encode(EXTERNAL, ProtocolVersion) - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

encodeFailed(Field, CQLWord, GenericType<?>, DataType, Object, Exception) - Static method in exception com.datastax.oss.dsbulk.workflow.commons.schema.InvalidMappingException

ENCODING - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

encoding - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

EngineSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

ensureBraces(String) - Static method in class com.datastax.oss.dsbulk.codecs.text.utils.StringUtils

If the given string is surrounded by curly braces, return it intact, otherwise trim it and surround it with curly braces.

ensureBraces(String) - Static method in class com.datastax.oss.dsbulk.runner.utils.StringUtils

If the given string is surrounded by curly braces, return it intact, otherwise trim it and surround it with curly braces.

ensureBrackets(String) - Static method in class com.datastax.oss.dsbulk.codecs.text.utils.StringUtils

If the given string is surrounded by square brackets, return it intact, otherwise trim it and surround it with square brackets.

ensureBrackets(String) - Static method in class com.datastax.oss.dsbulk.runner.utils.StringUtils

If the given string is surrounded by square brackets, return it intact, otherwise trim it and surround it with square brackets.

ensureQuoted(String) - Static method in class com.datastax.oss.dsbulk.runner.utils.StringUtils

If the given string is surrounded by double-quotes, return it intact, otherwise trim it and surround it with double-quotes.

EPOCH - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

EPOCH_OFFSET - Static variable in enum com.datastax.oss.dsbulk.codecs.api.util.TimeUUIDGenerator

The timestamp is a 60-bit value.

equals(Object) - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultIndexedField

equals(Object) - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultMappedField

equals(Object) - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

equals(Object) - Method in class com.datastax.oss.dsbulk.executor.api.result.DefaultReadResult

equals(Object) - Method in class com.datastax.oss.dsbulk.mapping.CQLLiteral

equals(Object) - Method in class com.datastax.oss.dsbulk.mapping.CQLWord

equals(Object) - Method in class com.datastax.oss.dsbulk.mapping.FunctionCall

equals(Object) - Method in class com.datastax.oss.dsbulk.workflow.commons.log.Range

ErrorHandler - Class in com.datastax.oss.dsbulk.runner

ErrorHandler() - Constructor for class com.datastax.oss.dsbulk.runner.ErrorHandler

ErrorRecord - Interface in com.datastax.oss.dsbulk.connectors.api

A Record that could not be properly processed.

ErrorThreshold - Interface in com.datastax.oss.dsbulk.workflow.api.error

ExactNumberFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.number

A NumberFormat that converts floats and doubles to BigDecimal before formatting.

ExactNumberFormat(NumberFormat) - Constructor for class com.datastax.oss.dsbulk.codecs.api.format.number.ExactNumberFormat

execute() - Method in interface com.datastax.oss.dsbulk.workflow.api.Workflow

Executes the workflow.

execute() - Method in class com.datastax.oss.dsbulk.workflow.count.CountWorkflow

execute() - Method in class com.datastax.oss.dsbulk.workflow.load.LoadWorkflow

execute() - Method in class com.datastax.oss.dsbulk.workflow.unload.UnloadWorkflow

ExecutionContext - Interface in com.datastax.oss.dsbulk.executor.api.listener

The context of a statement or request execution.

ExecutionListener - Interface in com.datastax.oss.dsbulk.executor.api.listener

A listener for bulk executions.

ExecutorSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

exitCode() - Method in enum com.datastax.oss.dsbulk.runner.ExitStatus

ExitStatus - Enum in com.datastax.oss.dsbulk.runner

expectingTotalEvents(long) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListenerBuilder

The total number of expected events.

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

Converts the external representation of a value (i.e., the value, as produced by a connector) to its internal representation (i.e., the Java type that matches the target CQL type).

externalToInternal(T) - Method in class com.datastax.oss.dsbulk.codecs.api.IdempotentConvertingCodec

externalToInternal(T) - Method in class com.datastax.oss.dsbulk.codecs.api.writetime.WriteTimeCodec

externalToInternal(Boolean) - Method in class com.datastax.oss.dsbulk.codecs.jdk.bool.BooleanToNumberCodec

externalToInternal(Boolean) - Method in class com.datastax.oss.dsbulk.codecs.jdk.bool.BooleanToStringCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.collection.CollectionToCollectionCodec

externalToInternal(List<E>) - Method in class com.datastax.oss.dsbulk.codecs.jdk.collection.ListToTupleCodec

externalToInternal(List<E>) - Method in class com.datastax.oss.dsbulk.codecs.jdk.collection.ListToUDTCodec

externalToInternal(Map<EK, EV>) - Method in class com.datastax.oss.dsbulk.codecs.jdk.map.MapToMapCodec

externalToInternal(Map<EK, EV>) - Method in class com.datastax.oss.dsbulk.codecs.jdk.map.MapToUDTCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToBooleanCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToInstantCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToNumberCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToStringCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToUUIDCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.DateToTemporalCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.DateToUUIDCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.TemporalToTemporalCodec

externalToInternal(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.TemporalToUUIDCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToDateRangeCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToGeometryCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBigDecimalCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBigIntegerCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBlobCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBooleanCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToByteCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToCollectionCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToDoubleCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToDurationCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToFloatCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToInetAddressCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToInstantCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToIntegerCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToLocalDateCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToLocalTimeCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToLongCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToMapCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToShortCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToStringCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToTupleCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToUDTCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToUnknownTypeCodec

externalToInternal(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToUUIDCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToDateRangeCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToLineStringCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToPointCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToPolygonCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToBigDecimalCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToBigIntegerCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToBlobCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToBooleanCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToByteCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToCollectionCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToDoubleCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToDurationCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToFloatCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToInetAddressCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToInstantCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToIntegerCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToLocalDateCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToLocalTimeCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToLongCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToMapCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToShortCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToStringCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToTupleCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToUDTCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToUnknownTypeCodec

externalToInternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToUUIDCodec

extractingMetricsFrom(MetricsCollectingExecutionListener) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListenerBuilder

Instructs the new reporter to use the given delegate as is source of metrics.

extraneousField(Field) - Static method in exception com.datastax.oss.dsbulk.workflow.commons.schema.InvalidMappingException

F

failFast - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

failFast - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

failSafe() - Method in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

failSafe() - Method in interface com.datastax.oss.dsbulk.executor.api.BulkExecutorBuilder

Switches on fail-safe mode.

Field - Interface in com.datastax.oss.dsbulk.connectors.api

A field in a record.

fields() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultErrorRecord

fields() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

fields() - Method in interface com.datastax.oss.dsbulk.connectors.api.Record

Returns a set containing all the fields in this record.

fields() - Method in class com.datastax.oss.dsbulk.mapping.DefaultMapping

fields() - Method in interface com.datastax.oss.dsbulk.mapping.Mapping

Returns all the fields in this mapping.

fieldToVariables(Field) - Method in class com.datastax.oss.dsbulk.mapping.DefaultMapping

fieldToVariables(Field) - Method in interface com.datastax.oss.dsbulk.mapping.Mapping

Maps the given field to one or more variables in a write bound statement.

FILE_NAME_FORMAT - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

FILE_NAME_PATTERN - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

fileCounter - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

fileNameFormat - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

files - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

findPrinter(Class<? extends S>) - Method in class com.datastax.oss.dsbulk.format.statement.StatementPrinterRegistry

firstIndexOf(String) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

firstIndexOf(CqlIdentifier) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

flush() - Method in interface com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector.RecordWriter

Flushes all pending writes.

forAbsoluteValue(long) - Static method in interface com.datastax.oss.dsbulk.workflow.api.error.ErrorThreshold

Creates an ErrorThreshold based on an absolute number of maximum allowed errors.

format(EXTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

format(ByteBuffer) - Method in class com.datastax.oss.dsbulk.codecs.api.format.binary.Base64BinaryFormat

format(ByteBuffer) - Method in interface com.datastax.oss.dsbulk.codecs.api.format.binary.BinaryFormat

Formats the given ByteBuffer as a string.

format(ByteBuffer) - Method in class com.datastax.oss.dsbulk.codecs.api.format.binary.HexBinaryFormat

format(Geometry) - Method in interface com.datastax.oss.dsbulk.codecs.api.format.geo.GeoFormat

Formats the given Geometry as a string.

format(Geometry) - Method in class com.datastax.oss.dsbulk.codecs.api.format.geo.JsonGeoFormat

format(Geometry) - Method in class com.datastax.oss.dsbulk.codecs.api.format.geo.WellKnownBinaryGeoFormat

format(Geometry) - Method in class com.datastax.oss.dsbulk.codecs.api.format.geo.WellKnownTextGeoFormat

format(Object, StringBuffer, FieldPosition) - Method in class com.datastax.oss.dsbulk.codecs.api.format.number.ExactNumberFormat

format(double, StringBuffer, FieldPosition) - Method in class com.datastax.oss.dsbulk.codecs.api.format.number.ExactNumberFormat

format(long, StringBuffer, FieldPosition) - Method in class com.datastax.oss.dsbulk.codecs.api.format.number.ExactNumberFormat

format(Object, StringBuffer, FieldPosition) - Method in class com.datastax.oss.dsbulk.codecs.api.format.number.ToStringNumberFormat

format(double, StringBuffer, FieldPosition) - Method in class com.datastax.oss.dsbulk.codecs.api.format.number.ToStringNumberFormat

format(long, StringBuffer, FieldPosition) - Method in class com.datastax.oss.dsbulk.codecs.api.format.number.ToStringNumberFormat

format(TemporalAccessor) - Method in class com.datastax.oss.dsbulk.codecs.api.format.temporal.NumericTemporalFormat

format(TemporalAccessor) - Method in class com.datastax.oss.dsbulk.codecs.api.format.temporal.SimpleTemporalFormat

format(TemporalAccessor) - Method in interface com.datastax.oss.dsbulk.codecs.api.format.temporal.TemporalFormat

Formats the given temporal.

format(Row, ProtocolVersion, CodecRegistry) - Method in class com.datastax.oss.dsbulk.format.row.RowFormatter

Formats the given row.

format(Statement<?>, StatementFormatVerbosity, ProtocolVersion, CodecRegistry) - Method in class com.datastax.oss.dsbulk.format.statement.StatementFormatter

Formats the given statement.

FORMAT_NUMBERS - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

formatDuration(Duration) - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.DurationUtils

Formats the given duration in plain English text.

formatNumber(Number, NumberFormat) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Formats the given number using the given format.

formatSingleLine(String) - Static method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManagerUtils

formatSource(Record) - Static method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManagerUtils

forPartitioner(String) - Static method in interface com.datastax.oss.dsbulk.partitioner.BulkTokenFactory

forRatio(float, long) - Static method in interface com.datastax.oss.dsbulk.workflow.api.error.ErrorThreshold

Creates an ErrorThreshold based on a ratio of errors over the total items processed so far.

fraction() - Method in interface com.datastax.oss.dsbulk.partitioner.BulkTokenRange

fraction() - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenRange

fraction() - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenRange

fromCql(String) - Static method in class com.datastax.oss.dsbulk.mapping.CQLWord

Creates an identifier from its CQL form.

fromCqlIdentifier(CqlIdentifier) - Static method in class com.datastax.oss.dsbulk.mapping.CQLWord

Creates an identifier from a CqlIdentifier.

fromInternal(String) - Static method in class com.datastax.oss.dsbulk.mapping.CQLWord

Creates an identifier from its internal form.

fromUUIDTimestamp(long) - Static method in enum com.datastax.oss.dsbulk.codecs.api.util.TimeUUIDGenerator

FunctionCall - Class in com.datastax.oss.dsbulk.mapping

A CQL function call as declared in a query or in a mapping entry.

FunctionCall(CQLWord, CQLWord, CQLFragment...) - Constructor for class com.datastax.oss.dsbulk.mapping.FunctionCall

FunctionCall(CQLWord, CQLWord, List<CQLFragment>) - Constructor for class com.datastax.oss.dsbulk.mapping.FunctionCall

G

generate(Instant) - Method in enum com.datastax.oss.dsbulk.codecs.api.util.TimeUUIDGenerator

Generates a version 1 time-based UUID from the provided Instant.

generate(int) - Method in class com.datastax.oss.dsbulk.partitioner.TokenRangeReadStatementGenerator

Generates default SELECT statements to read the entire table, with a minimum of splitCount statements.

generate(int, Function<TokenRange, Statement<?>>) - Method in class com.datastax.oss.dsbulk.partitioner.TokenRangeReadStatementGenerator

Generates SELECT statements to read the entire table, with a minimum of splitCount statements and using the given factory to generate statements.

GEO_FORMAT - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

GeoFormat - Interface in com.datastax.oss.dsbulk.codecs.api.format.geo

An utility for formatting geometry data.

geoFormat - Variable in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToGeometryCodec

GeoFormatTest - Class in com.datastax.oss.dsbulk.codecs.api.format.geo

GeoFormatTest() - Constructor for class com.datastax.oss.dsbulk.codecs.api.format.geo.GeoFormatTest

getAbbreviatedOption() - Method in class com.datastax.oss.dsbulk.runner.help.HelpEntry

getAppConfigurationEntry(String) - Method in class com.datastax.oss.dsbulk.workflow.commons.auth.AuthProviderFactory.KeyTabConfiguration

getAppConfigurationEntry(String) - Method in class com.datastax.oss.dsbulk.workflow.commons.auth.AuthProviderFactory.TicketCacheConfiguration

getArgs() - Method in class com.datastax.oss.dsbulk.mapping.FunctionCall

getArgumentType() - Method in class com.datastax.oss.dsbulk.runner.help.HelpEntry

getAssignments() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getAttribute(String) - Method in class com.datastax.oss.dsbulk.codecs.api.ConversionContext

getAttribute(Object) - Method in class com.datastax.oss.dsbulk.executor.api.listener.DefaultExecutionContext

getAttribute(Object) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionContext

Retrieves an attribute stored in this context.

getBatchSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getBatchSize() - Method in interface com.datastax.oss.dsbulk.executor.api.result.Result

Returns the size of the batch, if the executed statement was a batch statement, or 1 otherwise.

getBooleanInputWords(List<String>) - Static method in class com.datastax.oss.dsbulk.workflow.commons.settings.CodecSettings

getBooleanOutputWords(List<String>) - Static method in class com.datastax.oss.dsbulk.workflow.commons.settings.CodecSettings

getBufferSize() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.BatchSettings

getBulkLoaderNameAndVersion() - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.WorkflowUtils

getBulkLoaderVersion() - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.WorkflowUtils

getBytesReceivedMeter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Meter that evaluates the total number of bytes received so far.

getBytesSentMeter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Meter that evaluates the total number of bytes sent so far.

getBytesUnsafe(int) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getChar(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Returns the character at the given path.

getCharset(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Returns the Charset at the given path.

getCodecRegistry() - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodecFactory

getCodecRegistry() - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

getCodecRegistry() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

getCodecSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getComments(ConfigValue) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Returns the comments associated with the given value, excluding type hints.

getCompressionSuffix(String) - Static method in class com.datastax.oss.dsbulk.io.CompressedIOUtils

getConfig() - Method in class com.datastax.oss.dsbulk.runner.cli.ParsedCommandLine

getConnector() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ConnectorSettings

getConnectorConfig() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ConnectorSettings

getConnectorName() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Returns the connector name, e.g.

getConnectorName() - Method in class com.datastax.oss.dsbulk.connectors.csv.CSVConnector

getConnectorName() - Method in class com.datastax.oss.dsbulk.connectors.json.JsonConnector

getConnectorName() - Method in exception com.datastax.oss.dsbulk.runner.cli.GlobalHelpRequestException

getConnectorName() - Method in exception com.datastax.oss.dsbulk.runner.cli.SectionHelpRequestException

getConnectorName() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ConnectorSettings

getConnectorSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getConsistencyLevel() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getConsistencyLevel() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getContext() - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodecFactory

getCqlType() - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

getCurrentOperationDirectory() - Static method in class com.datastax.oss.dsbulk.workflow.api.log.OperationDirectory

getCustomExecutionIdTemplate() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.EngineSettings

getCustomPayload() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getCustomPayload() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getDataSize(Statement<?>, ProtocolVersion, CodecRegistry) - Static method in class com.datastax.oss.dsbulk.sampler.DataSizes

Evaluates the data size contained in the given statement.

getDataSize(Row) - Static method in class com.datastax.oss.dsbulk.sampler.DataSizes

Evaluates the data size contained in the given row.

getDescription() - Method in class com.datastax.oss.dsbulk.runner.help.HelpEntry

getDescription() - Method in interface com.datastax.oss.dsbulk.workflow.api.WorkflowProvider

getDescription() - Method in class com.datastax.oss.dsbulk.workflow.count.CountWorkflowProvider

getDescription() - Method in class com.datastax.oss.dsbulk.workflow.load.LoadWorkflowProvider

getDescription() - Method in class com.datastax.oss.dsbulk.workflow.unload.UnloadWorkflowProvider

getDriverConfig() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.DriverSettings

getDriverSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getEffectiveBulkLoaderConfig() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getEnd() - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenRange

getEnd() - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenRange

getEngineSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getError() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultErrorRecord

getError() - Method in interface com.datastax.oss.dsbulk.connectors.api.ErrorRecord

Returns the error that prevented this record from being processed.

getError() - Method in class com.datastax.oss.dsbulk.executor.api.result.EmptyWriteResult

getError() - Method in interface com.datastax.oss.dsbulk.executor.api.result.Result

Returns an optional BulkExecutionException.

getError() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.UnmappableStatement

getExcludedVariables() - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

getExecutionId() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getExecutionInfo() - Method in class com.datastax.oss.dsbulk.executor.api.result.EmptyWriteResult

getExecutionInfo() - Method in interface com.datastax.oss.dsbulk.executor.api.result.Result

getExecutionListener() - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

getExecutionProfile() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getExecutionProfile() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getExecutionProfileName() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getExecutionProfileName() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getExecutorSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getExitStatus() - Method in class com.datastax.oss.dsbulk.runner.WorkflowThread

getExplicitMappings() - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

getFailedReadsCounter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Counter that evaluates the duration of execution of failed reads.

getFailedReadsWritesCounter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Counter that evaluates the duration of execution of all failed operations, including reads and writes.

getFailedStatementsCounter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Counter for failed statement executions.

getFailedWrites() - Method in class com.datastax.oss.dsbulk.executor.api.result.DefaultWriteResult

getFailedWrites() - Method in class com.datastax.oss.dsbulk.executor.api.result.EmptyWriteResult

getFailedWrites() - Method in interface com.datastax.oss.dsbulk.executor.api.result.WriteResult

If the query that produced this result was a conditional update, but the conditional update wasn't successful, returns a Stream containing the failed writes.

getFailedWritesCounter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Counter that evaluates the duration of execution of failed writes.

getFieldDescription() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultIndexedField

getFieldDescription() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultMappedField

getFieldDescription() - Method in interface com.datastax.oss.dsbulk.connectors.api.Field

getFieldDescription() - Method in class com.datastax.oss.dsbulk.mapping.FunctionCall

getFieldIndex() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultIndexedField

getFieldIndex() - Method in interface com.datastax.oss.dsbulk.connectors.api.IndexedField

getFieldName() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultMappedField

getFieldName() - Method in interface com.datastax.oss.dsbulk.connectors.api.MappedField

getFieldType(Field, DataType) - Method in interface com.datastax.oss.dsbulk.connectors.api.RecordMetadata

Returns the type of the given field.

getFieldValue(Field) - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultErrorRecord

getFieldValue(Field) - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

getFieldValue(Field) - Method in interface com.datastax.oss.dsbulk.connectors.api.Record

Returns the value associated with the given field.

getFromClauseEndIndex() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getFromClauseStartIndex() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getFunctionName() - Method in class com.datastax.oss.dsbulk.mapping.FunctionCall

getInFlightRequestsCounter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Counter that evaluates the number of current in-flight requests, i.e.

getInternalCodec() - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

getInternalJavaType() - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

getJavaType() - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

getKeyspace() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getKeyspace() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getKeyspaceName() - Method in class com.datastax.oss.dsbulk.mapping.FunctionCall

getKeyspaceName() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getLimits() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

getLiteral() - Method in class com.datastax.oss.dsbulk.mapping.CQLLiteral

getLogSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getLongOption() - Method in class com.datastax.oss.dsbulk.runner.help.HelpEntry

getLower() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.Range

getMaxConcurrentQueries() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.EngineSettings

getMaxErrorRatio() - Method in class com.datastax.oss.dsbulk.workflow.api.error.RatioErrorThreshold

getMaxErrors() - Method in class com.datastax.oss.dsbulk.workflow.api.error.AbsoluteErrorThreshold

getMessage() - Method in exception com.datastax.oss.dsbulk.executor.api.exception.BulkExecutionException

getMinSample() - Method in class com.datastax.oss.dsbulk.workflow.api.error.RatioErrorThreshold

getMonitoringSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getNamedValues() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getNode() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getNode() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getNullSafeValue(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

An alternative to Config.getValue(String) that handles null values gracefully instead of throwing.

getNumberFormat(String, Locale, RoundingMode, boolean) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

getNumberFormatThreadLocal(String, Locale, RoundingMode, boolean) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

getNumPartitions() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.StatsSettings

getObjectMapper() - Static method in class com.datastax.oss.dsbulk.codecs.text.json.JsonCodecUtils

The object mapper to use for converting Json nodes to and from Java types in Json codecs.

getOperationDirectory() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

getOptions(EndPoint, String) - Method in class com.datastax.oss.dsbulk.workflow.commons.auth.BulkGssApiAuthProvider

getOrCreateDestinationURL() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Returns the URL that the connector should write to.

getPageSize() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getPageSize() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getPagingState() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getPagingState() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getPath(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Returns the Path object at the given path.

getPath() - Method in enum com.datastax.oss.dsbulk.workflow.commons.settings.BulkDriverOption

getPosition() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultErrorRecord

getPosition() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

getPosition() - Method in interface com.datastax.oss.dsbulk.connectors.api.Record

Returns the record's position inside its resource, typically the line number if the resource is a file, or the row number, if the resource is a database table.

getPositionalValues() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getPositions() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.PositionsTracker

getPreparedStatement() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getPrinterRegistry() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

getProtocolVersion() - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

getProtocolVersion() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

getQuery() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getQueryTimestamp() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getQueryTimestamp() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getRawJavaType() - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.TemporalToTemporalCodec

getRecord() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getRecord() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getRecord() - Method in interface com.datastax.oss.dsbulk.workflow.commons.statement.MappedStatement

Returns the record that this statement was mapped from.

getRecordMetadata() - Method in interface com.datastax.oss.dsbulk.connectors.api.Connector

Returns metadata about the records that this connector can read or write.

getRecordMetadata() - Method in class com.datastax.oss.dsbulk.connectors.csv.CSVConnector

getRecordMetadata() - Method in class com.datastax.oss.dsbulk.connectors.json.JsonConnector

getRegistry() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns the MetricRegistry used to aggregate metrics for this listener.

getResource() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultErrorRecord

getResource() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

getResource() - Method in interface com.datastax.oss.dsbulk.connectors.api.Record

Returns the record's resource location, typically the file or database table where it was extracted from.

getResultSetVariables() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getRoutingKey() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getRoutingKey() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getRoutingKeyspace() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getRoutingKeyspace() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getRoutingToken() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getRoutingToken() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getRow() - Method in class com.datastax.oss.dsbulk.executor.api.result.DefaultReadResult

getRow() - Method in interface com.datastax.oss.dsbulk.executor.api.result.ReadResult

Returns the encapsulated Row object for this read result, if present.

getRowType() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

getSanitizedErrorMessage(Throwable) - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.ThrowableUtils

Returns a sanitized, prettified error message for the given throwable.

getSanitizedErrorMessage(Throwable, Predicate<Throwable>, int) - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.ThrowableUtils

Returns a sanitized, prettified error message for the given throwable.

getSchemaSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getSectionName() - Method in exception com.datastax.oss.dsbulk.runner.cli.SectionHelpRequestException

getSerialConsistencyLevel() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getSerialConsistencyLevel() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getSettings() - Method in interface com.datastax.oss.dsbulk.config.model.SettingsGroup

getShortOption() - Method in class com.datastax.oss.dsbulk.runner.help.HelpEntry

getSnapshot() - Method in class com.datastax.oss.dsbulk.executor.api.histogram.HdrHistogramReservoir

getSource() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultErrorRecord

getSource() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

getSource() - Method in interface com.datastax.oss.dsbulk.connectors.api.Record

Returns the record source, typically a line in a file or a row in a database table.

getStart() - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenRange

getStart() - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenRange

getStatement() - Method in exception com.datastax.oss.dsbulk.executor.api.exception.BulkExecutionException

The Statement that caused the execution failure.

getStatement() - Method in class com.datastax.oss.dsbulk.executor.api.result.EmptyWriteResult

getStatement() - Method in interface com.datastax.oss.dsbulk.executor.api.result.Result

Returns the Statement that has been executed to obtain this result.

getStatisticsModes() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.StatsSettings

getStatsSettings() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

getSuccessfulReadsCounter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Counter that evaluates the duration of execution of successful reads.

getSuccessfulReadsWritesCounter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Counter that evaluates the duration of execution of all successful operations, including reads and writes.

getSuccessfulStatementsCounter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Counter for successful statement executions.

getSuccessfulWritesCounter() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Counter that evaluates the duration of execution of successful writes.

getSupportedCompressions(boolean) - Static method in class com.datastax.oss.dsbulk.io.CompressedIOUtils

getSupportedStatementClass() - Method in class com.datastax.oss.dsbulk.format.statement.BatchStatementPrinter

getSupportedStatementClass() - Method in class com.datastax.oss.dsbulk.format.statement.BoundStatementPrinter

getSupportedStatementClass() - Method in class com.datastax.oss.dsbulk.format.statement.DefaultStatementPrinter

getSupportedStatementClass() - Method in class com.datastax.oss.dsbulk.format.statement.SimpleStatementPrinter

getSupportedStatementClass() - Method in interface com.datastax.oss.dsbulk.format.statement.StatementPrinter

The concrete Statement subclass that this printer handles.

getSupportedStatementClass() - Method in class com.datastax.oss.dsbulk.format.statement.StatementPrinterBase

getSupportedStatementClass() - Method in class com.datastax.oss.dsbulk.workflow.commons.format.statement.MappedBoundStatementPrinter

getSupportedStatementClass() - Method in class com.datastax.oss.dsbulk.workflow.commons.format.statement.MappedSimpleStatementPrinter

getTableName() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getTargetTable() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

getTemporalFormat(String, ZoneId, Locale, TimeUnit, ZonedDateTime, FastThreadLocal<NumberFormat>, boolean) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

getThreads(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Returns the number of threads at the given path.

getThreshold() - Method in exception com.datastax.oss.dsbulk.workflow.api.error.TooManyErrorsException

getTimeout() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getTimeout() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

getTitle() - Method in interface com.datastax.oss.dsbulk.workflow.api.WorkflowProvider

getTitle() - Method in class com.datastax.oss.dsbulk.workflow.count.CountWorkflowProvider

getTitle() - Method in class com.datastax.oss.dsbulk.workflow.load.LoadWorkflowProvider

getTitle() - Method in class com.datastax.oss.dsbulk.workflow.unload.UnloadWorkflowProvider

getTokenRangeRestrictionEndVariable() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getTokenRangeRestrictionEndVariableIndex() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getTokenRangeRestrictionStartVariable() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getTokenRangeRestrictionStartVariableIndex() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

getTokenValue(Token) - Static method in class com.datastax.oss.dsbulk.partitioner.utils.TokenUtils

getTotalErrors() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

getTotalReadsTimer() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Timer that evaluates the duration of execution of reads, both successful and failed.

getTotalReadsWritesTimer() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Timer that evaluates the duration of execution of all operations, including reads and writes, both successful and failed.

getTotalStatementsTimer() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Timer for total statement executions (successful and failed).

getTotalWritesTimer() - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Returns a Timer that evaluates the duration of execution of writes, both successful and failed.

getType(int) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getTypeHint(ConfigValue) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Retrieves the type hint for the given value, if any.

getTypeString(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Returns a string representation of the value type at this path.

getUpper() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.Range

getURL(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Returns the URL object at the given path.

getURLsFromFile(Path) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Loads list of URLs from a file given as the urlfile argument using encoding.

getUsingTimestampVariable() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

Returns the variable name used in a USING TIMESTAMP clause; or empty if no such clause or no such variable.

getUsingTTLVariable() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

Returns the variable name used in a USING TTL clause; or empty if no such clause or no such variable.

getValues() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

getValueType(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Alternative to ConfigValue.valueType() that honors any type hints found in the configuration, if any.

getVerbosity() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

getWorkflowProvider() - Method in class com.datastax.oss.dsbulk.runner.cli.ParsedCommandLine

getWriteTimeVariables() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

GlobalHelpRequestException - Exception in com.datastax.oss.dsbulk.runner.cli

Simple exception indicating that the user wants the main help output.

GraphUtils - Class in com.datastax.oss.dsbulk.workflow.commons.utils

GraphUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.utils.GraphUtils

group(List<BulkTokenRange>, int, int) - Method in class com.datastax.oss.dsbulk.partitioner.TokenRangeClusterer

Groups contiguous ranges together as long as they are contiguous and share the same replicas.

groupingKey(Statement<?>) - Method in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

GZIP_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

H

handleUnexpectedError(Workflow, Throwable) - Static method in class com.datastax.oss.dsbulk.runner.ErrorHandler

hashCode() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultIndexedField

hashCode() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultMappedField

hashCode() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

hashCode() - Method in class com.datastax.oss.dsbulk.executor.api.result.DefaultReadResult

hashCode() - Method in class com.datastax.oss.dsbulk.mapping.CQLLiteral

hashCode() - Method in class com.datastax.oss.dsbulk.mapping.CQLWord

hashCode() - Method in class com.datastax.oss.dsbulk.mapping.FunctionCall

hashCode() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.Range

hasReferenceValue(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Checks whether the given path has a default value or not.

hasSearchClause() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

hasUnsupportedSelectors() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

hasUserOverride(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Checks whether the given path has a user-defined value or not.

hasWhereClause() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

HdrHistogramReservoir - Class in com.datastax.oss.dsbulk.executor.api.histogram

This is a slightly modified copy of the following code: https://bitbucket.org/marshallpierce/hdrhistogram-metrics-reservoir, initially published under COIL 0.5 (Copyfree) license.

HdrHistogramReservoir() - Constructor for class com.datastax.oss.dsbulk.executor.api.histogram.HdrHistogramReservoir

Create a reservoir with a default recorder.

HdrHistogramReservoir(Recorder) - Constructor for class com.datastax.oss.dsbulk.executor.api.histogram.HdrHistogramReservoir

Create a reservoir with a user-specified recorder.

HelpEmitter - Class in com.datastax.oss.dsbulk.runner.help

HelpEmitter() - Constructor for class com.datastax.oss.dsbulk.runner.help.HelpEmitter

HelpEntry - Class in com.datastax.oss.dsbulk.runner.help

HelpEntry(String, String, String, String, String) - Constructor for class com.datastax.oss.dsbulk.runner.help.HelpEntry

HelpEntryFactory - Class in com.datastax.oss.dsbulk.runner.help

HelpEntryFactory() - Constructor for class com.datastax.oss.dsbulk.runner.help.HelpEntryFactory

HEX_INSTANCE - Static variable in class com.datastax.oss.dsbulk.codecs.api.format.geo.WellKnownBinaryGeoFormat

HexBinaryFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.binary

HighlightingMessageConverter - Class in com.datastax.oss.dsbulk.workflow.commons.log

A MessageConverter that highlights WARN and ERROR messages in bold yellow and bold red respectively.

HighlightingMessageConverter() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.log.HighlightingMessageConverter

htmlEscape(String) - Static method in class com.datastax.oss.dsbulk.docs.utils.StringUtils

Replaces tokens that are meaningful in html with their entity representations.

I

idempotent - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

IdempotentConvertingCodec<T> - Class in com.datastax.oss.dsbulk.codecs.api

IdempotentConvertingCodec(TypeCodec<T>) - Constructor for class com.datastax.oss.dsbulk.codecs.api.IdempotentConvertingCodec

ifError(Consumer<? super BulkExecutionException>) - Method in interface com.datastax.oss.dsbulk.executor.api.result.Result

If an error is present, invoke the specified consumer with the error, otherwise do nothing.

ifSuccess(Consumer<? super Row>) - Method in interface com.datastax.oss.dsbulk.executor.api.result.ReadResult

If the result is a success, invoke the specified consumer with the returned Row, otherwise do nothing.

indent() - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

indent() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

indexed(Object, URI, long, Object...) - Static method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

Creates an indexed record with the given values.

IndexedField - Interface in com.datastax.oss.dsbulk.connectors.api

A field in a Record identified by a zero-based integer index.

IndexedMappingField - Class in com.datastax.oss.dsbulk.mapping

A field in a mapping declaration, identified by a zero-based integer index.

IndexedMappingField(int) - Constructor for class com.datastax.oss.dsbulk.mapping.IndexedMappingField

init() - Method in interface com.datastax.oss.dsbulk.connectors.api.Connector

Initializes the connector.

init() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

init() - Method in class com.datastax.oss.dsbulk.connectors.csv.CSVConnector

init() - Method in class com.datastax.oss.dsbulk.connectors.json.JsonConnector

init() - Method in interface com.datastax.oss.dsbulk.workflow.api.Workflow

Initializes the workflow.

init() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

init() - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

init(boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.BatchSettings

init() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.CodecSettings

init(boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ConnectorSettings

init(boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.DriverSettings

init() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.EngineSettings

init() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ExecutorSettings

init() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

init() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.MonitoringSettings

init(CqlSession, boolean, boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

init(String, boolean, SchemaGenerationStrategy) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

init() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.StatsSettings

init() - Method in class com.datastax.oss.dsbulk.workflow.count.CountWorkflow

init() - Method in class com.datastax.oss.dsbulk.workflow.load.LoadWorkflow

init() - Method in class com.datastax.oss.dsbulk.workflow.unload.UnloadWorkflow

install() - Static method in class com.datastax.oss.dsbulk.url.BulkLoaderURLStreamHandlerFactory

Install this URL stream handler factory as the default factory for the JVM.

INSTANCE - Static variable in class com.datastax.oss.dsbulk.codecs.api.format.binary.Base64BinaryFormat

INSTANCE - Static variable in class com.datastax.oss.dsbulk.codecs.api.format.binary.HexBinaryFormat

INSTANCE - Static variable in class com.datastax.oss.dsbulk.codecs.api.format.geo.JsonGeoFormat

INSTANCE - Static variable in class com.datastax.oss.dsbulk.codecs.api.format.geo.WellKnownTextGeoFormat

INSTANCE - Static variable in class com.datastax.oss.dsbulk.workflow.api.error.UnlimitedErrorThreshold

instantToNumber(Instant, TimeUnit, Instant) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given Instant into a scalar timestamp expressed in the given time unit and relative to the Unix Epoch.

INTERNAL_TIMESTAMP_VARNAME - Static variable in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

INTERNAL_TTL_VARNAME - Static variable in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

internalCodec - Variable in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

internalToExternal(INTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

Converts the internal representation of a value (i.e., the Java type that matches the target CQL type) to its external representation (i.e., the value, as consumed by a connector).

internalToExternal(T) - Method in class com.datastax.oss.dsbulk.codecs.api.IdempotentConvertingCodec

internalToExternal(Long) - Method in class com.datastax.oss.dsbulk.codecs.api.writetime.WriteTimeCodec

internalToExternal(INTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.bool.BooleanToNumberCodec

internalToExternal(String) - Method in class com.datastax.oss.dsbulk.codecs.jdk.bool.BooleanToStringCodec

internalToExternal(INTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.collection.CollectionToCollectionCodec

internalToExternal(TupleValue) - Method in class com.datastax.oss.dsbulk.codecs.jdk.collection.ListToTupleCodec

internalToExternal(UdtValue) - Method in class com.datastax.oss.dsbulk.codecs.jdk.collection.ListToUDTCodec

internalToExternal(Map<IK, IV>) - Method in class com.datastax.oss.dsbulk.codecs.jdk.map.MapToMapCodec

internalToExternal(UdtValue) - Method in class com.datastax.oss.dsbulk.codecs.jdk.map.MapToUDTCodec

internalToExternal(Boolean) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToBooleanCodec

internalToExternal(Instant) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToInstantCodec

internalToExternal(INTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToNumberCodec

internalToExternal(String) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToStringCodec

internalToExternal(UUID) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToUUIDCodec

internalToExternal(INTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.DateToTemporalCodec

internalToExternal(UUID) - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.DateToUUIDCodec

internalToExternal(INTERNAL) - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.TemporalToTemporalCodec

internalToExternal(UUID) - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.TemporalToUUIDCodec

internalToExternal(DateRange) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToDateRangeCodec

internalToExternal(T) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToGeometryCodec

internalToExternal(BigDecimal) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBigDecimalCodec

internalToExternal(BigInteger) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBigIntegerCodec

internalToExternal(ByteBuffer) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBlobCodec

internalToExternal(Boolean) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBooleanCodec

internalToExternal(Byte) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToByteCodec

internalToExternal(C) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToCollectionCodec

internalToExternal(Double) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToDoubleCodec

internalToExternal(CqlDuration) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToDurationCodec

internalToExternal(Float) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToFloatCodec

internalToExternal(InetAddress) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToInetAddressCodec

internalToExternal(Integer) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToIntegerCodec

internalToExternal(Long) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToLongCodec

internalToExternal(Map<K, V>) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToMapCodec

internalToExternal(Short) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToShortCodec

internalToExternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToStringCodec

internalToExternal(T) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToTemporalCodec

internalToExternal(TupleValue) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToTupleCodec

internalToExternal(UdtValue) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToUDTCodec

internalToExternal(T) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToUnknownTypeCodec

internalToExternal(UUID) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToUUIDCodec

internalToExternal(DateRange) - Method in class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToDateRangeCodec

internalToExternal(LineString) - Method in class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToLineStringCodec

internalToExternal(Point) - Method in class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToPointCodec

internalToExternal(Polygon) - Method in class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToPolygonCodec

internalToExternal(ByteBuffer) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToBlobCodec

internalToExternal(Boolean) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToBooleanCodec

internalToExternal(C) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToCollectionCodec

internalToExternal(CqlDuration) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToDurationCodec

internalToExternal(InetAddress) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToInetAddressCodec

internalToExternal(Map<K, V>) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToMapCodec

internalToExternal(N) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToNumberCodec

internalToExternal(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToStringCodec

internalToExternal(T) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToTemporalCodec

internalToExternal(TupleValue) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToTupleCodec

internalToExternal(UdtValue) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToUDTCodec

internalToExternal(T) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToUnknownTypeCodec

internalToExternal(UUID) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringToUUIDCodec

InvalidMappingException - Exception in com.datastax.oss.dsbulk.workflow.commons.schema

IOUtils - Class in com.datastax.oss.dsbulk.io

IOUtils() - Constructor for class com.datastax.oss.dsbulk.io.IOUtils

isAllowExtraFields() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

isAllowMissingFields() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

isBatch() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

isBatchingEnabled() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.BatchSettings

isBatchQuery() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

isCollection(DataType) - Static method in class com.datastax.oss.dsbulk.codecs.jdk.JdkCodecUtils

isDataSizeSamplingAvailable() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Checks whether it is safe to perform data size sampling on this connector's data source.

isDataSizeSamplingEnabled() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.EngineSettings

isDirectoryNonEmpty(Path) - Static method in class com.datastax.oss.dsbulk.io.IOUtils

isDryRun() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.EngineSettings

isEmpty() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.PositionsTracker

isEnabled() - Method in interface com.datastax.oss.dsbulk.executor.api.listener.LogSink

Whether the sink will effectively process the message (i.e., log it) or not.

isIdempotent() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

isIdempotent() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

isInferring() - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

isInterrupted(Throwable) - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.ThrowableUtils

Returns true when the given throwable, its cause, or any of its suppressed errors is an InterruptedException or any of its common variants.

isLeaf(ConfigValue) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Returns true if the given value is a leaf.

isLeaf(String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Checks the given line for the presence of an @leaf annotation.

isNoneCompression(String) - Static method in class com.datastax.oss.dsbulk.io.CompressedIOUtils

isNull(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeConvertingCodec

Whether the input is null.

isNull(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringConvertingCodec

Whether the input is null.

isNullOrEmpty(JsonNode) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeConvertingCodec

Whether the input is null or empty.

isNullOrEmpty(String) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringConvertingCodec

Whether the input is null or empty.

isNumeric(DataType) - Static method in class com.datastax.oss.dsbulk.codecs.jdk.JdkCodecUtils

isOssCassandra(CqlSession) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ExecutorSettings

isParallelizable() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

isPathPresentAndNotEmpty(Config, String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Checks if the given path is present and its value is a non-empty string.

isSearchQuery() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

isSelectStar() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

isSources() - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

Whether record sources should be retained in memory.

isStandardStream(URL) - Static method in class com.datastax.oss.dsbulk.io.IOUtils

Returns true if the given URL references the standard input/output streams (that is, if it reads from System.in and writes to System.out).

isSuccess() - Method in interface com.datastax.oss.dsbulk.executor.api.result.Result

Returns true if the statement execution succeeded, false otherwise.

isSupportedCompression(String, boolean) - Static method in class com.datastax.oss.dsbulk.io.CompressedIOUtils

isTemporal(DataType) - Static method in class com.datastax.oss.dsbulk.codecs.jdk.JdkCodecUtils

isTracing() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

isTracing() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

isTypeHint(String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Checks the given line for the presence of an @type annotation.

isUUID(DataType) - Static method in class com.datastax.oss.dsbulk.codecs.jdk.JdkCodecUtils

isWindows() - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.PlatformUtils

Checks if the operating system is a Windows one.

J

javaType - Variable in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

JdkCodecUtils - Class in com.datastax.oss.dsbulk.codecs.jdk

JdkCodecUtils() - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.JdkCodecUtils

JMXUtils - Class in com.datastax.oss.dsbulk.workflow.commons.utils

JMXUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.utils.JMXUtils

JSON_NODE_FACTORY - Static variable in class com.datastax.oss.dsbulk.codecs.text.json.JsonCodecUtils

A JsonNodeFactory that preserves BigDecimal scales, used to generate Json nodes.

JSON_NODE_TYPE - Static variable in class com.datastax.oss.dsbulk.codecs.text.json.JsonCodecUtils

JsonCodecUtils - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonCodecUtils() - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonCodecUtils

JsonConnector - Class in com.datastax.oss.dsbulk.connectors.json

A connector for Json files.

JsonConnector() - Constructor for class com.datastax.oss.dsbulk.connectors.json.JsonConnector

JsonGeoFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.geo

JsonNodeConvertingCodec<T> - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeConvertingCodec(TypeCodec<T>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeConvertingCodec

JsonNodeConvertingCodecProvider - Class in com.datastax.oss.dsbulk.codecs.text.json

A specialized DefaultCodecRegistry that is capable of producing ConvertingCodecs.

JsonNodeConvertingCodecProvider() - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeConvertingCodecProvider

JsonNodeToBigDecimalCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToBigDecimalCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBigDecimalCodec

JsonNodeToBigIntegerCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToBigIntegerCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBigIntegerCodec

JsonNodeToBlobCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToBlobCodec(BinaryFormat, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBlobCodec

JsonNodeToBooleanCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToBooleanCodec(Map<String, Boolean>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToBooleanCodec

JsonNodeToByteCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToByteCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToByteCodec

JsonNodeToCollectionCodec<E,C extends Collection<E>> - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToDateRangeCodec - Class in com.datastax.oss.dsbulk.codecs.text.json.dse

JsonNodeToDateRangeCodec(List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToDateRangeCodec

JsonNodeToDoubleCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToDoubleCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToDoubleCodec

JsonNodeToDurationCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToDurationCodec(List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToDurationCodec

JsonNodeToFloatCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToFloatCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToFloatCodec

JsonNodeToGeometryCodec<T extends Geometry> - Class in com.datastax.oss.dsbulk.codecs.text.json.dse

JsonNodeToGeometryCodec(TypeCodec<T>, ObjectMapper, GeoFormat, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToGeometryCodec

JsonNodeToInetAddressCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToInetAddressCodec(List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToInetAddressCodec

JsonNodeToInstantCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToInstantCodec(TemporalFormat, ZoneId, ZonedDateTime, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToInstantCodec

JsonNodeToIntegerCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToIntegerCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToIntegerCodec

JsonNodeToLineStringCodec - Class in com.datastax.oss.dsbulk.codecs.text.json.dse

JsonNodeToLineStringCodec(ObjectMapper, GeoFormat, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToLineStringCodec

JsonNodeToListCodec<E> - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToListCodec(TypeCodec<List<E>>, ConvertingCodec<JsonNode, E>, ObjectMapper, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToListCodec

JsonNodeToLocalDateCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToLocalDateCodec(TemporalFormat, ZoneId, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToLocalDateCodec

JsonNodeToLocalTimeCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToLocalTimeCodec(TemporalFormat, ZoneId, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToLocalTimeCodec

JsonNodeToLongCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToLongCodec(PrimitiveLongCodec, FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToLongCodec

JsonNodeToMapCodec<K,V> - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToMapCodec(TypeCodec<Map<K, V>>, ConvertingCodec<String, K>, ConvertingCodec<JsonNode, V>, ObjectMapper, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToMapCodec

JsonNodeToPointCodec - Class in com.datastax.oss.dsbulk.codecs.text.json.dse

JsonNodeToPointCodec(ObjectMapper, GeoFormat, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToPointCodec

JsonNodeToPolygonCodec - Class in com.datastax.oss.dsbulk.codecs.text.json.dse

JsonNodeToPolygonCodec(ObjectMapper, GeoFormat, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToPolygonCodec

JsonNodeToSetCodec<E> - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToSetCodec(TypeCodec<Set<E>>, ConvertingCodec<JsonNode, E>, ObjectMapper, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToSetCodec

JsonNodeToShortCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToShortCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToShortCodec

JsonNodeToStringCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToStringCodec(TypeCodec<String>, ObjectMapper, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToStringCodec

JsonNodeToTemporalCodec<T extends TemporalAccessor> - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToTupleCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToTupleCodec(TypeCodec<TupleValue>, List<ConvertingCodec<JsonNode, Object>>, ObjectMapper, List<String>, boolean, boolean) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToTupleCodec

JsonNodeToUDTCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToUDTCodec(TypeCodec<UdtValue>, Map<CqlIdentifier, ConvertingCodec<JsonNode, Object>>, ObjectMapper, List<String>, boolean, boolean) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToUDTCodec

JsonNodeToUnknownTypeCodec<T> - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToUnknownTypeCodec(TypeCodec<T>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToUnknownTypeCodec

JsonNodeToUUIDCodec - Class in com.datastax.oss.dsbulk.codecs.text.json

JsonNodeToUUIDCodec(TypeCodec<UUID>, ConvertingCodec<String, Instant>, TimeUUIDGenerator, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeToUUIDCodec

L

leftPad(String, int) - Static method in class com.datastax.oss.dsbulk.workflow.commons.utils.StringUtils

Left pad a string with spaces to a size of size.

LINE_LENGTH - Static variable in class com.datastax.oss.dsbulk.workflow.api.utils.ConsoleUtils

The console's line length, if could be detected, otherwise this will report 150.

lineSeparator - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

listElementSeparator - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

listener - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

listener - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

ListToTupleCodec<E> - Class in com.datastax.oss.dsbulk.codecs.jdk.collection

ListToTupleCodec(Class<List<E>>, TypeCodec<TupleValue>, List<ConvertingCodec<E, Object>>) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.collection.ListToTupleCodec

ListToUDTCodec<E> - Class in com.datastax.oss.dsbulk.codecs.jdk.collection

ListToUDTCodec(Class<List<E>>, TypeCodec<UdtValue>, List<ConvertingCodec<E, Object>>) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.collection.ListToUDTCodec

loadURLs(Config) - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Validates and computes the list of URLs to be read or written.

LoadWorkflow - Class in com.datastax.oss.dsbulk.workflow.load

The main class for load workflows.

LoadWorkflowProvider - Class in com.datastax.oss.dsbulk.workflow.load

LoadWorkflowProvider() - Constructor for class com.datastax.oss.dsbulk.workflow.load.LoadWorkflowProvider

LOCAL_DATE_FORMAT - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

LOCAL_TIME_FORMAT - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

LOCALE - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

locateConnector(String) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ConnectorSettings

logEffectiveSettings(Config, Config) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

LogManager - Class in com.datastax.oss.dsbulk.workflow.commons.log

LogManager(CqlSession, Path, ErrorThreshold, ErrorThreshold, boolean, StatementFormatter, StatementFormatVerbosity, RowFormatter) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

LogManagerUtils - Class in com.datastax.oss.dsbulk.workflow.commons.log

LogManagerUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.log.LogManagerUtils

LogSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

LogSettings(Config, String) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

LogSettings.Verbosity - Enum in com.datastax.oss.dsbulk.workflow.commons.settings

LogSink - Interface in com.datastax.oss.dsbulk.executor.api.listener

A sink for log messages.

LZ4_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

LZMA_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

M

main(String[]) - Static method in class com.datastax.oss.dsbulk.runner.DataStaxBulkLoader

map(ReadResult) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.DefaultReadResultMapper

map(Record) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.DefaultRecordMapper

map(ReadResult) - Method in interface com.datastax.oss.dsbulk.workflow.commons.schema.ReadResultMapper

map(Record) - Method in interface com.datastax.oss.dsbulk.workflow.commons.schema.RecordMapper

MapConvertingCodecsProvider - Class in com.datastax.oss.dsbulk.codecs.jdk.map

MapConvertingCodecsProvider() - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.map.MapConvertingCodecsProvider

mapped(Object, URI, long, Field[], Object...) - Static method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

Creates a mapped record with the given keys and values.

mapped(Object, URI, long, Map<? extends Field, ?>) - Static method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

Creates a mapped record with the given map of keys and values.

MappedBoundStatement - Class in com.datastax.oss.dsbulk.workflow.commons.statement

MappedBoundStatement(Record, BoundStatement) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

MappedBoundStatementPrinter - Class in com.datastax.oss.dsbulk.workflow.commons.format.statement

MappedBoundStatementPrinter() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.format.statement.MappedBoundStatementPrinter

MappedField - Interface in com.datastax.oss.dsbulk.connectors.api

A field in a Record identified by an alphanumeric name.

MappedMappingField - Class in com.datastax.oss.dsbulk.mapping

A field in a mapping definition identified by an alphanumeric name.

MappedMappingField(String) - Constructor for class com.datastax.oss.dsbulk.mapping.MappedMappingField

MappedSimpleStatement - Class in com.datastax.oss.dsbulk.workflow.commons.statement

MappedSimpleStatement(Record, SimpleStatement) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

MappedSimpleStatementPrinter - Class in com.datastax.oss.dsbulk.workflow.commons.format.statement

MappedSimpleStatementPrinter() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.format.statement.MappedSimpleStatementPrinter

MappedStatement - Interface in com.datastax.oss.dsbulk.workflow.commons.statement

A statement that has been produced by mapping fields of a Record to variables in the query.

MappedStatementPrinter - Interface in com.datastax.oss.dsbulk.workflow.commons.format.statement

Mapping - Interface in com.datastax.oss.dsbulk.mapping

Defines a bidirectional, many-to-many relationship between record fields and CQL columns.

MappingField - Interface in com.datastax.oss.dsbulk.mapping

A field in a mapping definition.

MappingInspector - Class in com.datastax.oss.dsbulk.mapping

MappingInspector(String, boolean, MappingPreference) - Constructor for class com.datastax.oss.dsbulk.mapping.MappingInspector

MappingInspector(String, boolean, MappingPreference, Supplier<CQLWord>, Supplier<CQLWord>) - Constructor for class com.datastax.oss.dsbulk.mapping.MappingInspector

Deprecated.

As of DSBulk 1.8.0, the mapping inspector deprecates the special __ttl and __timestamp tokens; these will be removed in a future release. Therefore, providing external names for these tokens will also cease to be supported in a future release.

MappingPreference - Enum in com.datastax.oss.dsbulk.mapping

How to determine if a mapping should be considered indexed or mapped in case of ambiguities, and according to the connector's capabilities.

MappingToken - Interface in com.datastax.oss.dsbulk.mapping

A token appearing in a mapping string, such as a field, or a CQL fragment.

MapToMapCodec<EK,EV,IK,IV> - Class in com.datastax.oss.dsbulk.codecs.jdk.map

MapToMapCodec(Class<Map<EK, EV>>, TypeCodec<Map<IK, IV>>, ConvertingCodec<EK, IK>, ConvertingCodec<EV, IV>) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.map.MapToMapCodec

MapToUDTCodec<EK,EV> - Class in com.datastax.oss.dsbulk.codecs.jdk.map

MapToUDTCodec(Class<Map<EK, EV>>, TypeCodec<UdtValue>, ConvertingCodec<EK, String>, Map<CqlIdentifier, ConvertingCodec<EV, Object>>) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.map.MapToUDTCodec

MAX_CONCURRENT_FILES - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

MAX_RECORDS - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

maxAppendedBoundValuesExceeded() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

maxAppendedValuesExceeded() - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

maxBatchStatements - Variable in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

maxBoundValueLength - Variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterLimits

maxBoundValues - Variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterLimits

maxConcurrentFiles - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

maxConcurrentRequests - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

maxInFlightRequests - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

maxInnerStatements - Variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterLimits

maxOutgoingPayloadEntries - Variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterLimits

maxOutgoingPayloadValueLength - Variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterLimits

maxQueryStringLength - Variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterLimits

maxQueryStringLengthExceeded() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

maxRecords - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

maxRequestsPerSecond - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

maxSizeInBytes - Variable in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

maybeAddPortToHost(String, int) - Static method in class com.datastax.oss.dsbulk.workflow.commons.utils.AddressUtils

Adds the default port to a contact point string, depending on whether it already has a port or not.

maybeCreateURLStreamHandler(String) - Method in class com.datastax.oss.dsbulk.url.StdinStdoutURLStreamHandlerProvider

maybeCreateURLStreamHandler(String) - Method in interface com.datastax.oss.dsbulk.url.URLStreamHandlerProvider

Creates a URLStreamHandler for the given protocol, if possible, otherwise returns empty.

maybeProvide(DataType, GenericType<?>, ConvertingCodecFactory, boolean) - Method in interface com.datastax.oss.dsbulk.codecs.api.ConvertingCodecProvider

maybeProvide(DataType, GenericType<?>, ConvertingCodecFactory, boolean) - Method in class com.datastax.oss.dsbulk.codecs.jdk.bool.BooleanConvertingCodecsProvider

maybeProvide(DataType, GenericType<?>, ConvertingCodecFactory, boolean) - Method in class com.datastax.oss.dsbulk.codecs.jdk.collection.CollectionConvertingCodecsProvider

maybeProvide(DataType, GenericType<?>, ConvertingCodecFactory, boolean) - Method in class com.datastax.oss.dsbulk.codecs.jdk.map.MapConvertingCodecsProvider

maybeProvide(DataType, GenericType<?>, ConvertingCodecFactory, boolean) - Method in class com.datastax.oss.dsbulk.codecs.jdk.number.NumericConvertingCodecsProvider

maybeProvide(DataType, GenericType<?>, ConvertingCodecFactory, boolean) - Method in class com.datastax.oss.dsbulk.codecs.jdk.temporal.TemporalConvertingCodecsProvider

maybeProvide(DataType, GenericType<?>, ConvertingCodecFactory, boolean) - Method in class com.datastax.oss.dsbulk.codecs.text.json.JsonNodeConvertingCodecProvider

maybeProvide(DataType, GenericType<?>, ConvertingCodecFactory, boolean) - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringConvertingCodecProvider

MemoryReporter - Class in com.datastax.oss.dsbulk.workflow.commons.metrics

MetricsCollectingExecutionListener - Class in com.datastax.oss.dsbulk.executor.api.listener

A ExecutionListener that records useful metrics about the ongoing bulk operations.

MetricsCollectingExecutionListener() - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Creates a new instance using a newly-allocated MetricRegistry.

MetricsCollectingExecutionListener(MetricRegistry, ProtocolVersion, CodecRegistry, boolean) - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

Creates a new instance using the given MetricRegistry.

MetricsManager - Class in com.datastax.oss.dsbulk.workflow.commons.metrics

MetricsManager(MetricRegistry, boolean, String, ScheduledExecutorService, TimeUnit, TimeUnit, long, long, boolean, boolean, boolean, boolean, Path, LogSettings.Verbosity, Duration, boolean, ProtocolVersion, CodecRegistry, RowType) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

missingField(Field, CQLWord) - Static method in exception com.datastax.oss.dsbulk.workflow.commons.schema.InvalidMappingException

MonitoringSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

MonitoringSettings(Config, String) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.MonitoringSettings

MultipleRetryPolicy - Class in com.datastax.oss.dsbulk.workflow.commons.policies.retry

MultipleRetryPolicy(DriverContext, String) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.policies.retry.MultipleRetryPolicy

Murmur3BulkTokenFactory - Class in com.datastax.oss.dsbulk.partitioner.murmur3

A BulkTokenFactory for the Murmur3 Partitioner.

Murmur3BulkTokenFactory() - Constructor for class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenFactory

Murmur3BulkTokenRange - Class in com.datastax.oss.dsbulk.partitioner.murmur3

Murmur3BulkTokenRange(Murmur3Token, Murmur3Token, Set<EndPoint>) - Constructor for class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenRange

Murmur3TokenRangeSplitter - Class in com.datastax.oss.dsbulk.partitioner.murmur3

Murmur3TokenRangeSplitter() - Constructor for class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3TokenRangeSplitter

N

nameValueSeparator - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

narrowNumber(Number, Class<? extends N>, OverflowStrategy, RoundingMode) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Attempts to convert the given number to the target class, using loss-less conversions.

nCopies(String, int) - Static method in class com.datastax.oss.dsbulk.docs.utils.StringUtils

Returns a new string consisting of n copies of the given string.

nCopies(String, int) - Static method in class com.datastax.oss.dsbulk.runner.utils.StringUtils

Returns a new string consisting of n copies of the given string.

NettySslHandlerFactory - Class in com.datastax.oss.dsbulk.workflow.commons.ssl

newBatcherMonitor() - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

newBufferedInputStream(URL) - Static method in class com.datastax.oss.dsbulk.io.IOUtils

newBufferedOutputStream(URL) - Static method in class com.datastax.oss.dsbulk.io.IOUtils

newBufferedReader(URL, Charset, String) - Static method in class com.datastax.oss.dsbulk.io.CompressedIOUtils

newBufferedReader(URL, Charset) - Static method in class com.datastax.oss.dsbulk.io.IOUtils

newBufferedWriter(URL, Charset, String) - Static method in class com.datastax.oss.dsbulk.io.CompressedIOUtils

newBufferedWriter(URL, Charset) - Static method in class com.datastax.oss.dsbulk.io.IOUtils

newBulkExecutor(CqlSession, ExecutionListener, boolean, boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ExecutorSettings

newCountingUnit() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.DefaultReadResultCounter

newCountingUnit() - Method in interface com.datastax.oss.dsbulk.workflow.commons.schema.ReadResultCounter

newCustomExecutionId(String, String) - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.WorkflowUtils

newDefaultExecutionId(String) - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.WorkflowUtils

newFailedItemsMonitor() - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

newFailedReadsHandler() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

Handler for unsuccessful ReadResults.

newFailedRecordsHandler() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

Handler for failed records.

newFailedWritesHandler() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

Handler for unsuccessful WriteResults.

newLine() - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

newLine() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

newLogManager(CqlSession, boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

newMetricsManager(boolean, boolean, Path, LogSettings.Verbosity, MetricRegistry, ProtocolVersion, CodecRegistry, RowType) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.MonitoringSettings

newQueryWarningsHandler() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

Handler for query warnings.

newReadExecutor(CqlSession, MetricsCollectingExecutionListener, boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ExecutorSettings

newResultPositionsHandler() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

Handler for result positions.

newSession(String, MutableCodecRegistry) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.DriverSettings

newSingleFileReader(URL) - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Returns a new AbstractFileBasedConnector.RecordReader instance; cannot be null.

newSingleFileReader(URL) - Method in class com.datastax.oss.dsbulk.connectors.csv.CSVConnector

newSingleFileReader(URL) - Method in class com.datastax.oss.dsbulk.connectors.json.JsonConnector

newSingleFileWriter() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Returns a new AbstractFileBasedConnector.RecordWriter instance; cannot be null.

newSingleFileWriter() - Method in class com.datastax.oss.dsbulk.connectors.csv.CSVConnector

newSingleFileWriter() - Method in class com.datastax.oss.dsbulk.connectors.json.JsonConnector

newSslHandler(Channel, EndPoint) - Method in class com.datastax.oss.dsbulk.workflow.commons.ssl.NettySslHandlerFactory

newStatementBatcher(CqlSession) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.BatchSettings

newTerminationHandler() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

Handler that is meant to be executed at the very end of the main workflow.

newTotalItemsCounter() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

newTotalItemsMonitor() - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

newUnmappableRecordsHandler() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

Handler for unmappable records produced by the result mapper.

newUnmappableStatementsHandler() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

Handler for unmappable statements produced by the record mapper.

newWorkflow(Config) - Method in interface com.datastax.oss.dsbulk.workflow.api.WorkflowProvider

Creates a new Workflow with the given configuration and shortcuts map.

newWorkflow(Config) - Method in class com.datastax.oss.dsbulk.workflow.count.CountWorkflowProvider

newWorkflow(Config) - Method in class com.datastax.oss.dsbulk.workflow.load.LoadWorkflowProvider

newWorkflow(Config) - Method in class com.datastax.oss.dsbulk.workflow.unload.UnloadWorkflowProvider

newWriteExecutor(CqlSession, ExecutionListener) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.ExecutorSettings

nextWriterIndex - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

NodeComparator - Class in com.datastax.oss.dsbulk.workflow.commons.utils

NodeComparator() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.utils.NodeComparator

NONE_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

now() - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.PlatformUtils

NULL_STRINGS - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

nullPrimaryKey(CQLWord) - Static method in exception com.datastax.oss.dsbulk.workflow.commons.schema.InvalidMappingException

nullString() - Method in class com.datastax.oss.dsbulk.codecs.text.string.StringConvertingCodec

The string to use when formatting internal inputs.

nullValue - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

NUMBER_FORMAT - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

NumberToBooleanCodec<EXTERNAL extends Number> - Class in com.datastax.oss.dsbulk.codecs.jdk.number

NumberToBooleanCodec(Class<EXTERNAL>, List<BigDecimal>) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToBooleanCodec

numberToInstant(Number, TimeUnit, Instant) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number into an Instant, expressed in the given time unit, and relative to the given epoch.

NumberToInstantCodec<EXTERNAL extends Number> - Class in com.datastax.oss.dsbulk.codecs.jdk.number

NumberToInstantCodec(Class<EXTERNAL>, TimeUnit, ZonedDateTime) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToInstantCodec

NumberToNumberCodec<EXTERNAL extends Number,INTERNAL extends Number> - Class in com.datastax.oss.dsbulk.codecs.jdk.number

NumberToNumberCodec(Class<EXTERNAL>, TypeCodec<INTERNAL>) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToNumberCodec

NumberToStringCodec<EXTERNAL extends Number> - Class in com.datastax.oss.dsbulk.codecs.jdk.number

NumberToStringCodec(Class<EXTERNAL>, FastThreadLocal<NumberFormat>) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToStringCodec

numberToTemporal(Number) - Method in class com.datastax.oss.dsbulk.codecs.api.format.temporal.NumericTemporalFormat

NumberToUUIDCodec<EXTERNAL extends Number> - Class in com.datastax.oss.dsbulk.codecs.jdk.number

NumberToUUIDCodec(TypeCodec<UUID>, NumberToInstantCodec<EXTERNAL>, TimeUUIDGenerator) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.number.NumberToUUIDCodec

NUMERIC_PATTERN - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

NumericConvertingCodecsProvider - Class in com.datastax.oss.dsbulk.codecs.jdk.number

NumericConvertingCodecsProvider() - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.number.NumericConvertingCodecsProvider

NumericTemporalFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.temporal

A special temporal format that converts to and from numeric data.

NumericTemporalFormat(FastThreadLocal<NumberFormat>, ZoneId, TimeUnit, ZonedDateTime) - Constructor for class com.datastax.oss.dsbulk.codecs.api.format.temporal.NumericTemporalFormat

O

OBJECT_MAPPER - Static variable in class com.datastax.oss.dsbulk.codecs.text.TextConversionContext

objectMapper - Variable in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToGeometryCodec

onErrorResponse(Request, CoordinatorException, int) - Method in class com.datastax.oss.dsbulk.workflow.commons.policies.retry.MultipleRetryPolicy

Deprecated.

onExecutionFailed(BulkExecutionException, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onExecutionFailed(BulkExecutionException, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onExecutionFailed(BulkExecutionException, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a statement execution has failed.

onExecutionFailed(BulkExecutionException, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

onExecutionStarted(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onExecutionStarted(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onExecutionStarted(Statement<?>, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a statement is about to be executed.

onExecutionSuccessful(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onExecutionSuccessful(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onExecutionSuccessful(Statement<?>, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a statement has been successfully executed.

onExecutionSuccessful(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

onReadRequestFailed(Statement<?>, Throwable, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onReadRequestFailed(Statement<?>, Throwable, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onReadRequestFailed(Statement<?>, Throwable, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a read request has failed.

onReadRequestFailed(Statement<?>, Throwable, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

onReadRequestStarted(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onReadRequestStarted(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onReadRequestStarted(Statement<?>, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a read request is about to be sent.

onReadRequestStarted(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

onReadRequestSuccessful(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onReadRequestSuccessful(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onReadRequestSuccessful(Statement<?>, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a read request has been completed successfully.

onReadRequestSuccessful(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

onReadTimeout(Request, ConsistencyLevel, int, int, boolean, int) - Method in class com.datastax.oss.dsbulk.workflow.commons.policies.retry.MultipleRetryPolicy

Deprecated.

onRequestAborted(Request, Throwable, int) - Method in class com.datastax.oss.dsbulk.workflow.commons.policies.retry.MultipleRetryPolicy

Deprecated.

onRowReceived(Row, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onRowReceived(Row, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onRowReceived(Row, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a row has been successfully received.

onRowReceived(Row, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

onUnavailable(Request, ConsistencyLevel, int, int, int) - Method in class com.datastax.oss.dsbulk.workflow.commons.policies.retry.MultipleRetryPolicy

Deprecated.

onWriteRequestFailed(Statement<?>, Throwable, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onWriteRequestFailed(Statement<?>, Throwable, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onWriteRequestFailed(Statement<?>, Throwable, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a write request has failed.

onWriteRequestFailed(Statement<?>, Throwable, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

onWriteRequestStarted(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onWriteRequestStarted(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onWriteRequestStarted(Statement<?>, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a write request is about to be sent.

onWriteRequestStarted(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

onWriteRequestSuccessful(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListener

onWriteRequestSuccessful(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.CompositeExecutionListener

onWriteRequestSuccessful(Statement<?>, ExecutionContext) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionListener

Called when a write request has been completed successfully.

onWriteRequestSuccessful(Statement<?>, ExecutionContext) - Method in class com.datastax.oss.dsbulk.executor.api.listener.MetricsCollectingExecutionListener

onWriteTimeout(Request, ConsistencyLevel, WriteType, int, int, int) - Method in class com.datastax.oss.dsbulk.workflow.commons.policies.retry.MultipleRetryPolicy

Deprecated.

openConnection(URL) - Method in class com.datastax.oss.dsbulk.url.StdinStdoutURLStreamHandler

OperationDirectory - Class in com.datastax.oss.dsbulk.workflow.api.log

OperationDirectory() - Constructor for class com.datastax.oss.dsbulk.workflow.api.log.OperationDirectory

OperationDirectoryResolver - Class in com.datastax.oss.dsbulk.workflow.api.log

OperationDirectoryResolver(Path, String) - Constructor for class com.datastax.oss.dsbulk.workflow.api.log.OperationDirectoryResolver

ORIGIN_COMPARATOR - Static variable in class com.datastax.oss.dsbulk.config.model.SettingsGroupFactory

A comparator for configuration entries that preserves the original order in which they are found in the configuration file.

OVERFLOW_STRATEGY - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

OverflowStrategy - Enum in com.datastax.oss.dsbulk.codecs.api.util

A strategy to apply in case of overflow.

P

parse(String) - Method in class com.datastax.oss.dsbulk.codecs.api.ConvertingCodec

parse(String) - Method in class com.datastax.oss.dsbulk.codecs.api.format.binary.Base64BinaryFormat

parse(String) - Method in interface com.datastax.oss.dsbulk.codecs.api.format.binary.BinaryFormat

Parses the given string as a ByteBuffer.

parse(String) - Method in class com.datastax.oss.dsbulk.codecs.api.format.binary.HexBinaryFormat

parse(String, ParsePosition) - Method in class com.datastax.oss.dsbulk.codecs.api.format.number.ExactNumberFormat

parse(String, ParsePosition) - Method in class com.datastax.oss.dsbulk.codecs.api.format.number.ToStringNumberFormat

parse(String) - Method in class com.datastax.oss.dsbulk.codecs.api.format.temporal.NumericTemporalFormat

parse(String) - Method in class com.datastax.oss.dsbulk.codecs.api.format.temporal.SimpleTemporalFormat

parse(String) - Method in interface com.datastax.oss.dsbulk.codecs.api.format.temporal.TemporalFormat

Parses the given string as a temporal.

parse(String) - Method in class com.datastax.oss.dsbulk.codecs.api.format.temporal.ZonedTemporalFormat

parse() - Method in class com.datastax.oss.dsbulk.runner.cli.CommandLineParser

parseByteBuffer(String) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Parses the given string as a ByteBuffer.

parseDateRange(String) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Parses the given string as a DateRange.

ParsedCommandLine - Class in com.datastax.oss.dsbulk.runner.cli

ParseException - Exception in com.datastax.oss.dsbulk.runner.cli

Simple exception indicating that the command line parsing failed.

ParseException(String) - Constructor for exception com.datastax.oss.dsbulk.runner.cli.ParseException

ParseException(String, Throwable) - Constructor for exception com.datastax.oss.dsbulk.runner.cli.ParseException

parseGeometry(String) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToGeometryCodec

parseGeometry(byte[]) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToGeometryCodec

parseGeometry(String) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToLineStringCodec

parseGeometry(byte[]) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToLineStringCodec

parseGeometry(String) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToPointCodec

parseGeometry(byte[]) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToPointCodec

parseGeometry(String) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToPolygonCodec

parseGeometry(byte[]) - Method in class com.datastax.oss.dsbulk.codecs.text.json.dse.JsonNodeToPolygonCodec

parseLineString(String) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Parses the given string as a LineString.

parseLocale(String) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

parseNumber(String, NumberFormat, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<? extends Number>) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Parses the given string as a number.

parseNumber(String, NumberFormat) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Parses the given string using the given NumberFormat.

parsePoint(String) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Parses the given string as a Point.

parsePolygon(String) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Parses the given string as a Polygon.

parseUUID(String, ConvertingCodec<String, Instant>, TimeUUIDGenerator) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Parses the given string as a UUID.

partition(int) - Method in class com.datastax.oss.dsbulk.partitioner.PartitionGenerator

Partitions the entire ring into approximately splitCount splits.

PartitionGenerator - Class in com.datastax.oss.dsbulk.partitioner

PartitionGenerator(CqlIdentifier, TokenMap, BulkTokenFactory) - Constructor for class com.datastax.oss.dsbulk.partitioner.PartitionGenerator

PasswordPrompter - Class in com.datastax.oss.dsbulk.workflow.commons.settings

A ConfigPostProcessor that detects missing password settings and attempts to prompt for them, if standard input is available.

PasswordPrompter() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.PasswordPrompter

pattern - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

pid() - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.PlatformUtils

Returns this process ID, if available.

PlatformUtils - Class in com.datastax.oss.dsbulk.workflow.api.utils

PlatformUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.api.utils.PlatformUtils

plural() - Method in enum com.datastax.oss.dsbulk.workflow.commons.settings.RowType

PositionsTracker - Class in com.datastax.oss.dsbulk.workflow.commons.log

PositionsTracker() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.log.PositionsTracker

postProcess(Config) - Method in interface com.datastax.oss.dsbulk.workflow.api.config.ConfigPostProcessor

Post-process the given Config and return the processed, resulting config – which may be the same object, or a different one.

postProcess(Config) - Method in class com.datastax.oss.dsbulk.workflow.commons.settings.PasswordPrompter

print(Row, RowWriter) - Method in class com.datastax.oss.dsbulk.format.row.RowFormatter

print(BatchStatement, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.BatchStatementPrinter

print(S, StatementWriter, StatementFormatVerbosity) - Method in interface com.datastax.oss.dsbulk.format.statement.StatementPrinter

Prints the given statement, using the given statement writer and the given verbosity level.

print(S, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.StatementPrinterBase

printAndMaybeAddNewLine(String, PrintWriter) - Static method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManagerUtils

printBoundValues(BoundStatement, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.BoundStatementPrinter

printBoundValues(SimpleStatement, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.SimpleStatementPrinter

printBoundValues(S, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.StatementPrinterBase

printDebugInfoAboutCluster(CqlSession) - Static method in class com.datastax.oss.dsbulk.workflow.commons.utils.ClusterInformationUtils

printHeader(Row, RowWriter) - Method in class com.datastax.oss.dsbulk.format.row.RowFormatter

printHeader(S, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.StatementPrinterBase

printHeader(BoundStatement, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.workflow.commons.format.statement.MappedBoundStatementPrinter

printHeader(SimpleStatement, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.workflow.commons.format.statement.MappedSimpleStatementPrinter

printQueryString(BoundStatement, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.BoundStatementPrinter

printQueryString(SimpleStatement, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.SimpleStatementPrinter

printQueryString(S, StatementWriter, StatementFormatVerbosity) - Method in class com.datastax.oss.dsbulk.format.statement.StatementPrinterBase

printValues(Row, RowWriter) - Method in class com.datastax.oss.dsbulk.format.row.RowFormatter

processURLsForRead() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Inspects the list or URLs as loaded by AbstractFileBasedConnector.loadURLs(Config) and determines exactly what files and folders need to be read.

processURLsForWrite() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Inspects the list or URLs as loaded by AbstractFileBasedConnector.loadURLs(Config) and determines if the connector should write to a single file, or to a directory of files.

protocolVersion - Variable in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

protocolVersion() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

Q

QueryInspector - Class in com.datastax.oss.dsbulk.workflow.commons.schema

QueryInspector(String) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

quoteJMXIfNecessary(String) - Static method in class com.datastax.oss.dsbulk.workflow.commons.utils.JMXUtils

Returns the given string quoted with ObjectName.quote(String) if it contains illegal characters; otherwise, returns the original string.

R

RandomBulkTokenFactory - Class in com.datastax.oss.dsbulk.partitioner.random

A BulkTokenFactory for the Random Partitioner.

RandomBulkTokenFactory() - Constructor for class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenFactory

RandomBulkTokenRange - Class in com.datastax.oss.dsbulk.partitioner.random

RandomBulkTokenRange(RandomToken, RandomToken, Set<EndPoint>) - Constructor for class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenRange

RandomTokenRangeSplitter - Class in com.datastax.oss.dsbulk.partitioner.random

RandomTokenRangeSplitter() - Constructor for class com.datastax.oss.dsbulk.partitioner.random.RandomTokenRangeSplitter

range(Token, Token, Set<EndPoint>) - Method in interface com.datastax.oss.dsbulk.partitioner.BulkTokenFactory

Creates a BulkTokenRange for the given start and end tokens.

range(Token, Token, Set<EndPoint>) - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenFactory

range(Token, Token, Set<EndPoint>) - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenFactory

Range - Class in com.datastax.oss.dsbulk.workflow.commons.log

A closed range, that is, an interval defined by two inclusive bounds.

Range(long, long) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.log.Range

Range(long) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.log.Range

rateLimiter - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

RatioErrorThreshold - Class in com.datastax.oss.dsbulk.workflow.api.error

ReactiveBulkExecutor - Interface in com.datastax.oss.dsbulk.executor.api

An execution unit for bulk writes and bulk reads that operates in reactive mode.

ReactiveBulkReader - Interface in com.datastax.oss.dsbulk.executor.api.reader

A reactive execution unit for bulk read operations.

ReactiveBulkWriter - Interface in com.datastax.oss.dsbulk.executor.api.writer

A reactive execution unit for bulk write operations.

ReactiveStatementBatcher - Interface in com.datastax.oss.dsbulk.batcher.api

A StatementBatcher that is also capable of grouping together publishers of statements.

ReactiveStatementBatcherFactory - Interface in com.datastax.oss.dsbulk.batcher.api

ReactorBulkExecutor - Interface in com.datastax.oss.dsbulk.executor.reactor

An execution unit for bulk writes and bulk reads that operates in reactive mode using Reactor.

ReactorBulkExecutorBuilderFactory - Class in com.datastax.oss.dsbulk.executor.reactor

ReactorBulkExecutorBuilderFactory() - Constructor for class com.datastax.oss.dsbulk.executor.reactor.ReactorBulkExecutorBuilderFactory

ReactorBulkReader - Interface in com.datastax.oss.dsbulk.executor.reactor.reader

A reactive execution unit for bulk read operations using Reactor.

ReactorBulkWriter - Interface in com.datastax.oss.dsbulk.executor.reactor.writer

A reactive execution unit for bulk write operations using Reactor.

ReactorStatementBatcher - Class in com.datastax.oss.dsbulk.batcher.reactor

ReactorStatementBatcher() - Constructor for class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

Creates a new ReactorStatementBatcher that produces unlogged batches, operates in partition key mode and uses the latest stable protocol version and the default CodecRegistry instance.

ReactorStatementBatcher(int) - Constructor for class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

Creates a new ReactorStatementBatcher 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).

ReactorStatementBatcher(long) - Constructor for class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

Creates a new ReactorStatementBatcher 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).

ReactorStatementBatcher(int, long) - Constructor for class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

Creates a new ReactorStatementBatcher that produces unlogged batches, operates in partition key mode and uses the latest stable protocol version and the default CodecRegistry instance.

ReactorStatementBatcher(CqlSession) - Constructor for class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

Creates a new ReactorStatementBatcher 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.

ReactorStatementBatcher(CqlSession, BatchMode) - Constructor for class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

Creates a new ReactorStatementBatcher 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.

ReactorStatementBatcher(CqlSession, BatchMode, BatchType, int) - Constructor for class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

Creates a new ReactorStatementBatcher 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.

ReactorStatementBatcher(CqlSession, BatchMode, BatchType, int, long) - Constructor for class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcher

Creates a new ReactorStatementBatcher 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.

ReactorStatementBatcherFactory - Class in com.datastax.oss.dsbulk.batcher.reactor

ReactorStatementBatcherFactory() - Constructor for class com.datastax.oss.dsbulk.batcher.reactor.ReactorStatementBatcherFactory

read() - Method in interface com.datastax.oss.dsbulk.connectors.api.Connector

Reads all records from the datasource in a flow of flows that can be consumed in parallel.

read - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

read() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

readAsync(String, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.AsyncBulkReader

Executes the given read statement asynchronously, notifying the given consumer of every read result.

readAsync(Statement<?>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.AsyncBulkReader

Executes the given read statement asynchronously, notifying the given consumer of every read result.

readAsync(Stream<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.AsyncBulkReader

Executes the given stream of read statements asynchronously, notifying the given consumer of every read result.

readAsync(Iterable<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.AsyncBulkReader

Executes the given stream of read statements asynchronously, notifying the given consumer of every read result.

readAsync(Publisher<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.AsyncBulkReader

Executes the given iterable of read statements asynchronously, notifying the given consumer of every read result.

readAsync(Statement<?>, Consumer<? super ReadResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readAsync(Stream<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readAsync(Iterable<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readAsync(Publisher<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readConcurrency() - Method in interface com.datastax.oss.dsbulk.connectors.api.Connector

Returns the desired read concurrency, that is, how many resources are expected to be read in parallel.

readConcurrency() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

readNext(SynchronousSink<Record>) - Method in interface com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector.RecordReader

Reads the next record and emits the record to the sink, if any.

readPassword(Config, String, Console) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Reads a password from the console, then returns a new Config object containing the password read under the given path.

readReactive(String) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.ReactiveBulkReader

Executes the given read statement reactively.

readReactive(Statement<?>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.ReactiveBulkReader

Executes the given read statement reactively.

readReactive(Stream<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.ReactiveBulkReader

Executes the given stream of read statements reactively.

readReactive(Iterable<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.ReactiveBulkReader

Executes the given iterable of read statements reactively.

readReactive(Publisher<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.ReactiveBulkReader

Executes the given publisher of read statements reactively.

readReactive(Statement<?>) - Method in class com.datastax.oss.dsbulk.executor.reactor.ContinuousReactorBulkExecutor

readReactive(String) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readReactive(Statement<?>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readReactive(Stream<? extends Statement<?>>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readReactive(Iterable<? extends Statement<?>>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readReactive(Publisher<? extends Statement<?>>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readReactive(String) - Method in interface com.datastax.oss.dsbulk.executor.reactor.reader.ReactorBulkReader

Executes the given read statement reactively.

readReactive(Statement<?>) - Method in interface com.datastax.oss.dsbulk.executor.reactor.reader.ReactorBulkReader

Executes the given read statement reactively.

readReactive(Stream<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.reactor.reader.ReactorBulkReader

Executes the given stream of read statements reactively.

readReactive(Iterable<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.reactor.reader.ReactorBulkReader

Executes the given iterable of read statements reactively.

readReactive(Publisher<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.reactor.reader.ReactorBulkReader

Executes the given Flux of read statements reactively.

ReadResult - Interface in com.datastax.oss.dsbulk.executor.api.result

Represents one of the many results of a read operation.

ReadResultCounter - Interface in com.datastax.oss.dsbulk.workflow.commons.schema

ReadResultCounter.CountingUnit - Interface in com.datastax.oss.dsbulk.workflow.commons.schema

ReadResultMapper - Interface in com.datastax.oss.dsbulk.workflow.commons.schema

ReadResultPublisher - Class in com.datastax.oss.dsbulk.executor.api.publisher

A Publisher for ReadResults.

ReadResultPublisher(Statement<?>, CqlSession, boolean) - Constructor for class com.datastax.oss.dsbulk.executor.api.publisher.ReadResultPublisher

Creates a new ReadResultPublisher without ExecutionListener and without throughput regulation.

ReadResultPublisher(Statement<?>, CqlSession, boolean, ExecutionListener, Semaphore, RateLimiter) - Constructor for class com.datastax.oss.dsbulk.executor.api.publisher.ReadResultPublisher

Creates a new ReadResultPublisher.

ReadResultSubscription - Class in com.datastax.oss.dsbulk.executor.api.subscription

ReadResultSubscription(Subscriber<? super ReadResult>, Statement<?>, ExecutionListener, Semaphore, RateLimiter, boolean) - Constructor for class com.datastax.oss.dsbulk.executor.api.subscription.ReadResultSubscription

ReadsAndWritesReportingExecutionListener - Class in com.datastax.oss.dsbulk.executor.api.listener

An ExecutionListener that reports useful metrics about ongoing bulk read and write operations.

ReadsAndWritesReportingExecutionListener() - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.ReadsAndWritesReportingExecutionListener

Creates a default instance of ReadsAndWritesReportingExecutionListener.

ReadsAndWritesReportingExecutionListener(MetricsCollectingExecutionListener) - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.ReadsAndWritesReportingExecutionListener

Creates an instance of ReadsAndWritesReportingExecutionListener using the given delegate.

readSingleFile(URL) - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Reads a single text file accessible through the given URL.

ReadsReportingExecutionListener - Class in com.datastax.oss.dsbulk.executor.api.listener

An ExecutionListener that reports useful metrics about ongoing bulk read operations.

ReadsReportingExecutionListener() - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.ReadsReportingExecutionListener

Creates a default instance of ReadsReportingExecutionListener.

ReadsReportingExecutionListener(MetricsCollectingExecutionListener) - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.ReadsReportingExecutionListener

Creates an instance of ReadsReportingExecutionListener using the given delegate.

readSync(Statement<?>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.BulkReader

readSync(Publisher<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.BulkReader

readSync(String, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.SyncBulkReader

Executes the given read statement synchronously, notifying the given consumer of every read result.

readSync(Statement<?>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.SyncBulkReader

Executes the given read statement synchronously, notifying the given consumer of every read result.

readSync(Stream<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.SyncBulkReader

Executes the given stream of read statements synchronously, notifying the given consumer of every read result.

readSync(Iterable<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.SyncBulkReader

Executes the given stream of read statements synchronously, notifying the given consumer of every read result.

readSync(Publisher<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.reader.SyncBulkReader

Executes the given iterable of read statements asynchronously, notifying the given consumer of every read result.

readSync(Stream<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

readSync(Iterable<? extends Statement<?>>, Consumer<? super ReadResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

Record - Interface in com.datastax.oss.dsbulk.connectors.api

An item read by a Connector, or passed to a connector for writing.

RecordMapper - Interface in com.datastax.oss.dsbulk.workflow.commons.schema

RecordMetadata - Interface in com.datastax.oss.dsbulk.connectors.api

Defines metadata applicable to a record, in particular which field types it contains.

RecordReporter - Class in com.datastax.oss.dsbulk.workflow.commons.metrics

RECURSIVE - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

recursive - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

register(StatementPrinter<S>) - Method in class com.datastax.oss.dsbulk.format.statement.StatementPrinterRegistry

render(CQLRenderMode) - Method in interface com.datastax.oss.dsbulk.mapping.CQLFragment

render(CQLRenderMode) - Method in class com.datastax.oss.dsbulk.mapping.CQLLiteral

render(CQLRenderMode) - Method in class com.datastax.oss.dsbulk.mapping.CQLWord

render(CQLRenderMode) - Method in class com.datastax.oss.dsbulk.mapping.FunctionCall

replicas() - Method in interface com.datastax.oss.dsbulk.partitioner.BulkTokenRange

replicas() - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenRange

replicas() - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenRange

report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>) - Method in class com.datastax.oss.dsbulk.executor.api.listener.ReadsAndWritesReportingExecutionListener

report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>) - Method in class com.datastax.oss.dsbulk.executor.api.listener.ReadsReportingExecutionListener

report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>) - Method in class com.datastax.oss.dsbulk.executor.api.listener.StatementsReportingExecutionListener

report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>) - Method in class com.datastax.oss.dsbulk.executor.api.listener.WritesReportingExecutionListener

report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>) - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.BatchReporter

report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>) - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.ConsoleReporter

report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>) - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MemoryReporter

report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>) - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.RecordReporter

reportFinalMetrics() - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

reportLastLocations() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.LogManager

reportTotals() - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.DefaultReadResultCounter

reportTotals() - Method in interface com.datastax.oss.dsbulk.workflow.commons.schema.ReadResultCounter

request(long) - Method in class com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription

resolve() - Method in class com.datastax.oss.dsbulk.workflow.api.log.OperationDirectoryResolver

resolvePath(String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Resolves the given path.

resolveThreads(String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Resolves the given input as a positive integer representing the number of threads to allocate.

resolveURL(String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Resolves the given URL.

resolveUserHome(String) - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Resolves a path starting with "~" against the current user's home directory.

resourceCount - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Result - Interface in com.datastax.oss.dsbulk.executor.api.result

Common superinterface for ReadResult and WriteResult.

ResultSubscription<R extends Result,P extends AsyncPagingIterable<Row,P>> - Class in com.datastax.oss.dsbulk.executor.api.subscription

A single-subscriber subscription that executes the provided Statement with the provided CqlSession and emits all the rows returned by the query to its Subscriber.

retainRecordSources - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

roots - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

round(Duration, TimeUnit) - Static method in class com.datastax.oss.dsbulk.workflow.api.utils.DurationUtils

Rounds the given duration to the given time unit.

ROUNDING_MODE - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

RowFormatter - Class in com.datastax.oss.dsbulk.format.row

A component to format instances of Row.

RowFormatter() - Constructor for class com.datastax.oss.dsbulk.format.row.RowFormatter

Creates a row formatter with default settings.

RowFormatter(int, int) - Constructor for class com.datastax.oss.dsbulk.format.row.RowFormatter

Creates a row formatter with customized settings.

RowType - Enum in com.datastax.oss.dsbulk.workflow.commons.settings

RowWriter - Class in com.datastax.oss.dsbulk.format.row

This class exposes utility methods to help in formatting a row.

run() - Method in class com.datastax.oss.dsbulk.runner.CleanupThread

run() - Method in class com.datastax.oss.dsbulk.runner.DataStaxBulkLoader

run() - Method in class com.datastax.oss.dsbulk.runner.WorkflowThread

S

sampleReads(Iterable<Row>) - Static method in class com.datastax.oss.dsbulk.sampler.DataSizeSampler

sampleWrites(AttachmentPoint, Iterable<Statement<?>>) - Static method in class com.datastax.oss.dsbulk.sampler.DataSizeSampler

scanRootDirectory(Path) - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

Scans a directory for readable files and returns the files found as a stream.

SchemaGenerationStrategy - Enum in com.datastax.oss.dsbulk.workflow.commons.settings

SchemaSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

SchemaSettings(Config, SchemaGenerationStrategy) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.SchemaSettings

SectionHelpRequestException - Exception in com.datastax.oss.dsbulk.runner.cli

Simple exception indicating that the user wants the help for a particular section.

SectionHelpRequestException(String, String) - Constructor for exception com.datastax.oss.dsbulk.runner.cli.SectionHelpRequestException

serialConsistencyLevel - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

session - Variable in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher

session - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutor

session - Variable in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

setAllowExtraFields(boolean) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

setAllowMissingFields(boolean) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

setAttribute(Object, Object) - Method in class com.datastax.oss.dsbulk.executor.api.listener.DefaultExecutionContext

setAttribute(Object, Object) - Method in interface com.datastax.oss.dsbulk.executor.api.listener.ExecutionContext

Sets an attribute into this context.

setBinaryFormat(BinaryFormat) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

The BinaryFormat to use for conversions between String and CQL blob.

setBooleanInputWords(Map<String, Boolean>) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

Specify how strings map to true and false.

setBooleanNumbers(BigDecimal, BigDecimal) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

Sets how numbers are mapped to boolean values.

setBooleanOutputWords(Map<Boolean, String>) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

Specify how true and false map to strings.

setBytesUnsafe(int, ByteBuffer) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setConsistencyLevel(ConsistencyLevel) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setConsistencyLevel(ConsistencyLevel) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setCurrentOperationDirectory(Path) - Static method in class com.datastax.oss.dsbulk.workflow.api.log.OperationDirectory

setCustomPayload(Map<String, ByteBuffer>) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setCustomPayload(Map<String, ByteBuffer>) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setDateFormat(String) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

The temporal pattern to use for String to CQL date conversion.

setEpoch(ZonedDateTime) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

This setting applies only to CQL timestamp columns, and USING TIMESTAMP clauses in queries.

setExecutionProfile(DriverExecutionProfile) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setExecutionProfile(DriverExecutionProfile) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setExecutionProfileName(String) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setExecutionProfileName(String) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setExitStatus(ExitStatus) - Method in class com.datastax.oss.dsbulk.runner.WorkflowThread

setFieldValue(Field, Object) - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

Sets the value associated with the given field.

setFormatNumbers(boolean) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

Whether or not to use the numeric pattern to format numeric output.

setGeoFormat(GeoFormat) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

The GeoFormat to use for conversions between String and CQL blob.

setIdempotent(Boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setIdempotent(Boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setKeyspace(CqlIdentifier) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setLocale(Locale) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

Sets the locale to use for locale-sensitive conversions.

setLower(long) - Method in class com.datastax.oss.dsbulk.workflow.commons.log.Range

setNamedValuesWithIds(Map<CqlIdentifier, Object>) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setNode(Node) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setNode(Node) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setNormal() - Static method in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

setNullStrings(List<String>) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

Comma-separated list of case-sensitive strings that should be mapped to null.

setNullStrings(String...) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

Comma-separated list of case-sensitive strings that should be mapped to null.

setNumberFormat(String) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

The numeric pattern to use for conversions between String and CQL numeric types.

setObjectMapper(ObjectMapper) - Method in class com.datastax.oss.dsbulk.codecs.text.TextConversionContext

setOverflowStrategy(OverflowStrategy) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

The overflow strategy to apply.

setPageSize(int) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setPageSize(int) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setPagingState(ByteBuffer) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setPagingState(ByteBuffer) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setPositionalValues(List<Object>) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setQuery(String) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setQueryTimestamp(long) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setQueryTimestamp(long) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setQuiet() - Static method in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

setRoundingMode(RoundingMode) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

The rounding strategy to use for conversions from CQL numeric types to String.

setRoutingKey(ByteBuffer) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setRoutingKey(ByteBuffer) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setRoutingKeyspace(CqlIdentifier) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setRoutingKeyspace(CqlIdentifier) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setRoutingToken(Token) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setRoutingToken(Token) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setSerialConsistencyLevel(ConsistencyLevel) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setSerialConsistencyLevel(ConsistencyLevel) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setTimeFormat(String) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

The temporal pattern to use for String to CQL time conversion.The default is HH:mm:ss.

setTimeout(Duration) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setTimeout(Duration) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setTimestampFormat(String) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

The temporal pattern to use for String to CQL timestamp conversion.

setTimeUnit(TimeUnit) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

This setting applies only to CQL timestamp columns, and USING TIMESTAMP clauses in queries.

setTimeUUIDGenerator(TimeUUIDGenerator) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

Strategy to use when generating time-based (version 1) UUIDs from timestamps.

setTimeZone(ZoneId) - Method in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

Sets the time zone to use for temporal conversions.

SettingsGroup - Interface in com.datastax.oss.dsbulk.config.model

Encapsulates a group of settings that should be rendered together.

SettingsGroupFactory - Class in com.datastax.oss.dsbulk.config.model

SettingsGroupFactory() - Constructor for class com.datastax.oss.dsbulk.config.model.SettingsGroupFactory

SettingsManager - Class in com.datastax.oss.dsbulk.workflow.commons.settings

SettingsManager(Config) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.SettingsManager

setTracing(boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

setTracing(boolean) - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedSimpleStatement

setUpper(long) - Method in class com.datastax.oss.dsbulk.workflow.commons.log.Range

setVerbose() - Static method in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

ShortcutsFactory - Class in com.datastax.oss.dsbulk.config.shortcuts

ShortcutsFactory() - Constructor for class com.datastax.oss.dsbulk.config.shortcuts.ShortcutsFactory

SimpleNodeFilter - Class in com.datastax.oss.dsbulk.workflow.commons.policies.lbp

DSSBulk's default node filter.

SimpleNodeFilter(DriverContext, String) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.policies.lbp.SimpleNodeFilter

Constructor required by the driver to create an instance of this filter.

SimpleNodeFilter(Set<EndPoint>, Set<EndPoint>) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.policies.lbp.SimpleNodeFilter

SimpleStatementPrinter - Class in com.datastax.oss.dsbulk.format.statement

SimpleStatementPrinter() - Constructor for class com.datastax.oss.dsbulk.format.statement.SimpleStatementPrinter

SimpleTemporalFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.temporal

A generic temporal format.

SimpleTemporalFormat(DateTimeFormatter) - Constructor for class com.datastax.oss.dsbulk.codecs.api.format.temporal.SimpleTemporalFormat

SimpleTemporalFormat(DateTimeFormatter, DateTimeFormatter) - Constructor for class com.datastax.oss.dsbulk.codecs.api.format.temporal.SimpleTemporalFormat

singleWriter - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

singular() - Method in enum com.datastax.oss.dsbulk.workflow.commons.settings.RowType

size() - Method in class com.datastax.oss.dsbulk.executor.api.histogram.HdrHistogramReservoir

size() - Method in interface com.datastax.oss.dsbulk.partitioner.BulkTokenRange

size() - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenRange

size() - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenRange

size() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.MappedBoundStatement

SKIP_RECORDS - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

skipRecords - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

SNAPPY_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

sortFieldsByIndex(Multimap<MappingField, CQLFragment>) - Static method in class com.datastax.oss.dsbulk.mapping.MappingInspector

split(BulkTokenRange, int) - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3TokenRangeSplitter

split(BulkTokenRange, int) - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomTokenRangeSplitter

split(Iterable<BulkTokenRange>, int) - Method in interface com.datastax.oss.dsbulk.partitioner.TokenRangeSplitter

Splits the given ranges uniformly into (smaller) splitCount chunks.

split(BulkTokenRange, int) - Method in interface com.datastax.oss.dsbulk.partitioner.TokenRangeSplitter

Splits the given token range uniformly into sub-ranges with the given desired split count.

splitter() - Method in interface com.datastax.oss.dsbulk.partitioner.BulkTokenFactory

Returns a TokenRangeSplitter for the type of tokens managed by this token factory.

splitter() - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenFactory

splitter() - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenFactory

SslHandlerFactoryFactory - Class in com.datastax.oss.dsbulk.workflow.commons.ssl

SslHandlerFactoryFactory() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.ssl.SslHandlerFactoryFactory

STACK_TRACE_PRINTER_OPTIONS - Static variable in class com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings

The options for stack trace printing.

standaloneDriverReference() - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Creates a resolved config containing only the driver settings that DSBulk overrides.

standaloneDSBulkReference() - Static method in class com.datastax.oss.dsbulk.config.ConfigUtils

Creates a resolved config containing only DSBulk settings.

STANDARD_STREAM_PROTOCOL - Static variable in class com.datastax.oss.dsbulk.url.StdinStdoutURLStreamHandlerProvider

The protocol for standard input and standard output URLs.

STAR - Static variable in class com.datastax.oss.dsbulk.mapping.MappingInspector

start() - Method in class com.datastax.oss.dsbulk.executor.api.listener.DefaultExecutionContext

start(Callable<CompletionStage<? extends P>>) - Method in class com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription

Must be called immediately after Subscriber.onSubscribe(Subscription).

start() - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

StatementBatcher - Interface in com.datastax.oss.dsbulk.batcher.api

A component that groups statements together in batches sharing the same partition key or replica set.

StatementFormatter - Class in com.datastax.oss.dsbulk.format.statement

A component to format instances of Statement.

StatementFormatter.Builder - Class in com.datastax.oss.dsbulk.format.statement

Helper class to build StatementFormatter instances with a fluent API.

StatementFormatterLimits - Class in com.datastax.oss.dsbulk.format.statement

A set of user-defined limitation rules that printers should strive to comply with when formatting statements.

StatementFormatterSymbols - Class in com.datastax.oss.dsbulk.format.statement

StatementFormatterSymbols() - Constructor for class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

StatementFormatVerbosity - Enum in com.datastax.oss.dsbulk.format.statement

The desired statement format verbosity.

StatementPrinter<S extends Statement> - Interface in com.datastax.oss.dsbulk.format.statement

A statement printer is responsible for printing a specific type of statement, with a given verbosity level, and using a given statement writer.

StatementPrinterBase<S extends Statement<S>> - Class in com.datastax.oss.dsbulk.format.statement

A common parent class for StatementPrinter implementations.

StatementPrinterBase() - Constructor for class com.datastax.oss.dsbulk.format.statement.StatementPrinterBase

StatementPrinterRegistry - Class in com.datastax.oss.dsbulk.format.statement

A registry for statement printers.

statementsCount - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

StatementsReportingExecutionListener - Class in com.datastax.oss.dsbulk.executor.api.listener

An ExecutionListener that reports useful metrics about executed statements.

StatementsReportingExecutionListener() - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.StatementsReportingExecutionListener

Creates a default instance of StatementsReportingExecutionListener.

StatementsReportingExecutionListener(MetricsCollectingExecutionListener) - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.StatementsReportingExecutionListener

Creates an instance of StatementsReportingExecutionListener using the given delegate.

StatementWriter - Class in com.datastax.oss.dsbulk.format.statement

This class exposes utility methods to help statement printers in formatting a statement.

StatsSettings - Class in com.datastax.oss.dsbulk.workflow.commons.settings

StatsSettings(Config) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.settings.StatsSettings

StatsSettings.StatisticsMode - Enum in com.datastax.oss.dsbulk.workflow.commons.settings

StdinStdoutURLStreamHandler - Class in com.datastax.oss.dsbulk.url

A URLStreamHandler for reading from System.in and writing to System.out.

StdinStdoutURLStreamHandlerProvider - Class in com.datastax.oss.dsbulk.url

StdinStdoutURLStreamHandlerProvider() - Constructor for class com.datastax.oss.dsbulk.url.StdinStdoutURLStreamHandlerProvider

stop() - Method in class com.datastax.oss.dsbulk.executor.api.listener.DefaultExecutionContext

stop() - Method in class com.datastax.oss.dsbulk.workflow.commons.metrics.MetricsManager

StringConvertingCodec<T> - Class in com.datastax.oss.dsbulk.codecs.text.string

StringConvertingCodec(TypeCodec<T>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringConvertingCodec

StringConvertingCodecProvider - Class in com.datastax.oss.dsbulk.codecs.text.string

A specialized DefaultCodecRegistry that is capable of producing ConvertingCodecs.

StringConvertingCodecProvider() - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringConvertingCodecProvider

StringToBigDecimalCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToBigDecimalCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToBigDecimalCodec

StringToBigIntegerCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToBigIntegerCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToBigIntegerCodec

StringToBlobCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToBlobCodec(List<String>, BinaryFormat) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToBlobCodec

StringToBooleanCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToBooleanCodec(Map<String, Boolean>, Map<Boolean, String>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToBooleanCodec

StringToByteCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToByteCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToByteCodec

StringToCollectionCodec<E,C extends Collection<E>> - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToDateRangeCodec - Class in com.datastax.oss.dsbulk.codecs.text.string.dse

StringToDateRangeCodec(List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToDateRangeCodec

StringToDoubleCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToDoubleCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToDoubleCodec

StringToDurationCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToDurationCodec(List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToDurationCodec

StringToFloatCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToFloatCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToFloatCodec

StringToInetAddressCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToInetAddressCodec(List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToInetAddressCodec

StringToInstantCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToInstantCodec(TemporalFormat, ZoneId, ZonedDateTime, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToInstantCodec

StringToIntegerCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToIntegerCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToIntegerCodec

StringToLineStringCodec - Class in com.datastax.oss.dsbulk.codecs.text.string.dse

StringToLineStringCodec(GeoFormat, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToLineStringCodec

StringToListCodec<E> - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToListCodec(ConvertingCodec<JsonNode, List<E>>, ObjectMapper, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToListCodec

StringToLocalDateCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToLocalDateCodec(TemporalFormat, ZoneId, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToLocalDateCodec

StringToLocalTimeCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToLocalTimeCodec(TemporalFormat, ZoneId, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToLocalTimeCodec

StringToLongCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToLongCodec(PrimitiveLongCodec, FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToLongCodec

StringToMapCodec<K,V> - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToMapCodec(ConvertingCodec<JsonNode, Map<K, V>>, ObjectMapper, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToMapCodec

StringToNumberCodec<N extends Number> - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToPointCodec - Class in com.datastax.oss.dsbulk.codecs.text.string.dse

StringToPointCodec(GeoFormat, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToPointCodec

StringToPolygonCodec - Class in com.datastax.oss.dsbulk.codecs.text.string.dse

StringToPolygonCodec(GeoFormat, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.dse.StringToPolygonCodec

StringToSetCodec<E> - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToSetCodec(ConvertingCodec<JsonNode, Set<E>>, ObjectMapper, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToSetCodec

StringToShortCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToShortCodec(FastThreadLocal<NumberFormat>, OverflowStrategy, RoundingMode, TemporalFormat, ZoneId, TimeUnit, ZonedDateTime, Map<String, Boolean>, List<BigDecimal>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToShortCodec

StringToStringCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToStringCodec(TypeCodec<String>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToStringCodec

StringToTemporalCodec<T extends TemporalAccessor> - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToTupleCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToTupleCodec(ConvertingCodec<JsonNode, TupleValue>, ObjectMapper, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToTupleCodec

StringToUDTCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToUDTCodec(ConvertingCodec<JsonNode, UdtValue>, ObjectMapper, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToUDTCodec

StringToUnknownTypeCodec<T> - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToUnknownTypeCodec(TypeCodec<T>, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToUnknownTypeCodec

StringToUUIDCodec - Class in com.datastax.oss.dsbulk.codecs.text.string

StringToUUIDCodec(TypeCodec<UUID>, ConvertingCodec<String, Instant>, TimeUUIDGenerator, List<String>) - Constructor for class com.datastax.oss.dsbulk.codecs.text.string.StringToUUIDCodec

StringUtils - Class in com.datastax.oss.dsbulk.codecs.text.utils

StringUtils() - Constructor for class com.datastax.oss.dsbulk.codecs.text.utils.StringUtils

StringUtils - Class in com.datastax.oss.dsbulk.docs.utils

StringUtils() - Constructor for class com.datastax.oss.dsbulk.docs.utils.StringUtils

StringUtils - Class in com.datastax.oss.dsbulk.runner.utils

StringUtils() - Constructor for class com.datastax.oss.dsbulk.runner.utils.StringUtils

StringUtils - Class in com.datastax.oss.dsbulk.workflow.commons.utils

StringUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.commons.utils.StringUtils

subscribe(Subscriber<? super ReadResult>) - Method in class com.datastax.oss.dsbulk.executor.api.publisher.ContinuousReadResultPublisher

subscribe(Subscriber<? super ReadResult>) - Method in class com.datastax.oss.dsbulk.executor.api.publisher.ReadResultPublisher

subscribe(Subscriber<? super WriteResult>) - Method in class com.datastax.oss.dsbulk.executor.api.publisher.WriteResultPublisher

summaryEnd - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

summaryStart - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

supports(ConnectorFeature) - Method in interface com.datastax.oss.dsbulk.connectors.api.Connector

Whether or not the connector supports the given feature.

supports(ConnectorFeature) - Method in class com.datastax.oss.dsbulk.connectors.csv.CSVConnector

supports(ConnectorFeature) - Method in class com.datastax.oss.dsbulk.connectors.json.JsonConnector

SyncBulkExecutor - Interface in com.datastax.oss.dsbulk.executor.api

An execution unit for bulk writes and bulk reads that operates in synchronous mode.

SyncBulkReader - Interface in com.datastax.oss.dsbulk.executor.api.reader

An asynchronous execution unit for bulk read operations.

SyncBulkWriter - Interface in com.datastax.oss.dsbulk.executor.api.writer

A synchronous execution unit for bulk write operations.

T

TemporalConvertingCodecsProvider - Class in com.datastax.oss.dsbulk.codecs.jdk.temporal

TemporalConvertingCodecsProvider() - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.temporal.TemporalConvertingCodecsProvider

TemporalFormat - Interface in com.datastax.oss.dsbulk.codecs.api.format.temporal

A small wrapper around DateTimeFormatter that allows to use different formats when parsing and formatting.

temporalToNumber(TemporalAccessor) - Method in class com.datastax.oss.dsbulk.codecs.api.format.temporal.NumericTemporalFormat

TemporalToTemporalCodec<EXTERNAL extends TemporalAccessor,INTERNAL extends TemporalAccessor> - Class in com.datastax.oss.dsbulk.codecs.jdk.temporal

TemporalToTemporalCodec(Class<EXTERNAL>, TypeCodec<INTERNAL>, ZoneId, ZonedDateTime) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.temporal.TemporalToTemporalCodec

TemporalToUUIDCodec<EXTERNAL extends TemporalAccessor> - Class in com.datastax.oss.dsbulk.codecs.jdk.temporal

TemporalToUUIDCodec(TypeCodec<UUID>, TemporalToTemporalCodec<EXTERNAL, Instant>, TimeUUIDGenerator) - Constructor for class com.datastax.oss.dsbulk.codecs.jdk.temporal.TemporalToUUIDCodec

test(BatchableStatement<?>) - Method in class com.datastax.oss.dsbulk.batcher.api.DefaultStatementBatcher.AdaptiveSizingBatchPredicate

test(Node) - Method in class com.datastax.oss.dsbulk.workflow.commons.policies.lbp.SimpleNodeFilter

TextConversionContext - Class in com.datastax.oss.dsbulk.codecs.text

TextConversionContext() - Constructor for class com.datastax.oss.dsbulk.codecs.text.TextConversionContext

thresholdAsString() - Method in class com.datastax.oss.dsbulk.workflow.api.error.AbsoluteErrorThreshold

thresholdAsString() - Method in interface com.datastax.oss.dsbulk.workflow.api.error.ErrorThreshold

Returns a textual description of this threshold, mainly for informational purposes, e.g.

thresholdAsString() - Method in class com.datastax.oss.dsbulk.workflow.api.error.RatioErrorThreshold

thresholdAsString() - Method in class com.datastax.oss.dsbulk.workflow.api.error.UnlimitedErrorThreshold

ThrowableUtils - Class in com.datastax.oss.dsbulk.workflow.api.utils

ThrowableUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.api.utils.ThrowableUtils

TIME_PATTERN - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

TIME_UNIT - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

TIME_UUID_GENERATOR - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

TIME_ZONE - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

timeout - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

timestamp - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

TIMESTAMP_FORMAT - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

TIMESTAMP_PATTERN - Static variable in class com.datastax.oss.dsbulk.codecs.api.CommonConversionContext

TimeUUIDGenerator - Enum in com.datastax.oss.dsbulk.codecs.api.util

This class is loosely inspired by Cassandra's UUIDGen class and by the DataStax Java driver's UUIDs class.

toBigDecimal(Number) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number into a BigDecimal.

toBigIntegerExact(Number) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number into a BigInteger, throwing an exception in case of overflow.

toByteValueExact(Number) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number into a Byte, throwing an exception in case of overflow.

toDoubleValueExact(Number) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number into a Double, throwing an exception in case of overflow.

toErrorResult(BulkExecutionException) - Method in class com.datastax.oss.dsbulk.executor.api.subscription.ContinuousReadResultSubscription

toFloatValueExact(Number) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number into a Float, throwing an exception in case of overflow.

toInstant(TemporalAccessor, ZoneId, LocalDate) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given temporal into an Instant.

toIntValueExact(Number) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number into an Integer, throwing an exception in case of overflow.

TokenRangeClusterer - Class in com.datastax.oss.dsbulk.partitioner

Groups small, contiguous token ranges sharing the same replicas in order to reduce the total number of splits.

TokenRangeClusterer(BulkTokenFactory) - Constructor for class com.datastax.oss.dsbulk.partitioner.TokenRangeClusterer

TokenRangeReadStatementGenerator - Class in com.datastax.oss.dsbulk.partitioner

Generates SELECT statements that read the entire table by token ranges.

TokenRangeReadStatementGenerator(RelationMetadata, Metadata) - Constructor for class com.datastax.oss.dsbulk.partitioner.TokenRangeReadStatementGenerator

TokenRangeSplitter - Interface in com.datastax.oss.dsbulk.partitioner

Splits token ranges into smaller sub-ranges.

TokenUtils - Class in com.datastax.oss.dsbulk.partitioner.utils

TokenUtils() - Constructor for class com.datastax.oss.dsbulk.partitioner.utils.TokenUtils

toLocalDate(TemporalAccessor, ZoneId) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given temporal into a LocalDate.

toLocalDateTime(TemporalAccessor, ZoneId, LocalDate) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given temporal into a LocalDateTime.

toLocalTime(TemporalAccessor, ZoneId) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given temporal into a LocalTime.

toLongValueExact(Number) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number into a Long, throwing an exception in case of overflow.

TooManyErrorsException - Exception in com.datastax.oss.dsbulk.workflow.api.error

Thrown when the engine encounters too many errors.

TooManyErrorsException(ErrorThreshold) - Constructor for exception com.datastax.oss.dsbulk.workflow.api.error.TooManyErrorsException

toShortValueExact(Number) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given number into a Short, throwing an exception in case of overflow.

toString() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultIndexedField

toString() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultMappedField

toString() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

toString() - Method in class com.datastax.oss.dsbulk.executor.api.result.DefaultReadResult

toString() - Method in class com.datastax.oss.dsbulk.executor.api.result.DefaultWriteResult

toString() - Method in class com.datastax.oss.dsbulk.format.row.RowWriter

toString() - Method in class com.datastax.oss.dsbulk.format.statement.StatementWriter

toString() - Method in class com.datastax.oss.dsbulk.mapping.CQLLiteral

toString() - Method in class com.datastax.oss.dsbulk.mapping.CQLWord

toString() - Method in class com.datastax.oss.dsbulk.mapping.FunctionCall

toString() - Method in class com.datastax.oss.dsbulk.workflow.commons.log.Range

toString() - Method in class com.datastax.oss.dsbulk.workflow.commons.statement.UnmappableStatement

toString() - Method in class com.datastax.oss.dsbulk.workflow.count.CountWorkflow

toString() - Method in class com.datastax.oss.dsbulk.workflow.load.LoadWorkflow

toString() - Method in class com.datastax.oss.dsbulk.workflow.unload.UnloadWorkflow

ToStringNumberFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.number

A NumberFormat that bypasses the formatting pattern and simply calls Object.toString().

ToStringNumberFormat(NumberFormat) - Constructor for class com.datastax.oss.dsbulk.codecs.api.format.number.ToStringNumberFormat

TOTAL_TOKEN_COUNT - Static variable in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenFactory

TOTAL_TOKEN_COUNT - Static variable in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenFactory

totalTokenCount() - Method in interface com.datastax.oss.dsbulk.partitioner.BulkTokenFactory

totalTokenCount() - Method in class com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenFactory

totalTokenCount() - Method in class com.datastax.oss.dsbulk.partitioner.random.RandomBulkTokenFactory

toUUIDTimestamp(Instant) - Static method in enum com.datastax.oss.dsbulk.codecs.api.util.TimeUUIDGenerator

toZonedDateTime(TemporalAccessor, ZoneId, LocalDate) - Static method in class com.datastax.oss.dsbulk.codecs.api.util.CodecUtils

Converts the given temporal into a ZonedDateTime.

truncatedOutput - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

TTL - Static variable in class com.datastax.oss.dsbulk.mapping.MappingInspector

U

ucfirst(String) - Static method in class com.datastax.oss.dsbulk.docs.utils.StringUtils

Upper-cases the first letter of the given string

UncloseableInputStream - Class in com.datastax.oss.dsbulk.url

An input stream that cannot be closed.

UncloseableInputStream(InputStream) - Constructor for class com.datastax.oss.dsbulk.url.UncloseableInputStream

UncloseableOutputStream - Class in com.datastax.oss.dsbulk.url

An output stream that cannot be closed.

UncloseableOutputStream(OutputStream) - Constructor for class com.datastax.oss.dsbulk.url.UncloseableOutputStream

UNLIMITED - Static variable in class com.datastax.oss.dsbulk.format.row.RowFormatter

A special value that conveys the notion of "unlimited".

UNLIMITED - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterLimits

A special value that conveys the notion of "unlimited".

unlimited() - Static method in interface com.datastax.oss.dsbulk.workflow.api.error.ErrorThreshold

Creates an ErrorThreshold that cannot be exceeded.

UnlimitedErrorThreshold - Class in com.datastax.oss.dsbulk.workflow.api.error

UnloadWorkflow - Class in com.datastax.oss.dsbulk.workflow.unload

The main class for unload workflows.

UnloadWorkflowProvider - Class in com.datastax.oss.dsbulk.workflow.unload

UnloadWorkflowProvider() - Constructor for class com.datastax.oss.dsbulk.workflow.unload.UnloadWorkflowProvider

UnmappableStatement - Class in com.datastax.oss.dsbulk.workflow.commons.statement

UnmappableStatement(Record, Throwable) - Constructor for class com.datastax.oss.dsbulk.workflow.commons.statement.UnmappableStatement

unsetPrimaryKey(CQLWord) - Static method in exception com.datastax.oss.dsbulk.workflow.commons.schema.InvalidMappingException

unsetValue - Static variable in class com.datastax.oss.dsbulk.format.statement.StatementFormatterSymbols

update(long) - Method in class com.datastax.oss.dsbulk.executor.api.histogram.HdrHistogramReservoir

update(URI, long) - Method in class com.datastax.oss.dsbulk.workflow.commons.log.PositionsTracker

update(ReadResult) - Method in interface com.datastax.oss.dsbulk.workflow.commons.schema.ReadResultCounter.CountingUnit

URL - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

URLFILE - Static variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

urls - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

URLStreamHandlerProvider - Interface in com.datastax.oss.dsbulk.url

A provider for URLStreamHandler instances.

V

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.batcher.api.BatchMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.codecs.api.util.OverflowStrategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.codecs.api.util.TimeUUIDGenerator

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.connectors.api.CommonConnectorFeature

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.format.statement.StatementFormatVerbosity

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.mapping.CQLRenderMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.mapping.MappingPreference

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.runner.ExitStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.BulkDriverOption

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings.Verbosity

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.RowType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.SchemaGenerationStrategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.StatsSettings.StatisticsMode

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.datastax.oss.dsbulk.batcher.api.BatchMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.codecs.api.util.OverflowStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.codecs.api.util.TimeUUIDGenerator

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.connectors.api.CommonConnectorFeature

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultErrorRecord

values() - Method in class com.datastax.oss.dsbulk.connectors.api.DefaultRecord

values() - Method in interface com.datastax.oss.dsbulk.connectors.api.Record

Returns a collection containing all the values in this record.

values() - Static method in enum com.datastax.oss.dsbulk.format.statement.StatementFormatVerbosity

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.mapping.CQLRenderMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.mapping.MappingPreference

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.runner.ExitStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.BulkDriverOption

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.LogSettings.Verbosity

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.RowType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.SchemaGenerationStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.datastax.oss.dsbulk.workflow.commons.settings.StatsSettings.StatisticsMode

Returns an array containing the constants of this enum type, in the order they are declared.

variables() - Method in class com.datastax.oss.dsbulk.mapping.DefaultMapping

variables() - Method in interface com.datastax.oss.dsbulk.mapping.Mapping

Returns all the variables in this mapping.

variableToFields(CQLWord) - Method in class com.datastax.oss.dsbulk.mapping.DefaultMapping

variableToFields(CQLWord) - Method in interface com.datastax.oss.dsbulk.mapping.Mapping

Maps the given row variable to one or more fields in a record.

VersionRequestException - Exception in com.datastax.oss.dsbulk.runner.cli

Simple exception indicating that the user wants to know the version of the tool.

VersionRequestException() - Constructor for exception com.datastax.oss.dsbulk.runner.cli.VersionRequestException

visitAllowedFunctionName(CqlParser.AllowedFunctionNameContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitBatchStatement(CqlParser.BatchStatementContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitCfName(CqlParser.CfNameContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitCident(CqlParser.CidentContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitColumnFamilyName(CqlParser.ColumnFamilyNameContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitColumnName(MappingParser.ColumnNameContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitColumnOperationDifferentiator(CqlParser.ColumnOperationDifferentiatorContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitDeleteStatement(CqlParser.DeleteStatementContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitField(MappingParser.FieldContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitFieldOrFunction(MappingParser.FieldOrFunctionContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitFunction(MappingParser.FunctionContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitFunction(CqlParser.FunctionContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitFunctionArg(MappingParser.FunctionArgContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitFunctionName(MappingParser.FunctionNameContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitIdentifier(MappingParser.IdentifierContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitIndex(MappingParser.IndexContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitIndexedEntry(MappingParser.IndexedEntryContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitIndexOrFunction(MappingParser.IndexOrFunctionContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitInferredMappedEntry(MappingParser.InferredMappedEntryContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitInsertStatement(CqlParser.InsertStatementContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitJsonInsertStatement(CqlParser.JsonInsertStatementContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitKeyspaceName(MappingParser.KeyspaceNameContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitKeyspaceName(CqlParser.KeyspaceNameContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitKsName(CqlParser.KsNameContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitLiteral(MappingParser.LiteralContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitMapping(MappingParser.MappingContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitNoncolIdent(CqlParser.NoncolIdentContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitNormalInsertStatement(CqlParser.NormalInsertStatementContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitRegularMappedEntry(MappingParser.RegularMappedEntryContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitRelation(CqlParser.RelationContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitSelectClause(CqlParser.SelectClauseContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitSelector(CqlParser.SelectorContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitSelectStatement(CqlParser.SelectStatementContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitSimpleEntry(MappingParser.SimpleEntryContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitTerm(CqlParser.TermContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitTtl(MappingParser.TtlContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitUnaliasedSelector(CqlParser.UnaliasedSelectorContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitUpdateStatement(CqlParser.UpdateStatementContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitUsingClauseDelete(CqlParser.UsingClauseDeleteContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitUsingClauseObjective(CqlParser.UsingClauseObjectiveContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitValue(CqlParser.ValueContext) - Method in class com.datastax.oss.dsbulk.workflow.commons.schema.QueryInspector

visitVariable(MappingParser.VariableContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitVariableOrFunction(MappingParser.VariableOrFunctionContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

visitWritetime(MappingParser.WritetimeContext) - Method in class com.datastax.oss.dsbulk.mapping.MappingInspector

W

wasApplied() - Method in class com.datastax.oss.dsbulk.executor.api.result.DefaultWriteResult

wasApplied() - Method in class com.datastax.oss.dsbulk.executor.api.result.EmptyWriteResult

wasApplied() - Method in interface com.datastax.oss.dsbulk.executor.api.result.WriteResult

If the query that produced this result was a conditional update, returns whether the conditional update could be successfully applied.

WellKnownBinaryGeoFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.geo

WellKnownTextGeoFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.geo

withExecutionListener(ExecutionListener) - Method in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

withExecutionListener(ExecutionListener) - Method in interface com.datastax.oss.dsbulk.executor.api.BulkExecutorBuilder

Sets an optional ExecutionListener.

withLogSink(LogSink) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListenerBuilder

Use the given LogSink to log messages.

withMaxBoundValueLength(int) - Method in class com.datastax.oss.dsbulk.format.statement.StatementFormatter.Builder

Sets the maximum length, in numbers of printed characters, allowed for a single bound value.

withMaxBoundValues(int) - Method in class com.datastax.oss.dsbulk.format.statement.StatementFormatter.Builder

Sets the maximum number of printed bound values.

withMaxInFlightRequests(int) - Method in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

withMaxInFlightRequests(int) - Method in interface com.datastax.oss.dsbulk.executor.api.BulkExecutorBuilder

Sets the maximum number of in-flight requests.

withMaxInnerStatements(int) - Method in class com.datastax.oss.dsbulk.format.statement.StatementFormatter.Builder

Sets the maximum number of printed inner statements of a BatchStatement.

withMaxQueryStringLength(int) - Method in class com.datastax.oss.dsbulk.format.statement.StatementFormatter.Builder

Sets the maximum length allowed for query strings.

withMaxRequestsPerSecond(int) - Method in class com.datastax.oss.dsbulk.executor.api.AbstractBulkExecutorBuilder

withMaxRequestsPerSecond(int) - Method in interface com.datastax.oss.dsbulk.executor.api.BulkExecutorBuilder

Sets the maximum number of concurrent requests per second.

withScheduler(ScheduledExecutorService) - Method in class com.datastax.oss.dsbulk.executor.api.listener.AbstractMetricsReportingExecutionListenerBuilder

Use the given scheduler to schedule periodic reports.

Workflow - Interface in com.datastax.oss.dsbulk.workflow.api

Defines a pipeline of transformations to apply.

WorkflowProvider - Interface in com.datastax.oss.dsbulk.workflow.api

A provider for Workflows.

WorkflowThread - Class in com.datastax.oss.dsbulk.runner

A thread responsible for running the workflow.

WorkflowThread(Workflow) - Constructor for class com.datastax.oss.dsbulk.runner.WorkflowThread

WorkflowUtils - Class in com.datastax.oss.dsbulk.workflow.api.utils

WorkflowUtils() - Constructor for class com.datastax.oss.dsbulk.workflow.api.utils.WorkflowUtils

write() - Method in interface com.datastax.oss.dsbulk.connectors.api.Connector

Returns a function that handles writing records to the datasource.

write(Record) - Method in interface com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector.RecordWriter

Writes the record to the destination file, in a thread-safe manner (i.e., this method is never called concurrently).

write() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

writeAsync(String) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

Executes the given write statement asynchronously.

writeAsync(Statement<?>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

Executes the given write statement asynchronously.

writeAsync(Stream<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

Executes the given stream of write statements asynchronously.

writeAsync(Stream<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

Executes the given stream of write statements asynchronously, notifying the given consumer of every write result.

writeAsync(Iterable<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

Executes the given iterable of write statements asynchronously.

writeAsync(Iterable<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

Executes the given iterable of write statements asynchronously, notifying the given consumer of every write result.

writeAsync(Publisher<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

Executes the given flow of write statements asynchronously.

writeAsync(Publisher<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

Executes the given flow of write statements asynchronously, notifying the given consumer of every write result.

writeAsync(Statement<?>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

writeAsync(Stream<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

writeAsync(Iterable<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

writeAsync(Publisher<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

writeConcurrency() - Method in interface com.datastax.oss.dsbulk.connectors.api.Connector

Returns the desired write concurrency, that is, how many resources are expected to be written in parallel.

writeConcurrency() - Method in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

writeReactive(String) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.ReactiveBulkWriter

Executes the given write statement reactively.

writeReactive(Statement<?>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.ReactiveBulkWriter

Executes the given write statement reactively.

writeReactive(Stream<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.ReactiveBulkWriter

Executes the given stream of write statements reactively.

writeReactive(Iterable<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.ReactiveBulkWriter

Executes the given iterable of write statements reactively.

writeReactive(Publisher<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.ReactiveBulkWriter

Executes the given publisher of write statements reactively.

writeReactive(Statement<?>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

writeReactive(Stream<? extends Statement<?>>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

writeReactive(Iterable<? extends Statement<?>>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

writeReactive(Publisher<? extends Statement<?>>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

writeReactive(String) - Method in interface com.datastax.oss.dsbulk.executor.reactor.writer.ReactorBulkWriter

Executes the given write statement reactively.

writeReactive(Statement<?>) - Method in interface com.datastax.oss.dsbulk.executor.reactor.writer.ReactorBulkWriter

Executes the given write statement reactively.

writeReactive(Stream<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.reactor.writer.ReactorBulkWriter

Executes the given stream of write statements reactively.

writeReactive(Iterable<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.reactor.writer.ReactorBulkWriter

Executes the given iterable of write statements reactively.

writeReactive(Publisher<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.reactor.writer.ReactorBulkWriter

Executes the given Flux of write statements reactively.

WriteResult - Interface in com.datastax.oss.dsbulk.executor.api.result

Represents the unique result of a write operation.

WriteResultPublisher - Class in com.datastax.oss.dsbulk.executor.api.publisher

A Publisher for WriteResults.

WriteResultPublisher(Statement<?>, CqlSession, boolean) - Constructor for class com.datastax.oss.dsbulk.executor.api.publisher.WriteResultPublisher

Creates a new WriteResultPublisher without ExecutionListener and without throughput regulation.

WriteResultPublisher(Statement<?>, CqlSession, boolean, ExecutionListener, Semaphore, RateLimiter) - Constructor for class com.datastax.oss.dsbulk.executor.api.publisher.WriteResultPublisher

Creates a new WriteResultPublisher.

WriteResultSubscription - Class in com.datastax.oss.dsbulk.executor.api.subscription

WriteResultSubscription(Subscriber<? super WriteResult>, Statement<?>, ExecutionListener, Semaphore, RateLimiter, boolean) - Constructor for class com.datastax.oss.dsbulk.executor.api.subscription.WriteResultSubscription

writers - Variable in class com.datastax.oss.dsbulk.connectors.commons.AbstractFileBasedConnector

WritesReportingExecutionListener - Class in com.datastax.oss.dsbulk.executor.api.listener

An ExecutionListener that reports useful metrics about ongoing bulk write operations.

WritesReportingExecutionListener() - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.WritesReportingExecutionListener

Creates a default instance of WritesReportingExecutionListener.

WritesReportingExecutionListener(MetricsCollectingExecutionListener) - Constructor for class com.datastax.oss.dsbulk.executor.api.listener.WritesReportingExecutionListener

Creates an instance of WritesReportingExecutionListener using the given delegate.

writeSync(Statement<?>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.BulkWriter

writeSync(Publisher<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.BulkWriter

writeSync(String) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

Executes the given write statement synchronously.

writeSync(Statement<?>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

Executes the given write statement synchronously.

writeSync(Stream<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

Executes the given stream of write statements synchronously.

writeSync(Stream<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

Executes the given stream of write statements synchronously, notifying the given consumer of every write result.

writeSync(Iterable<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

Executes the given iterable of write statements synchronously.

writeSync(Iterable<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

Executes the given iterable of write statements synchronously, notifying the given consumer of every write result.

writeSync(Publisher<? extends Statement<?>>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

Executes the given flow of write statements synchronously.

writeSync(Publisher<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

Executes the given flow of write statements synchronously, notifying the given consumer of every write result.

writeSync(Stream<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

writeSync(Iterable<? extends Statement<?>>, Consumer<? super WriteResult>) - Method in class com.datastax.oss.dsbulk.executor.reactor.DefaultReactorBulkExecutor

WRITETIME - Static variable in class com.datastax.oss.dsbulk.mapping.MappingInspector

WriteTimeCodec<T> - Class in com.datastax.oss.dsbulk.codecs.api.writetime

A special wrapper codec that maps write times to and from an external format.

WriteTimeCodec(ConvertingCodec<T, Instant>) - Constructor for class com.datastax.oss.dsbulk.codecs.api.writetime.WriteTimeCodec

X

XZ_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

Z

Z_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

ZonedTemporalFormat - Class in com.datastax.oss.dsbulk.codecs.api.format.temporal

A special temporal format that applies a fixed time zone to parsed inputs when they do not contain any time zone or time offset information, thus allowing such inputs to be converted to an Instant.

ZonedTemporalFormat(DateTimeFormatter, ZoneId) - Constructor for class com.datastax.oss.dsbulk.codecs.api.format.temporal.ZonedTemporalFormat

ZonedTemporalFormat(DateTimeFormatter, DateTimeFormatter, ZoneId) - Constructor for class com.datastax.oss.dsbulk.codecs.api.format.temporal.ZonedTemporalFormat

ZSTD_COMPRESSION - Static variable in class com.datastax.oss.dsbulk.io.CompressedIOUtils

A B C D E F G H I J L M N O P Q R S T U V W X Z