NOTE: The long options described here can be persisted in conf/application.conf and thus permanently override defaults and avoid specifying options on the command line.
A template configuration file can be found here.
Common Settings
Connector Settings
Connector Csv Settings
Connector Json Settings
Schema Settings
Batch Settings
Codec Settings
Engine Settings
Executor Settings
Log Settings
Monitoring Settings
Runner Settings
Stats Settings
Driver Settings
Load options from the given file rather than from <dsbulk_home>/conf/application.conf.
The name of the connector to use.
Default: "csv".
The URL or path of the resource(s) to read from or write to.
Which URL protocols are available depend on which URL stream handlers have been installed, but at least the file protocol is guaranteed to be supported for reads and writes, and the http and https protocols are guaranteed to be supported for reads.
The file protocol can be used with all supported file systems, local or not.
- When reading: the URL can point to a single file, or to an existing directory; in case of a directory, the fileNamePattern setting can be used to filter files to read, and the recursive setting can be used to control whether or not the connector should look for files in subdirectories as well.
- When writing: the URL will be treated as a directory; if it doesn't exist, the loader will attempt to create it; CSV files will be created inside this directory, and their names can be controlled with the fileNameFormat setting.
Note that if the value specified here does not have a protocol, then it is assumed to be a file protocol. Relative URLs will be resolved against the current working directory. Also, for convenience, if the path begins with a tilde (~), that symbol will be expanded to the current user's home directory.
In addition the value - indicates stdin when loading and stdout when unloading. This is in line with Unix tools such as tar, which uses - to represent stdin/stdout when reading/writing an archive.
Examples:
url = "/path/to/dir/or/file" # without protocol
url = "./path/to/dir/or/file" # without protocol, relative to working directory
url = "~/path/to/dir/or/file" # without protocol, relative to the user's home directory
url = "file:///path/to/dir/or/file" # with file protocol
url = "http://acme.com/file.csv" # with HTTP protocol
url = "-" # to read csv data from stdin (for load) or
url = "-" # write csv data to stdout (for unload)
For other URLs: the URL will be read or written directly; settings like fileNamePattern, recursive, and fileNameFormat will have no effect.
The default value is - (read from stdin / write to stdout).
Default: "-".
The character(s) to use as field delimiter. Field delimiters containing more than one character are accepted.
Default: ",".
Enable or disable whether the files to read or write begin with a header line. If enabled for loading, the first non-empty line in every file will assign field names for each record column, in lieu of schema.mapping, fieldA = col1, fieldB = col2, fieldC = col3. If disabled for loading, records will not contain fields names, only field indexes, 0 = col1, 1 = col2, 2 = col3. For unloading, if this setting is enabled, each file will begin with a header line, and if disabled, each file will not contain a header line.
Note: This option will apply to all files loaded or unloaded.
Default: true.
The number of records to skip from each input file before the parser can begin to execute. Note that if the file contains a header line, that line is not counted as a valid record. This setting is ignored when writing.
Default: 0.
The maximum number of records to read from or write to each file. When reading, all records past this number will be discarded. When writing, a file will contain at most this number of records; if more records remain to be written, a new file will be created using the fileNameFormat setting. Note that when writing to anything other than a directory, this setting is ignored. This setting takes into account the header setting: if a file begins with a header line, that line is not counted as a record. This feature is disabled by default (indicated by its -1 value).
Default: -1.
The URL or path of the resource(s) to read from or write to.
Which URL protocols are available depend on which URL stream handlers have been installed, but at least the file protocol is guaranteed to be supported for reads and writes, and the http and https protocols are guaranteed to be supported for reads.
The file protocol can be used with all supported file systems, local or not.
- When reading: the URL can point to a single file, or to an existing directory; in case of a directory, the fileNamePattern setting can be used to filter files to read, and the recursive setting can be used to control whether or not the connector should look for files in subdirectories as well.
- When writing: the URL will be treated as a directory; if it doesn't exist, the loader will attempt to create it; json files will be created inside this directory, and their names can be controlled with the fileNameFormat setting.
Note that if the value specified here does not have a protocol, then it is assumed to be a file protocol. Relative URLs will be resolved against the current working directory. Also, for convenience, if the path begins with a tilde (~), that symbol will be expanded to the current user's home directory.
In addition the value - indicates stdin when loading and stdout when unloading. This is in line with Unix tools such as tar, which uses - to represent stdin/stdout when reading/writing an archive.
Examples:
url = "/path/to/dir/or/file" # without protocol
url = "./path/to/dir/or/file" # without protocol, relative to working directory
url = "~/path/to/dir/or/file" # without protocol, relative to the user's home directory
url = "file:///path/to/dir/or/file" # with file protocol
url = "http://acme.com/file.json" # with HTTP protocol
url = "-" # to read json data from stdin (for load) or
url = "-" # write json data to stdout (for unload)
For other URLs: the URL will be read or written directly; settings like fileNamePattern, recursive, and fileNameFormat will have no effect.
The default value is - (read from stdin / write to stdout).
Default: "-".
The number of JSON records to skip from each input file before the parser can begin to execute. This setting is ignored when writing.
Default: 0.
The maximum number of records to read from or write to each file. When reading, all records past this number will be discarded. When writing, a file will contain at most this number of records; if more records remain to be written, a new file will be created using the fileNameFormat setting. Note that when writing to anything other than a directory, this setting is ignored. This feature is disabled by default (indicated by its -1 value).
Default: -1.
The contact points to use for the initial connection to the cluster.
These are addresses of Cassandra nodes that the driver uses to discover the cluster topology. Only one contact point is required (the driver will retrieve the address of the other nodes automatically), but it is usually a good idea to provide more than one contact point, because if that single contact point is unavailable, the driver cannot initialize itself correctly.
This must be a list of strings with each contact point specified as "host" or "host:port". If the specified host doesn't have a port, the default port specified in basic.default-port will be used. Note that Cassandra 3 and below and DSE 6.7 and below require all nodes in a cluster to share the same port (see CASSANDRA-7544).
Valid examples of contact points are:
- IPv4 addresses with ports:
[ "192.168.0.1:9042", "192.168.0.2:9042" ] - IPv4 addresses without ports:
[ "192.168.0.1", "192.168.0.2" ] - IPv6 addresses with ports:
[ "fe80:0:0:0:f861:3eff:fe1d:9d7b:9042", "fe80:0:0:f861:3eff:fe1d:9d7b:9044:9042" ] - IPv6 addresses without ports:
[ "fe80:0:0:0:f861:3eff:fe1d:9d7b", "fe80:0:0:f861:3eff:fe1d:9d7b:9044" ] - Host names with ports:
[ "host1.com:9042", "host2.com:9042" ] - Host names without ports:
[ "host1.com", "host2.com:" ]
If the host is a DNS name that resolves to multiple A-records, all the corresponding addresses will be used. Avoid using "localhost" as the host name (since it resolves to both IPv4 and IPv6 addresses on some platforms).
The heuristic to determine whether or not a contact point is in the form "host" or "host:port" is not 100% accurate for some IPv6 addresses; you should avoid ambiguous IPv6 addresses such as fe80::f861:3eff:fe1d:1234, because such a string can be seen either as a combination of IP fe80::f861:3eff:fe1d with port 1234, or as IP fe80::f861:3eff:fe1d:1234 without port. In such cases, DSBulk will not change the contact point. This issue can be avoided by providing IPv6 addresses in full form, e.g. if instead of fe80::f861:3eff:fe1d:1234 you provide fe80:0:0:0:0:f861:3eff:fe1d:1234, then the string is unequivocally parsed as IP fe80:0:0:0:0:f861:3eff:fe1d with port 1234.
Note: on Cloud deployments, DSBulk automatically sets this option to an empty list, as contact points are not allowed to be explicitly provided when connecting to DataStax Astra databases.
Default: ["127.0.0.1:9042"].
The default port to use for basic.contact-points, when a host is specified without port. Note that Cassandra 3 and below and DSE 6.7 and below require all nodes in a cluster to share the same port (see CASSANDRA-7544). If this setting is not specified, the default port will be 9042.
Default: 9042.
-b,
--driver.basic.cloud.secure-connect-bundle
--datastax-java-driver.basic.cloud.secure-connect-bundle <string>
The location of the secure bundle used to connect to a Datastax Astra database. This setting must be a path on the local filesystem or a valid URL.
Examples:
"/path/to/bundle.zip" # path on *Nix systems
"./path/to/bundle.zip" # path on *Nix systems, relative to workding directory
"~/path/to/bundle.zip" # path on *Nix systems, relative to home directory
"C:\\path\\to\\bundle.zip" # path on Windows systems,
# note that you need to escape backslashes in HOCON
"file:/a/path/to/bundle.zip" # URL with file protocol
"http://host.com/bundle.zip" # URL with HTTP protocol
Note: if you set this to a non-null value, DSBulk assumes that you are connecting to an DataStax Astra database; in this case, you should not set any of the following settings because they are not compatible with Cloud deployments:
datastax-java-driver.basic.contact-pointsdatastax-java-driver.basic.request.consistencydatastax-java-driver.advanced.ssl-engine-factory.*
If you do so, a log will be emitted and the setting will be ignored.
Default: null.
-u,
--driver.advanced.auth-provider.username
--datastax-java-driver.advanced.auth-provider.username <string>
The username to use to authenticate against a cluster with authentication enabled. Providers that accept this setting:
PlainTextAuthProvider
Default: null.
-p,
--driver.advanced.auth-provider.password
--datastax-java-driver.advanced.auth-provider.password <string>
The password to use to authenticate against a cluster with authentication enabled. Providers that accept this setting:
PlainTextAuthProvider
Default: null.
The consistency level to use for all queries. Note that stronger consistency levels usually result in reduced throughput. In addition, any level higher than ONE will automatically disable continuous paging, which can dramatically reduce read throughput.
Valid values are: ANY, LOCAL_ONE, ONE, TWO, THREE, LOCAL_QUORUM, QUORUM, EACH_QUORUM, ALL.
Note: on Cloud deployments, the only accepted consistency level when writing is LOCAL_QUORUM. Therefore, the default value is LOCAL_ONE, except when loading in Cloud deployments, in which case the default is automatically changed to LOCAL_QUORUM.
Default: "LOCAL_ONE".
-dc,
--driver.basic.load-balancing-policy.local-datacenter
--datastax-java-driver.basic.load-balancing-policy.local-datacenter <string>
The datacenter that is considered "local": the default load balancing policy will only include nodes from this datacenter in its query plans. Set this to a non-null value if you want to force the local datacenter; otherwise, the DcInferringLoadBalancingPolicy used by default by DSBulk will infer the local datacenter from the provided contact points.
Default: null.
Keyspace used for loading or unloading data. Keyspace names should not be quoted and are case-sensitive. MyKeyspace will match a keyspace named MyKeyspace but not mykeyspace. Either keyspace or graph is required if query is not specified or is not qualified with a keyspace name.
Default: null.
Table used for loading or unloading data. Table names should not be quoted and are case-sensitive. MyTable will match a table named MyTable but not mytable. Either table, vertex or edge is required if query is not specified.
Default: null.
The field-to-column mapping to use, that applies to both loading and unloading; ignored when counting. If not specified, the loader will apply a strict one-to-one mapping between the source fields and the database table. If that is not what you want, then you must supply an explicit mapping. Mappings should be specified as a map of the following form:
- Indexed data sources:
0 = col1, 1 = col2, 2 = col3, where0,1,2, are the zero-based indices of fields in the source data; andcol1,col2,col3are bound variable names in the insert statement.- A shortcut to map the first
nfields is to simply specify the destination columns:col1, col2, col3.
- A shortcut to map the first
- Mapped data sources:
fieldA = col1, fieldB = col2, fieldC = col3, wherefieldA,fieldB,fieldC, are field names in the source data; andcol1,col2,col3are bound variable names in the insert statement.- A shortcut to map fields named like columns is to simply specify the destination columns:
col1, col2, col3.
- A shortcut to map fields named like columns is to simply specify the destination columns:
To specify that a field should be used as the timestamp (a.k.a. write-time) or ttl (a.k.a. time-to-live) of the inserted row, use the specially named fake columns __ttl and __timestamp: fieldA = __timestamp, fieldB = __ttl. Note that Timestamp fields are parsed as regular CQL timestamp columns and must comply with either codec.timestamp, or alternatively, with codec.unit + codec.epoch. TTL fields are parsed as integers representing durations in seconds, and must comply with codec.number.
To specify that a column should be populated with the result of a function call, specify the function call as the input field (e.g. now() = c4). Note, this is only relevant for load operations. Similarly, to specify that a field should be populated with the result of a function call, specify the function call as the input column (e.g. field1 = now()). This is only relevant for unload operations. Function calls can also be qualified by a keyspace name: field1 = ks1.max(c1,c2).
In addition, for mapped data sources, it is also possible to specify that the mapping be partly auto-generated and partly explicitly specified. For example, if a source row has fields c1, c2, c3, and c5, and the table has columns c1, c2, c3, c4, one can map all like-named columns and specify that c5 in the source maps to c4 in the table as follows: * = *, c5 = c4.
One can specify that all like-named fields be mapped, except for c2: * = -c2. To skip c2 and c3: * = [-c2, -c3].
Any identifier, field or column, that is not strictly alphanumeric (i.e. not matching [a-zA-Z0-9_]+) must be surrounded by double-quotes, just like you would do in CQL: "Field ""A""" = "Column 2" (to escape a double-quote, simply double it). Note that, contrary to the CQL grammar, unquoted identifiers will not be lower-cased: an identifier such as MyColumn1 will match a column named "MyColumn1" and not mycolumn1.
The exact type of mapping to use depends on the connector being used. Some connectors can only produce indexed records; others can only produce mapped ones, while others are capable of producing both indexed and mapped records at the same time. Refer to the connector's documentation to know which kinds of mapping it supports.
Default: null.
Enable or disable dry-run mode, a test mode that runs the command but does not load data. Not applicable for unloading nor counting.
Default: false.
The maximum number of concurrent queries that should be carried in parallel.
This acts as a safeguard to prevent more queries executing in parallel than the cluster can handle, or to regulate throughput when latencies get too high. Batch statements count as one query.
When using continuous paging, also make sure to set this number to a value equal to or lesser than the number of nodes in the local datacenter multiplied by the value configured server-side for continuous_paging.max_concurrent_sessions in the cassandra.yaml configuration file (60 by default); otherwise some requests might be rejected.
The special syntax NC can be used to specify a number that is a multiple of the number of available cores, e.g. if the number of cores is 8, then 0.5C = 0.5 * 8 = 4 concurrent queries.
The default value is 'AUTO'; with this special value, DSBulk will optimize the number of concurrent queries according to the number of available cores, and the operation being executed. The actual value usually ranges from the number of cores to eight times that number.
Default: "AUTO".
The maximum number of errors to tolerate before aborting the entire operation. This can be expressed either as an absolute number of errors - in which case, set this to an integer greater than or equal to zero; or as a percentage of total rows processed so far - in which case, set this to a string of the form N%, where N is a decimal number between 0 and 100 exclusive (e.g. "20%"). Setting this value to any negative integer disables this feature (not recommended).
Default: 100.
The writable directory where all log files will be stored; if the directory specified does not exist, it will be created. URLs are not acceptable (not even file:/ URLs). Log files for a specific run, or execution, will be located in a sub-directory under the specified directory. Each execution generates a sub-directory identified by an "execution ID". See engine.executionId for more information about execution IDs. Relative paths will be resolved against the current working directory. Also, for convenience, if the path begins with a tilde (~), that symbol will be expanded to the current user's home directory.
Default: "./logs".
The desired level of verbosity. Valid values are:
quiet: DSBulk will only log WARN and ERROR messages.normal: DSBulk will log a few INFO messages, as well as WARN and ERROR messages.high: DSBulk will also print some DEBUG messages at the beginning of the operation, such as DSBulk's settings, inferred query, and the read and write concurrency.max: DSBulk will print numerous DEBUG messages from itself, the driver, and from some important libraries (Netty and Reactor).
Verbosity levels quiet, normal and high are suitable to use in a production environment. Verbosity high is the recommended level to diagnose problems related to configuration and/or performance in production environments. Verbosity max, however, should only be used for debugging, and preferably on small amounts of data; otherwise it could print hundreds of gigabytes of text to the main log file and to the console.
Default: "normal".
The report interval. DSBulk will print useful metrics about the ongoing operation at this rate; for example, if this value is set to 10 seconds, then DSBulk will print metrics every ten seconds. Valid values: any value specified in HOCON duration syntax, but durations lesser than one second will be rounded up to 1 second.
Default: "5 seconds".
Connector-specific settings. This section contains settings for the connector to use; it also contains sub-sections, one for each available connector.
This setting is ignored when counting.
The name of the connector to use.
Default: "csv".
CSV Connector configuration.
The URL or path of the resource(s) to read from or write to.
Which URL protocols are available depend on which URL stream handlers have been installed, but at least the file protocol is guaranteed to be supported for reads and writes, and the http and https protocols are guaranteed to be supported for reads.
The file protocol can be used with all supported file systems, local or not.
- When reading: the URL can point to a single file, or to an existing directory; in case of a directory, the fileNamePattern setting can be used to filter files to read, and the recursive setting can be used to control whether or not the connector should look for files in subdirectories as well.
- When writing: the URL will be treated as a directory; if it doesn't exist, the loader will attempt to create it; CSV files will be created inside this directory, and their names can be controlled with the fileNameFormat setting.
Note that if the value specified here does not have a protocol, then it is assumed to be a file protocol. Relative URLs will be resolved against the current working directory. Also, for convenience, if the path begins with a tilde (~), that symbol will be expanded to the current user's home directory.
In addition the value - indicates stdin when loading and stdout when unloading. This is in line with Unix tools such as tar, which uses - to represent stdin/stdout when reading/writing an archive.
Examples:
url = "/path/to/dir/or/file" # without protocol
url = "./path/to/dir/or/file" # without protocol, relative to working directory
url = "~/path/to/dir/or/file" # without protocol, relative to the user's home directory
url = "file:///path/to/dir/or/file" # with file protocol
url = "http://acme.com/file.csv" # with HTTP protocol
url = "-" # to read csv data from stdin (for load) or
url = "-" # write csv data to stdout (for unload)
For other URLs: the URL will be read or written directly; settings like fileNamePattern, recursive, and fileNameFormat will have no effect.
The default value is - (read from stdin / write to stdout).
Default: "-".
The character(s) to use as field delimiter. Field delimiters containing more than one character are accepted.
Default: ",".
Enable or disable whether the files to read or write begin with a header line. If enabled for loading, the first non-empty line in every file will assign field names for each record column, in lieu of schema.mapping, fieldA = col1, fieldB = col2, fieldC = col3. If disabled for loading, records will not contain fields names, only field indexes, 0 = col1, 1 = col2, 2 = col3. For unloading, if this setting is enabled, each file will begin with a header line, and if disabled, each file will not contain a header line.
Note: This option will apply to all files loaded or unloaded.
Default: true.
The number of records to skip from each input file before the parser can begin to execute. Note that if the file contains a header line, that line is not counted as a valid record. This setting is ignored when writing.
Default: 0.
The maximum number of records to read from or write to each file. When reading, all records past this number will be discarded. When writing, a file will contain at most this number of records; if more records remain to be written, a new file will be created using the fileNameFormat setting. Note that when writing to anything other than a directory, this setting is ignored. This setting takes into account the header setting: if a file begins with a header line, that line is not counted as a record. This feature is disabled by default (indicated by its -1 value).
Default: -1.
The character used for quoting fields when the field delimiter is part of the field value. Only one character can be specified. Note that this setting applies to all files to be read or written.
Default: """.
The character that represents a line comment when found in the beginning of a line of text. Only one character can be specified. Note that this setting applies to all files to be read or written. This feature is disabled by default (indicated by its null character value).
Default: "\u0000".
The compression that will be used for writing or reading files. Supported values are (for both reading and writing): none, xz, gzip, bzip2, zstd, lz4, lzma, snappy, deflate. For reading only, supported values are: brotli, z, deflate64.
Default: "none".
Sets the String representation of an empty value. When reading, if the parser does not read any character from the input, and the input is within quotes, this value will be used instead. When writing, if the writer has an empty string to write to the output, this value will be used instead. The default value is AUTO, which means that, when reading, the parser will emit an empty string, and when writing, the writer will write a quoted empty field to the output.
Default: "AUTO".
The file encoding to use for all read or written files.
Default: "UTF-8".
The character used for escaping quotes inside an already quoted value. Only one character can be specified. Note that this setting applies to all files to be read or written.
Default: "\".
The file name format to use when writing. This setting is ignored when reading and for non-file URLs. The file name must comply with the formatting rules of String.format(), and must contain a %d format specifier that will be used to increment file name counters.
If compression is enabled, the default value for this setting will be modified to include the default suffix for the selected compression method. For example, if compression is gzip, the default file name format will be output-%06d.csv.gz.
Default: "output-%06d.csv".
The glob pattern to use when searching for files to read. The syntax to use is the glob syntax, as described in java.nio.file.FileSystem.getPathMatcher(). This setting is ignored when writing and for non-file URLs. Only applicable when the url setting points to a directory on a known filesystem, ignored otherwise.
If compression is enabled, the default value for this setting will be modified to include the default suffix for the selected compression method. For example, if compression is gzip, the default glob pattern will be **/*.csv.gz.
Default: "**/*.csv".
Defines whether or not leading whitespaces from values being read/written should be skipped. This setting is honored when reading and writing. Default value is false.
Default: false.
--connector.csv.ignoreLeadingWhitespacesInQuotes
--dsbulk.connector.csv.ignoreLeadingWhitespacesInQuotes <boolean>
Defines whether or not trailing whitespaces from quoted values should be skipped. This setting is only honored when reading; it is ignored when writing. Default value is false.
Default: false.
Defines whether or not trailing whitespaces from values being read/written should be skipped. This setting is honored when reading and writing. Default value is false.
Default: false.
--connector.csv.ignoreTrailingWhitespacesInQuotes
--dsbulk.connector.csv.ignoreTrailingWhitespacesInQuotes <boolean>
Defines whether or not leading whitespaces from quoted values should be skipped. This setting is only honored when reading; it is ignored when writing. Default value is false.
Default: false.
The maximum number of characters that a field can contain. This setting is used to size internal buffers and to avoid out-of-memory problems. If set to -1, internal buffers will be resized dynamically. While convenient, this can lead to memory problems. It could also hurt throughput, if some large fields require constant resizing; if this is the case, set this value to a fixed positive number that is big enough to contain all field values.
Default: 4096.
The maximum number of columns that a record can contain. This setting is used to size internal buffers and to avoid out-of-memory problems.
Default: 512.
-maxConcurrentFiles,
--connector.csv.maxConcurrentFiles
--dsbulk.connector.csv.maxConcurrentFiles <string>
The maximum number of files that can be read or written simultaneously. This setting is effective only when reading from or writing to many resources in parallel, such as a collection of files in a root directory; it is ignored otherwise. The special syntax NC can be used to specify a number of threads that is a multiple of the number of available cores, e.g. if the number of cores is 8, then 0.5C = 0.5 * 8 = 4 threads.
The default value is the special value AUTO; with this value, the connector will decide the best number of files.
Default: "AUTO".
The character(s) that represent a line ending. When set to the special value auto (default), the system's line separator, as determined by System.lineSeparator(), will be used when writing, and auto-detection of line endings will be enabled when reading. Only one or two characters can be specified; beware that most typical line separator characters need to be escaped, e.g. one should specify \r\n for the typical line ending on Windows systems (carriage return followed by a new line).
Default: "auto".
--connector.csv.normalizeLineEndingsInQuotes
--dsbulk.connector.csv.normalizeLineEndingsInQuotes <boolean>
Defines whether or not line separators should be replaced by a normalized line separator '\n' inside quoted values. This setting is honored when reading and writing. Note: due to a bug in the CSV parsing library, on Windows systems, the line ending detection mechanism may not function properly when this setting is false; in case of problem, set this to true. Default value is false.
Default: false.
Sets the String representation of a null value. When reading, if the parser does not read any character from the input, this value will be used instead. When writing, if the writer has a null object to write to the output, this value will be used instead. The default value is AUTO, which means that, when reading, the parser will emit a null, and when writing, the writer won't write any character at all to the output.
Default: "AUTO".
Enable or disable scanning for files in the root's subdirectories. Only applicable when url is set to a directory on a known filesystem. Used for loading only.
Default: false.
The URL or path of the file that contains the list of resources to read from.
The file specified here should be located on the local filesystem.
This setting and connector.csv.url are mutually exclusive. If both are defined and non empty, this setting takes precedence over connector.csv.url.
This setting applies only when loading. When unloading, this setting should be left empty or set to null; any non-empty value will trigger a fatal error.
The file with URLs should follow this format:
/path/to/file/file.csv
/path/to.dir/
Every line should contain one path. You don't need to escape paths in this file.
All the remarks for connector.csv.url apply for each line in the file, and especially, settings like fileNamePattern, recursive, and fileNameFormat all apply to each line individually.
You can comment out a line in the URL file by making it start with a # sign:
#/path/that/will/be/ignored
Such a line will be ignored.
For your convenience, every line in the urlfile will be trimmed - that is, any leading and trailing white space will be removed.
The file should be encoded in UTF-8, and each line should be a valid URL to load.
The default value is "" - which means that this property is ignored.
Default: <unspecified>.
JSON Connector configuration.
The URL or path of the resource(s) to read from or write to.
Which URL protocols are available depend on which URL stream handlers have been installed, but at least the file protocol is guaranteed to be supported for reads and writes, and the http and https protocols are guaranteed to be supported for reads.
The file protocol can be used with all supported file systems, local or not.
- When reading: the URL can point to a single file, or to an existing directory; in case of a directory, the fileNamePattern setting can be used to filter files to read, and the recursive setting can be used to control whether or not the connector should look for files in subdirectories as well.
- When writing: the URL will be treated as a directory; if it doesn't exist, the loader will attempt to create it; json files will be created inside this directory, and their names can be controlled with the fileNameFormat setting.
Note that if the value specified here does not have a protocol, then it is assumed to be a file protocol. Relative URLs will be resolved against the current working directory. Also, for convenience, if the path begins with a tilde (~), that symbol will be expanded to the current user's home directory.
In addition the value - indicates stdin when loading and stdout when unloading. This is in line with Unix tools such as tar, which uses - to represent stdin/stdout when reading/writing an archive.
Examples:
url = "/path/to/dir/or/file" # without protocol
url = "./path/to/dir/or/file" # without protocol, relative to working directory
url = "~/path/to/dir/or/file" # without protocol, relative to the user's home directory
url = "file:///path/to/dir/or/file" # with file protocol
url = "http://acme.com/file.json" # with HTTP protocol
url = "-" # to read json data from stdin (for load) or
url = "-" # write json data to stdout (for unload)
For other URLs: the URL will be read or written directly; settings like fileNamePattern, recursive, and fileNameFormat will have no effect.
The default value is - (read from stdin / write to stdout).
Default: "-".
The number of JSON records to skip from each input file before the parser can begin to execute. This setting is ignored when writing.
Default: 0.
The maximum number of records to read from or write to each file. When reading, all records past this number will be discarded. When writing, a file will contain at most this number of records; if more records remain to be written, a new file will be created using the fileNameFormat setting. Note that when writing to anything other than a directory, this setting is ignored. This feature is disabled by default (indicated by its -1 value).
Default: -1.
The mode for loading and unloading JSON documents. Valid values are:
- MULTI_DOCUMENT: Each resource may contain an arbitrary number of successive JSON documents to be mapped to records. For example the format of each JSON document is a single document:
{doc1}. The root directory for the JSON documents can be specified withurland the documents can be read recursively by settingconnector.json.recursiveto true. - SINGLE_DOCUMENT: Each resource contains a root array whose elements are JSON documents to be mapped to records. For example, the format of the JSON document is an array with embedded JSON documents:
[ {doc1}, {doc2}, {doc3} ].
Default: "MULTI_DOCUMENT".
The compression that will be used for writing or reading files. Supported values are (for both reading and writing): none, xz, gzip, bzip2, zstd, lz4, lzma, snappy, deflate. For reading only, supported values are: brotli, z, deflate64.
Default: "none".
--connector.json.deserializationFeatures
--dsbulk.connector.json.deserializationFeatures <map<string,boolean>>
A map of JSON deserialization features to set. Map keys should be enum constants defined in com.fasterxml.jackson.databind.DeserializationFeature. The default value is the only way to guarantee that floating point numbers will not have their precision truncated when parsed, but can result in slightly slower parsing. Used for loading only.
Note that some Jackson features might not be supported, in particular features that operate on the resulting Json tree by filtering elements or altering their contents, since such features conflict with dsbulk's own filtering and formatting capabilities. Instead of trying to modify the resulting tree using Jackson features, you should try to achieve the same result using the settings available under the codec and schema sections.
The file encoding to use for all read or written files.
Default: "UTF-8".
The file name format to use when writing. This setting is ignored when reading and for non-file URLs. The file name must comply with the formatting rules of String.format(), and must contain a %d format specifier that will be used to increment file name counters.
If compression is enabled, the default value for this setting will be modified to include the default suffix for the selected compression method. For example, if compression is gzip, the default file name format will be output-%06d.json.gz.
Default: "output-%06d.json".
The glob pattern to use when searching for files to read. The syntax to use is the glob syntax, as described in java.nio.file.FileSystem.getPathMatcher(). This setting is ignored when writing and for non-file URLs. Only applicable when the url setting points to a directory on a known filesystem, ignored otherwise.
If compression is enabled, the default value for this setting will be modified to include the default suffix for the selected compression method. For example, if compression is gzip, the default glob pattern will be **/*.json.gz.
Default: "**/*.json".
JSON generator features to enable. Valid values are all the enum constants defined in com.fasterxml.jackson.core.JsonGenerator.Feature. For example, a value of { ESCAPE_NON_ASCII : true, QUOTE_FIELD_NAMES : true } will configure the generator to escape all characters beyond 7-bit ASCII and quote field names when writing JSON output. Used for unloading only.
Note that some Jackson features might not be supported, in particular features that operate on the resulting Json tree by filtering elements or altering their contents, since such features conflict with dsbulk's own filtering and formatting capabilities. Instead of trying to modify the resulting tree using Jackson features, you should try to achieve the same result using the settings available under the codec and schema sections.
-maxConcurrentFiles,
--connector.json.maxConcurrentFiles
--dsbulk.connector.json.maxConcurrentFiles <string>
The maximum number of files that can be read or written simultaneously. This setting is effective only when reading from or writing to many resources in parallel, such as a collection of files in a root directory; it is ignored otherwise. The special syntax NC can be used to specify a number of threads that is a multiple of the number of available cores, e.g. if the number of cores is 8, then 0.5C = 0.5 * 8 = 4 threads.
The default value is the special value AUTO; with this value, the connector will decide the best number of files.
Default: "AUTO".
JSON parser features to enable. Valid values are all the enum constants defined in com.fasterxml.jackson.core.JsonParser.Feature. For example, a value of { ALLOW_COMMENTS : true, ALLOW_SINGLE_QUOTES : true } will configure the parser to allow the use of comments and single-quoted strings in JSON data. Used for loading only.
Note that some Jackson features might not be supported, in particular features that operate on the resulting Json tree by filtering elements or altering their contents, since such features conflict with dsbulk's own filtering and formatting capabilities. Instead of trying to modify the resulting tree using Jackson features, you should try to achieve the same result using the settings available under the codec and schema sections.
Enable or disable pretty printing. When enabled, JSON records are written with indents. Used for unloading only.
Note: Can result in much bigger records.
Default: false.
Enable or disable scanning for files in the root's subdirectories. Only applicable when url is set to a directory on a known filesystem. Used for loading only.
Default: false.
--connector.json.serializationFeatures
--dsbulk.connector.json.serializationFeatures <map<string,boolean>>
A map of JSON serialization features to set. Map keys should be enum constants defined in com.fasterxml.jackson.databind.SerializationFeature. Used for unloading only.
Note that some Jackson features might not be supported, in particular features that operate on the resulting Json tree by filtering elements or altering their contents, since such features conflict with dsbulk's own filtering and formatting capabilities. Instead of trying to modify the resulting tree using Jackson features, you should try to achieve the same result using the settings available under the codec and schema sections.
The strategy to use for filtering out entries when formatting output. Valid values are enum constants defined in com.fasterxml.jackson.annotation.JsonInclude.Include (but beware that the CUSTOM strategy cannot be honored). Used for unloading only.
Default: "ALWAYS".
The URL or path of the file that contains the list of resources to read from.
The file specified here should be located on the local filesystem.
This setting and connector.json.url are mutually exclusive. If both are defined and non empty, this setting takes precedence over connector.json.url.
This setting applies only when loading. When unloading, this setting should be left empty or set to null; any non-empty value will trigger a fatal error.
The file with URLs should follow this format:
/path/to/file/file.json
/path/to.dir/
Every line should contain one path. You don't need to escape paths in this file.
All the remarks for connector.csv.json apply for each line in the file, and especially, settings like fileNamePattern, recursive, and fileNameFormat all apply to each line individually.
You can comment out a line in the URL file by making it start with a # sign:
#/path/that/will/be/ignored
Such a line will be ignored.
For your convenience, every line in the urlfile will be trimmed - that is, any leading and trailing white space will be removed.
The file should be encoded in UTF-8, and each line should be a valid URL to load.
The default value is "" - which means that this property is ignored.
Default: <unspecified>.
Schema-specific settings.
Keyspace used for loading or unloading data. Keyspace names should not be quoted and are case-sensitive. MyKeyspace will match a keyspace named MyKeyspace but not mykeyspace. Either keyspace or graph is required if query is not specified or is not qualified with a keyspace name.
Default: null.
Table used for loading or unloading data. Table names should not be quoted and are case-sensitive. MyTable will match a table named MyTable but not mytable. Either table, vertex or edge is required if query is not specified.
Default: null.
The field-to-column mapping to use, that applies to both loading and unloading; ignored when counting. If not specified, the loader will apply a strict one-to-one mapping between the source fields and the database table. If that is not what you want, then you must supply an explicit mapping. Mappings should be specified as a map of the following form:
- Indexed data sources:
0 = col1, 1 = col2, 2 = col3, where0,1,2, are the zero-based indices of fields in the source data; andcol1,col2,col3are bound variable names in the insert statement.- A shortcut to map the first
nfields is to simply specify the destination columns:col1, col2, col3.
- A shortcut to map the first
- Mapped data sources:
fieldA = col1, fieldB = col2, fieldC = col3, wherefieldA,fieldB,fieldC, are field names in the source data; andcol1,col2,col3are bound variable names in the insert statement.- A shortcut to map fields named like columns is to simply specify the destination columns:
col1, col2, col3.
- A shortcut to map fields named like columns is to simply specify the destination columns:
To specify that a field should be used as the timestamp (a.k.a. write-time) or ttl (a.k.a. time-to-live) of the inserted row, use the specially named fake columns __ttl and __timestamp: fieldA = __timestamp, fieldB = __ttl. Note that Timestamp fields are parsed as regular CQL timestamp columns and must comply with either codec.timestamp, or alternatively, with codec.unit + codec.epoch. TTL fields are parsed as integers representing durations in seconds, and must comply with codec.number.
To specify that a column should be populated with the result of a function call, specify the function call as the input field (e.g. now() = c4). Note, this is only relevant for load operations. Similarly, to specify that a field should be populated with the result of a function call, specify the function call as the input column (e.g. field1 = now()). This is only relevant for unload operations. Function calls can also be qualified by a keyspace name: field1 = ks1.max(c1,c2).
In addition, for mapped data sources, it is also possible to specify that the mapping be partly auto-generated and partly explicitly specified. For example, if a source row has fields c1, c2, c3, and c5, and the table has columns c1, c2, c3, c4, one can map all like-named columns and specify that c5 in the source maps to c4 in the table as follows: * = *, c5 = c4.
One can specify that all like-named fields be mapped, except for c2: * = -c2. To skip c2 and c3: * = [-c2, -c3].
Any identifier, field or column, that is not strictly alphanumeric (i.e. not matching [a-zA-Z0-9_]+) must be surrounded by double-quotes, just like you would do in CQL: "Field ""A""" = "Column 2" (to escape a double-quote, simply double it). Note that, contrary to the CQL grammar, unquoted identifiers will not be lower-cased: an identifier such as MyColumn1 will match a column named "MyColumn1" and not mycolumn1.
The exact type of mapping to use depends on the connector being used. Some connectors can only produce indexed records; others can only produce mapped ones, while others are capable of producing both indexed and mapped records at the same time. Refer to the connector's documentation to know which kinds of mapping it supports.
Default: null.
Specify whether or not to accept records that contain extra fields that are not declared in the mapping. For example, if a record contains three fields A, B, and C, but the mapping only declares fields A and B, then if this option is true, C will be silently ignored and the record will be considered valid, and if false, the record will be rejected. This setting also applies to user-defined types and tuples. Only applicable for loading, ignored otherwise.
This setting is ignored when counting.
Default: true.
Specify whether or not to accept records that are missing fields declared in the mapping. For example, if the mapping declares three fields A, B, and C, but a record contains only fields A and B, then if this option is true, C will be silently assigned null and the record will be considered valid, and if false, the record will be rejected. If the missing field is mapped to a primary key column, the record will always be rejected, since the database will reject the record. This setting also applies to user-defined types and tuples. Only applicable for loading, ignored otherwise.
This setting is ignored when counting.
Default: false.
Edge label used for loading or unloading graph data. This option can only be used for modern graphs created with the Native engine (DSE 6.8+). The edge label must correspond to an existing table created with the WITH EDGE LABEL option; also, when edge is specified, then from and to must be specified as well. Edge labels should not be quoted and are case-sensitive. MyEdge will match a label named MyEdge but not myedge. Either table, vertex or edge is required if query is not specified.
Default: null.
The name of the edge's incoming vertex label, for loading or unloading graph data. This option can only be used for modern graphs created with the Native engine (DSE 6.8+). This option is mandatory when edge is specified; ignored otherwise. Vertex labels should not be quoted and are case-sensitive. MyVertex will match a label named MyVertex but not myvertex.
Default: null.
Graph name used for loading or unloading graph data. This option can only be used for modern graphs created with the Native engine (DSE 6.8+). Graph names should not be quoted and are case-sensitive. MyGraph will match a graph named MyGraph but not mygraph. Either keyspace or graph is required if query is not specified or is not qualified with a keyspace name.
Default: null.
Specify whether to map null input values to "unset" in the database, i.e., don't modify a potentially pre-existing value of this field for this row. Valid for load scenarios, otherwise ignore. Note that setting to false creates tombstones to represent null.
Note that this setting is applied after the codec.nullStrings setting, and may intercept nulls produced by that setting.
This setting is ignored when counting. When set to true but the protocol version in use does not support unset values (i.e., all protocol versions lesser than 4), this setting will be forced to false and a warning will be logged.
Default: true.
Whether to preserve cell timestamps when loading and unloading. Ignored when schema.query is provided, or when the target table is a counter table. If true, the following rules will be applied to generated queries:
- When loading, instead of a single INSERT statement, the generated query will be a BATCH query; this is required in order to preserve individual column timestamps for each row.
- When unloading, the generated SELECT statement will export each column along with its individual timestamp.
For both loading and unlaoding, DSBulk will import and export timestamps using field names such as "writetime(<column>)", where <column> is the column's internal CQL name; for example, if the table has a column named "MyCol", its corresponding timestamp would be exported as "writetime(MyCol)" in the generated query and in the resulting connector record. If you intend to use this feature to export and import tables letting DSBulk generate the appropriate queries, these names are fine and need not be changed. If, however, you would like to export or import data to or from external sources that use different field names, you could do so by using the function writetime in a schema.mapping entry; for example, the following mapping would map col1 along with its timestamp to two distinct fields, field1 and field1_writetime: field1 = col1, field1_writetime = writetime(col1).
Default: false.
Whether to preserve cell TTLs when loading and unloading. Ignored when schema.query is provided, or when the target table is a counter table. If true, the following rules will be applied to generated queries:
- When loading, instead of a single INSERT statement, the generated query will be a BATCH query; this is required in order to preserve individual column TTLs for each row.
- When unloading, the generated SELECT statement will export each column along with its individual TTL.
For both loading and unlaoding, DSBulk will import and export TTLs using field names such as "ttl(<column>)", where <column> is the column's internal CQL name; for example, if the table has a column named "MyCol", its corresponding TTL would be exported as "ttl(MyCol)" in the generated query and in the resulting connector record. If you intend to use this feature to export and import tables letting DSBulk generate the appropriate queries, these names are fine and need not be changed. If, however, you would like to export or import data to or from external sources that use different field names, you could do so by using the function ttl in a schema.mapping entry; for example, the following mapping would map col1 along with its TTL to two distinct fields, field1 and field1_ttl: field1 = col1, field1_ttl = ttl(col1).
Default: false.
The query to use. If not specified, then schema.keyspace and schema.table must be specified, and dsbulk will infer the appropriate statement based on the table's metadata, using all available columns. If schema.keyspace is provided, the query need not include the keyspace to qualify the table reference.
For loading, the statement can be any INSERT, UPDATE or DELETE statement. INSERT statements are preferred for most load operations, and bound variables should correspond to mapped fields; for example, INSERT INTO table1 (c1, c2, c3) VALUES (:fieldA, :fieldB, :fieldC). UPDATE statements are required if the target table is a counter table, and the columns are updated with incremental operations (SET col1 = col1 + :fieldA where fieldA is a field in the input data). A DELETE statement will remove existing data during the load operation.
For unloading and counting, the statement can be any regular SELECT statement. If the statement does not contain any WHERE, ORDER BY, GROUP BY, or LIMIT clause, the engine will generate a token range restriction clause of the form: WHERE token(...) > :start and token(...) <= :end and will generate range read statements, thus allowing parallelization of reads while at the same time targeting coordinators that are also replicas (see schema.splits). If the statement does contain WHERE, ORDER BY, GROUP BY or LIMIT clauses however, the query will be executed as is; the engine will only be able to parallelize the operation if the query includes a WHERE clause including the following relations: token(...) > :start AND token(...) <= :end (the bound variables can have any name). Note that, unlike LIMIT clauses, PER PARTITION LIMIT clauses can be parallelized.
Statements can use both named and positional bound variables. Named bound variables should be preferred, unless the protocol version in use does not allow them; they usually have names matching those of the columns in the destination table, but this is not a strict requirement; it is, however, required that their names match those of fields specified in the mapping. Positional variables can also be used, and will be named after their corresponding column in the destination table.
When loading and unloading graph data, the query must be provided in plain CQL; Gremlin queries are not supported.
Note: The query is parsed to discover which bound variables are present, and to map the variables correctly to fields.
See mapping setting for more information.
Default: null.
The timestamp of inserted/updated cells during load; otherwise, the current time of the system running the tool is used. Not applicable to unloading nor counting. Ignored when schema.query is provided. The value must be expressed in the timestamp format specified by the codec.timestamp setting.
Query timestamps for Cassandra have microsecond resolution; any sub-microsecond information specified is lost. For more information, see the CQL Reference.
Default: null.
The Time-To-Live (TTL) of inserted/updated cells during load (seconds); a value of -1 means there is no TTL. Not applicable to unloading nor counting. Ignored when schema.query is provided. For more information, see the CQL Reference, Setting the time-to-live (TTL) for value, and Expiring data with time-to-live.
Default: -1.
The number of token range splits in which to divide the token ring. In other words, this setting determines how many read requests will be generated in order to read an entire table. Only used when unloading and counting; ignored otherwise. Note that the actual number of splits may be slightly greater or lesser than the number specified here, depending on the actual cluster topology and token ownership. Also, it is not possible to generate fewer splits than the total number of primary token ranges in the cluster, so the actual number of splits is always equal to or greater than that number. Set this to higher values if you experience timeouts when reading from the database, specially if paging is disabled. This setting should also be greater than engine.maxConcurrentQueries. The special syntax NC can be used to specify a number that is a multiple of the number of available cores, e.g. if the number of cores is 8, then 0.5C = 0.5 * 8 = 4 splits.
Default: "8C".
The name of the edge's outgoing vertex label, for loading or unloading graph data. This option can only be used for modern graphs created with the Native engine (DSE 6.8+). This option is mandatory when edge is specified; ignored otherwise. Vertex labels should not be quoted and are case-sensitive. MyVertex will match a label named MyVertex but not myvertex.
Default: null.
Vertex label used for loading or unloading graph data. This option can only be used for modern graphs created with the Native engine (DSE 6.8+). The vertex label must correspond to an existing table created with the WITH VERTEX LABEL option. Vertex labels should not be quoted and are case-sensitive. MyVertex will match a label named MyVertex but not myvertex. Either table, vertex or edge is required if query is not specified.
Default: null.
Batch-specific settings.
These settings control how the workflow engine groups together statements before writing them.
Only applicable for loading.
The buffer size to use for flushing batched statements. Should be set to a multiple of maxBatchStatements, e.g. 2 or 4 times that value; higher values consume more memory and usually do not incur in any noticeable performance gain. When set to a value lesser than or equal to zero, the buffer size is implicitly set to 4 times maxBatchStatments.
Default: -1.
DEPRECATED. Use maxBatchStatements instead.
Default: null.
The maximum number of statements that a batch can contain. The ideal value depends on two factors:
- The data being loaded: the larger the data, the smaller the batches should be.
- The batch mode: when
PARTITION_KEYis used, larger batches are acceptable, whereas whenREPLICA_SETis used, smaller batches usually perform better. Also, when usingREPLICA_SET, it is preferrable to keep this number below the threshold configured server-side for the settingunlogged_batch_across_partitions_warn_threshold(the default is 10); failing to do so is likely to trigger query warnings (seelog.maxQueryWarningsfor more information). When set to a value lesser than or equal to zero, the maximum number of statements is considered unlimited. At least one ofmaxBatchStatementsormaxSizeInBytesmust be set to a positive value when batching is enabled.
Default: 32.
The maximum data size that a batch can hold. This is the number of bytes required to encode all the data to be persisted, without counting the overhead generated by the native protocol (headers, frames, etc.).
The value specified here should be lesser than or equal to the value that has been configured server-side for the option batch_size_fail_threshold_in_kb in cassandra.yaml, but note that the heuristic used to compute data sizes is not 100% accurate and sometimes underestimates the actual size. See the documentation for the cassandra.yaml configuration file for more information.
When set to a value lesser than or equal to zero, the maximum data size is considered unlimited. At least one of maxBatchStatements or maxSizeInBytes must be set to a positive value when batching is enabled.
Values for this option should either be valid long integers, or use HOCON's size-in-bytes format, e.g. 1234, 1K or 5 kibibytes.
Default: -1.
The grouping mode. Valid values are:
DISABLED: batching is disabled.PARTITION_KEY: groups together statements that share the same partition key. This is usually the most performant mode; however it may not work at all if the dataset is unordered, i.e., if partition keys appear randomly and cannot be grouped together.REPLICA_SET: groups together statements that share the same replica set. This mode works in all cases, but may incur in some throughput and latency degradation, specially with large clusters or high replication factors. When tuning DSBulk for batching, the recommended approach is as follows:
- Start with
PARTITION_KEY; - If the average batch size is close to 1, try increasing
bufferSize; - If increasing
bufferSizedoesn't help, switch toREPLICA_SETand setmaxBatchStatementsormaxSizeInBytesto low values to avoid timeouts or errors; - Increase
maxBatchStatementsormaxSizeInBytesto get the best throughput while keeping latencies acceptable. The default isPARTITION_KEY.
Default: "PARTITION_KEY".
Conversion-specific settings. These settings apply for both load and unload workflows.
When writing, these settings determine how record fields emitted by connectors are parsed.
When unloading, these settings determine how row cells emitted by DSE are formatted.
When counting, these settings are ignored.
Strategy to use when converting binary data to strings. Only applicable when unloading columns of CQL type blob, or columns of geometry types, if the value of codec.geo is WKB; and only if the connector in use requires stringification. Valid values are:
- BASE64: Encode the binary data into a Base-64 string. This is the default strategy.
- HEX: Encode the binary data as CQL blob literals. CQL blob literals follow the general syntax:
0[xX][0-9a-fA-F]+, that is,0xfollowed by hexadecimal characters, for example:0xcafebabe. This format produces lengthier strings than BASE64, but is also the only format compatible with CQLSH.
Default: "BASE64".
Set how true and false representations of numbers are interpreted. The representation is of the form true_value,false_value. The mapping is reciprocal, so that numbers are mapping to Boolean and vice versa. All numbers unspecified in this setting are rejected.
Default: [1,0].
Specify how true and false representations can be used by dsbulk. Each representation is of the form true_value:false_value, case-insensitive. For loading, all representations are honored: when a record field value exactly matches one of the specified strings, the value is replaced with true of false before writing to the database. For unloading, this setting is only applicable for string-based connectors, such as the CSV connector: the first representation will be used to format booleans before they are written out, and all others are ignored.
Default: ["1:0","Y:N","T:F","YES:NO","TRUE:FALSE"].
The temporal pattern to use for String to CQL date conversion. Valid choices:
- A date-time pattern such as
yyyy-MM-dd. - A pre-defined formatter such as
ISO_LOCAL_DATE. Any public static field injava.time.format.DateTimeFormattercan be used. - The special formatter
UNITS_SINCE_EPOCH, which is a special parser that reads and writes local dates as numbers representing time units since a given epoch; the unit and the epoch to use can be specified withcodec.unitandcodec.timestamp.
For more information on patterns and pre-defined formatters, see Patterns for Formatting and Parsing in Oracle Java documentation.
For more information about CQL date, time and timestamp literals, see Date, time, and timestamp format.
Default: "ISO_LOCAL_DATE".
This setting is used in the following situations:
- When the target column is of CQL
timestamptype, or when loading to aUSING TIMESTAMPclause, or when unloading from awritetime()function call, and ifcodec.timestampis set toUNITS_SINCE_EPOCH, then the epoch specified here determines the relative point in time to use to convert numeric data to and from temporals. For example, if the input is 123 and the epoch specified here is2000-01-01T00:00:00Z, then the input will be interpreted as Ncodec.units since January 1st 2000. - When loading, and the target CQL type is numeric, but the input is alphanumeric and represents a temporal literal, the time unit specified here will be used to convert the parsed temporal into a numeric value. For example, if the input is
2018-12-10T19:32:45Zand the epoch specified here is2000-01-01T00:00:00Z, then the parsed timestamp will be converted to Ncodec.units since January 1st 2000. - When parsing temporal literals, if the input does not contain a date part, then the date part of the instant specified here will be used instead. For example, if the input is
19:32:45and the epoch specified here is2000-01-01T00:00:00Z, then the input will be interpreted2000-01-01T19:32:45Z.
The value must be expressed in ISO_ZONED_DATE_TIME format.
Default: "1970-01-01T00:00:00Z".
Whether or not to use the codec.number pattern to format numeric output. When set to true, the numeric pattern defined by codec.number will be applied. This allows for nicely-formatted output, but may result in rounding (see codec.roundingStrategy), or alteration of the original decimal's scale. When set to false, numbers will be stringified using the toString() method, and will never result in rounding or scale alteration. Only applicable when unloading, and only if the connector in use requires stringification, because the connector, such as the CSV connector, does not handle raw numeric data; ignored otherwise.
Default: false.
Strategy to use when converting geometry types to strings. Geometry types are only available in DataStax Enterprise (DSE) 5.0 or higher. Only applicable when unloading columns of CQL type Point, LineString or Polygon, and only if the connector in use requires stringification. Valid values are:
- WKT: Encode the data in Well-known text format. This is the default strategy.
- WKB: Encode the data in Well-known binary format. The actual encoding will depend on the value chosen for the
codec.binarysetting (HEX or BASE64). - JSON: Encode the data in GeoJson format.
Default: "WKT".
The locale to use for locale-sensitive conversions.
Default: "en_US".
Comma-separated list of case-sensitive strings that should be mapped to null. For loading, when a record field value exactly matches one of the specified strings, the value is replaced with null before writing to the database. For unloading, this setting is only applicable for string-based connectors, such as the CSV connector: the first string specified will be used to change a row cell containing null to the specified string when written out.
For example, setting this to ["NULL"] will cause a field containing the word NULL to be mapped to null while loading, and a column containing null to be converted to the word NULL while unloading.
The default value is [] (no strings are mapped to null). In the default mode, DSBulk behaves as follows:
- When loading, if the target CQL type is textual (i.e. text, varchar or ascii), the original field value is left untouched; for other types, if the value is an empty string, it is converted to
null. - When unloading,
nullvalues are left untouched.
Note that, regardless of this setting, DSBulk will always convert empty strings to null if the target CQL type is not textual when loading (i.e. not text, varchar or ascii).
This setting is applied before schema.nullToUnset, hence any null produced by a null-string can still be left unset if required.
Default: [].
The DecimalFormat pattern to use for conversions between String and CQL numeric types.
See java.text.DecimalFormat for details about the pattern syntax to use.
Most inputs are recognized: optional localized thousands separator, localized decimal separator, or optional exponent. Using locale en_US, 1234, 1,234, 1234.5678, 1,234.5678 and 1,234.5678E2 are all valid. For unloading and formatting, rounding may occur and cause precision loss. See codec.formatNumbers and codec.roundingStrategy.
Default: "#,###.##".
This setting can mean one of three possibilities:
- The value is outside the range of the target CQL type. For example, trying to convert 128 to a CQL
tinyint(max value of 127) results in overflow. - The value is decimal, but the target CQL type is integral. For example, trying to convert 123.45 to a CQL
intresults in overflow. - The value's precision is too large for the target CQL type. For example, trying to insert 0.1234567890123456789 into a CQL
doubleresults in overflow, because there are too many significant digits to fit in a 64-bit double.
Valid choices:
REJECT: overflows are considered errors and the data is rejected. This is the default value.TRUNCATE: the data is truncated to fit in the target CQL type. The truncation algorithm is similar to the narrowing primitive conversion defined in The Java Language Specification, Section 5.1.3, with the following exceptions:- If the value is too big or too small, it is rounded up or down to the maximum or minimum value allowed, rather than truncated at bit level. For example, 128 would be rounded down to 127 to fit in a byte, whereas Java would have truncated the exceeding bits and converted to -127 instead.
- If the value is decimal, but the target CQL type is integral, it is first rounded to an integral using the defined rounding strategy, then narrowed to fit into the target type. This can result in precision loss and should be used with caution.
Only applicable for loading, when parsing numeric inputs; it does not apply for unloading, since formatting never results in overflow.
Default: "REJECT".
The rounding strategy to use for conversions from CQL numeric types to String.
Valid choices: any java.math.RoundingMode enum constant name, including: CEILING, FLOOR, UP, DOWN, HALF_UP, HALF_EVEN, HALF_DOWN, and UNNECESSARY. The precision used when rounding is inferred from the numeric pattern declared under codec.number. For example, the default codec.number (#,###.##) has a rounding precision of 2, and the number 123.456 would be rounded to 123.46 if roundingStrategy was set to UP. The default value will result in infinite precision, and ignore the codec.number setting.
Only applicable when unloading, if codec.formatNumbers is true and if the connector in use requires stringification, because the connector, such as the CSV connector, does not handle raw numeric data; ignored otherwise.
Default: "UNNECESSARY".
The temporal pattern to use for String to CQL time conversion. Valid choices:
- A date-time pattern, such as
HH:mm:ss. - A pre-defined formatter, such as
ISO_LOCAL_TIME. Any public static field injava.time.format.DateTimeFormattercan be used. - The special formatter
UNITS_SINCE_EPOCH, which is a special parser that reads and writes local times as numbers representing time units since a given epoch; the unit and the epoch to use can be specified withcodec.unitandcodec.timestamp.
For more information on patterns and pre-defined formatters, see Patterns for formatting and Parsing in Oracle Java documentation.
For more information about CQL date, time and timestamp literals, see Date, time, and timestamp format.
Default: "ISO_LOCAL_TIME".
The time zone to use for temporal conversions. When loading, the time zone will be used to obtain a timestamp from inputs that do not convey any explicit time zone information. When unloading, the time zone will be used to format all timestamps.
Default: "UTC".
The temporal pattern to use for String to CQL timestamp conversion. Valid choices:
- A date-time pattern such as
yyyy-MM-dd HH:mm:ss. - A pre-defined formatter such as
ISO_ZONED_DATE_TIMEorISO_INSTANT. Any public static field injava.time.format.DateTimeFormattercan be used. - The special formatter
CQL_TIMESTAMP, which is a special parser that accepts all valid CQL literal formats for thetimestamptype. - The special formatter
UNITS_SINCE_EPOCH, which is a special parser that reads and writes timestamps as numbers representing time units since a given epoch; the unit and the epoch to use can be specified withcodec.unitandcodec.timestamp.
For more information on patterns and pre-defined formatters, see Patterns for Formatting and Parsing in Oracle Java documentation.
For more information about CQL date, time and timestamp literals, see Date, time, and timestamp format.
The default value is the special CQL_TIMESTAMP value. When parsing, this format recognizes all CQL temporal literals; if the input is a local date or date/time, the timestamp is resolved using the time zone specified under timeZone. When formatting, this format uses the ISO_OFFSET_DATE_TIME pattern, which is compliant with both CQL and ISO-8601.
Default: "CQL_TIMESTAMP".
This setting is used in the following situations:
- When the target column is of CQL
timestamptype, or when loading data through aUSING TIMESTAMPclause, or when unloading data from awritetime()function call, and ifcodec.timestampis set toUNITS_SINCE_EPOCH, then the time unit specified here is used to convert numeric data to and from temporals. For example, if the input is 123 and the time unit specified here is SECONDS, then the input will be interpreted as 123 seconds sincecodec.epoch. - When loading, and the target CQL type is numeric, but the input is alphanumeric and represents a temporal literal, the time unit specified here will be used to convert the parsed temporal into a numeric value. For example, if the input is
2018-12-10T19:32:45Zand the time unit specified here is SECONDS, then the parsed temporal will be converted into seconds sincecodec.epoch.
All TimeUnit enum constants are valid choices.
Default: "MILLISECONDS".
Strategy to use when generating time-based (version 1) UUIDs from timestamps. Clock sequence and node ID parts of generated UUIDs are determined on a best-effort basis and are not fully compliant with RFC 4122. Valid values are:
- RANDOM: Generates UUIDs using a random number in lieu of the local clock sequence and node ID. This strategy will ensure that the generated UUIDs are unique, even if the original timestamps are not guaranteed to be unique.
- FIXED: Preferred strategy if original timestamps are guaranteed unique, since it is faster. Generates UUIDs using a fixed local clock sequence and node ID.
- MIN: Generates the smallest possible type 1 UUID for a given timestamp. Warning: this strategy doesn't guarantee uniquely generated UUIDs and should be used with caution.
- MAX: Generates the biggest possible type 1 UUID for a given timestamp. Warning: this strategy doesn't guarantee uniquely generated UUIDs and should be used with caution.
Default: "RANDOM".
Engine-specific settings. Engine settings control how workflows are configured, and notably, what is their execution ID, whether they should run in Dry-run mode, and the desired amount of concurrency.
Enable or disable dry-run mode, a test mode that runs the command but does not load data. Not applicable for unloading nor counting.
Default: false.
The maximum number of concurrent queries that should be carried in parallel.
This acts as a safeguard to prevent more queries executing in parallel than the cluster can handle, or to regulate throughput when latencies get too high. Batch statements count as one query.
When using continuous paging, also make sure to set this number to a value equal to or lesser than the number of nodes in the local datacenter multiplied by the value configured server-side for continuous_paging.max_concurrent_sessions in the cassandra.yaml configuration file (60 by default); otherwise some requests might be rejected.
The special syntax NC can be used to specify a number that is a multiple of the number of available cores, e.g. if the number of cores is 8, then 0.5C = 0.5 * 8 = 4 concurrent queries.
The default value is 'AUTO'; with this special value, DSBulk will optimize the number of concurrent queries according to the number of available cores, and the operation being executed. The actual value usually ranges from the number of cores to eight times that number.
Default: "AUTO".
Specify whether DSBulk should use data size sampling to optimize its execution engine. Only applicable for loading, ignored otherwise.
Data size sampling is done by reading a few records from the connector; in this case, the connector will be invoked twice: once to sample the data size, then again to read the entire data. This is only possible if the data source can be rewinded and read again from the beginning. If your data source does not support this – for example, because it can only be read once – then you should set this option to false.
Note that when loading from standard input, DSBulk will never perform data size sampling, regardless of the value set here.
The default value is 'true', meaning that data size sampling is enabled.
Default: true.
A unique identifier to attribute to each execution. When unspecified or empty, the engine will automatically generate identifiers of the following form: workflow_timestamp, where :
- workflow stands for the workflow type (
LOAD,UNLOAD, etc.); - timestamp is the current timestamp formatted as
uuuuMMdd-HHmmss-SSSSSS(see https://docs.oracle.com/javase/8/docs/api/java/time/format/DateTimeFormatter.html#patterns) in UTC, with microsecond precision if available, and millisecond precision otherwise.
When this identifier is user-supplied, it is important to guarantee its uniqueness; failing to do so may result in execution failures. It is also possible to provide templates here. Any format compliant with the formatting rules of String.format() is accepted, and can contain the following parameters:
%1$s: the workflow type (LOAD,UNLOAD, etc.);%2$t: the current time (with microsecond precision if available, and millisecond precision otherwise);%3$s: the JVM process PID (this parameter might not be available on some operating systems; if its value cannot be determined, a random integer will be inserted instead).
Default: null.
Executor-specific settings. Executor settings control how the DataStax Java driver is used by DSBulk, and notably, the desired amount of driver-level concurrency and throughput. These settings are for advanced users.
Enable or disable continuous paging. If the target cluster does not support continuous paging or if driver.query.consistency is not ONE or LOCAL_ONE, traditional paging will be used regardless of this setting.
Default: true.
--executor.continuousPaging.maxConcurrentQueries
--dsbulk.executor.continuousPaging.maxConcurrentQueries <number>
The maximum number of concurrent continuous paging queries that should be carried in parallel. Set this number to a value equal to or lesser than the value configured server-side for continuous_paging.max_concurrent_sessions in the cassandra.yaml configuration file (60 by default); otherwise some requests might be rejected. Settting this option to any negative value or zero will disable it.
DEPRECATED: use engine.maxConcurrentQueries instead.
Default: 60.
The maximum number of pages to retrieve. Setting this value to zero retrieves all pages available.
DEPRECATED. Use datastax-java-driver.advanced.continuous-paging.max-pages instead.
Default: 0.
--executor.continuousPaging.maxPagesPerSecond
--dsbulk.executor.continuousPaging.maxPagesPerSecond <number>
The maximum number of pages per second. Setting this value to zero indicates no limit.
DEPRECATED. Use datastax-java-driver.advanced.continuous-paging.max-pages-per-second instead.
Default: 0.
The size of the page. The unit to use is determined by the pageUnit setting. The ideal page size depends on the size of the rows being unloaded: larger page sizes may have a positive impact on throughput for small rows, and vice versa.
DEPRECATED. Use datastax-java-driver.advanced.continuous-paging.page-size instead.
Default: 5000.
The unit to use for the pageSize setting. Possible values are: ROWS, BYTES.
DEPRECATED. Use datastax-java-driver.advanced.continuous-paging.page-size-in-bytes instead.
Default: "ROWS".
The maximum number of bytes per second. When writing to the database, this means the maximum number of bytes written per second; when reading from the database, this means the maximum number of bytes read per second.
This acts as a safeguard to prevent overloading the cluster. Reduce this value when the throughput for reads and writes cannot match the throughput of connectors, and latencies get too high; this is usually a sign that the workflow engine is not well calibrated and will eventually run out of memory, or some queries will timeout.
This setting applies a "hard" limit to the gloabl throughput, capping it at a fixed value. If you need a a soft throughput limit, you should use maxInFlight instead.
Note that this setting is implemented by a semaphore and may block application threads if there are too many in-flight requests.
Setting this option to any negative value or zero will disable it.
Values for this option should either be valid long integers, or use HOCON's size-in-bytes format, e.g. 1234, 1K or 5 kibibytes.
Default: -1.
The maximum number of "in-flight" queries, or maximum number of concurrent requests waiting for a response from the server. When writing to the database, batch statements count as one request. When reading from the database, each request for the next pages count as one request.
This acts as a safeguard to prevent overloading the cluster. Reduce this value when the throughput for reads and writes cannot match the throughput of connectors, and latencies get too high; this is usually a sign that the workflow engine is not well calibrated and will eventually run out of memory, or some queries will timeout.
This setting applies a "soft" limit to the gloabl throughput, without capping it at a fixed value. If you need a fixed maximum throughput, you should use maxPerSecond instead.
Note that this setting is implemented by a semaphore and may block application threads if there are too many in-flight requests.
Setting this option to any negative value or zero will disable it.
Default: -1.
The maximum number of concurrent operations per second. When writing to the database, this means the maximum number of writes per second (batch statements are counted by the number of statements included); when reading from the database, this means the maximum number of rows per second.
This acts as a safeguard to prevent overloading the cluster. Reduce this value when the throughput for reads and writes cannot match the throughput of connectors, and latencies get too high; this is usually a sign that the workflow engine is not well calibrated and will eventually run out of memory, or some queries will timeout.
When connecting to DataStax Astra clusters, a rate limit is always enforced. By default, the limit is 4,096 operations per second and per coordinator; therefore, if no rate limit is set, and the cluster is an Astra cluster, DSBulk will automatically apply an appropriate limit and log a message.
This setting applies a "hard" limit to the gloabl throughput, capping it at a fixed value. If you need a a soft throughput limit, you should use maxInFlight instead.
Note that this setting is implemented by a semaphore and may block application threads if there are too many in-flight requests.
Setting this option to any negative value or zero will disable it.
Default: -1.
Log and error management settings.
The maximum number of errors to tolerate before aborting the entire operation. This can be expressed either as an absolute number of errors - in which case, set this to an integer greater than or equal to zero; or as a percentage of total rows processed so far - in which case, set this to a string of the form N%, where N is a decimal number between 0 and 100 exclusive (e.g. "20%"). Setting this value to any negative integer disables this feature (not recommended).
Default: 100.
The writable directory where all log files will be stored; if the directory specified does not exist, it will be created. URLs are not acceptable (not even file:/ URLs). Log files for a specific run, or execution, will be located in a sub-directory under the specified directory. Each execution generates a sub-directory identified by an "execution ID". See engine.executionId for more information about execution IDs. Relative paths will be resolved against the current working directory. Also, for convenience, if the path begins with a tilde (~), that symbol will be expanded to the current user's home directory.
Default: "./logs".
The desired level of verbosity. Valid values are:
quiet: DSBulk will only log WARN and ERROR messages.normal: DSBulk will log a few INFO messages, as well as WARN and ERROR messages.high: DSBulk will also print some DEBUG messages at the beginning of the operation, such as DSBulk's settings, inferred query, and the read and write concurrency.max: DSBulk will print numerous DEBUG messages from itself, the driver, and from some important libraries (Netty and Reactor).
Verbosity levels quiet, normal and high are suitable to use in a production environment. Verbosity high is the recommended level to diagnose problems related to configuration and/or performance in production environments. Verbosity max, however, should only be used for debugging, and preferably on small amounts of data; otherwise it could print hundreds of gigabytes of text to the main log file and to the console.
Default: "normal".
Whether or not to use ANSI colors and other escape sequences in log messages printed to the console. Valid values are:
normal: this is the default option. DSBulk will only use ANSI when the terminal is:- compatible with ANSI escape sequences; all common terminals on *nix and BSD systems, including MacOS, are ANSI-compatible, and some popular terminals for Windows (Mintty, MinGW);
- a standard Windows DOS command prompt (ANSI sequences are translated on the fly).
force: DSBulk will use ANSI, even if the terminal has not been detected as ANSI-compatible.disabled: DSBulk will not use ANSI.
Default: "normal".
Whether to enable checkpointing for the current operation. When set to true (the default), DSBulk will track records that were processed and will produce a checkpoint file at the end of the operation. The checkpoint file can then be used later on to resume the same operation, if not all records were processed, or if the operation was interrupted.
Note that a checkpointed operation consumes more memory, and is slightly slower. If you don't need checkpointing, you should disable it.
Default: true.
The path to a checkpoint file to resume an operation from. If this option is set, and depending on the replay strategy, then only unprocessed and/or failed data will be re-processed.
When using a checkpoint file to resume an operation, make sure that both operations target the same dataset:
- When loading, make sure that the files to load weren't renamed or moved, otherwise all files would be considered new and loaded entirely. Also, if the file contents have changed, new records may go unnoticed, or cause other records to be processed twice.
- When unloading, make sure that the read query, the token distribution across the ring, the number of splits (see
schema.splits) and the data to read are all the same across operations, otherwise the unloaded data could be inconsistent.
Default: null.
The replay strategy to use when resuming an operation from a checkpoint file. Valid values are:
resume: DSBulk will only process new records from resources that weren't consumed entirely. Records that were already processed will be ignored, including rejected ones (rejected records are always written to bad files). This is the safest option when loading if the operation is not idempotent.retry: this is the default option. DSBulk will process new and rejected records from resources that weren't consumed entirely. Note that this strategy may result in some rows being inserted twice and thus should only be used if the operation is idempotent.retryAll: likeretry, DSBulk will process new and rejected records, but unlikeretry, it will process all resources, including those marked as consumed entirely. Note that this strategy may result in some rows being inserted twice and thus should only be used if the operation is idempotent.
Default: "retry".
The maximum number of query warnings to log before muting them. Query warnings are sent by the server (for example, if the number of statements in a batch is greater than the warning threshold configured on the server). They are useful to diagnose suboptimal configurations but tend to be too invasive, which is why DSBulk by default will only log the 50 first query warnings; any subsequent warnings will be muted and won't be logged at all. Setting this value to any negative integer disables this feature (not recommended).
Default: 50.
The maximum length for a result set value. Result set values longer than this value will be truncated.
Setting this value to -1 makes the maximum length for a result set value unlimited (not recommended).
Default: 50.
The maximum number of result set values to print. If the row has more result set values than this limit, the exceeding values will not be printed.
Setting this value to -1 makes the maximum number of result set values unlimited (not recommended).
Default: 50.
Whether to print record sources in debug files. When set to true (the default), debug files will contain, for each record that failed to be processed, its original source, such as the text line that the record was parsed from.
Furthermore, when loading, enabling this option also enables the creation of so-called "bad files", that is, files containing the original lines that could not be inserted; these files could then be used as the data source of a subsequent load operation that would load only the failed records.
This feature is useful to locate failed records more easily and diagnose processing failures – especially if the original data source is a remote one, such as an FTP or HTTP URL.
But for this feature to be possible, record sources must be kept in memory until the record is fully processed. For large record sizes (over 1 megabyte per record), retaining record sources in memory could put a high pressure on the JVM heap, thus exposing the operation to out-of-memory errors. This phenomenon is exacerbated when batching is enabled. If you are experiencing such errors, consider disabling this option.
Note that, regardless of the value of this option, DSBulk will always print the record's resource – that is, the file name or the database table where it came from – and the record's position – that is, the ordinal position of the record inside the resource, when available (for example, this could be the line number in a CSV file).
Default: true.
The desired log level. Valid values are:
- ABRIDGED: Print only basic information in summarized form.
- NORMAL: Print basic information in summarized form, and the statement's query string, if available. For batch statements, this verbosity level also prints information about the batch's inner statements.
- EXTENDED: Print full information, including the statement's query string, if available, and the statement's bound values, if available. For batch statements, this verbosity level also prints all information available about the batch's inner statements.
Default: "EXTENDED".
The maximum length for a bound value. Bound values longer than this value will be truncated.
Setting this value to -1 makes the maximum length for a bound value unlimited (not recommended).
Default: 50.
The maximum number of bound values to print. If the statement has more bound values than this limit, the exceeding values will not be printed.
Setting this value to -1 makes the maximum number of bound values unlimited (not recommended).
Default: 50.
The maximum number of inner statements to print for a batch statement. Only applicable for batch statements, ignored otherwise. If the batch statement has more children than this value, the exceeding child statements will not be printed.
Setting this value to -1 disables this feature (not recommended).
Default: 10.
The maximum length for a query string. Query strings longer than this value will be truncated.
Setting this value to -1 disables this feature (not recommended).
Default: 500.
Monitoring-specific settings.
The report interval. DSBulk will print useful metrics about the ongoing operation at this rate; for example, if this value is set to 10 seconds, then DSBulk will print metrics every ten seconds. Valid values: any value specified in HOCON duration syntax, but durations lesser than one second will be rounded up to 1 second.
Default: "5 seconds".
Enable or disable console reporting. If enabled, DSBulk will print useful metrics about the ongoing operation to standard error; the metrics will be refreshed at reportRate. Displayed information includes: total records, failed records, throughput, latency, and if available, average batch size. Note that when log.verbosity is set to quiet (0), DSBulk will disable the console reporter regardless of the value specified here. The default is true (print ongoing metrics to the console).
Default: true.
Enable or disable CSV reporting. If enabled, CSV files containing metrics will be generated in the designated log directory. Driver metrics can also be exported, but they are disabled by default; see monitoring.jmx for details for details about how to enable them.
Default: false.
The time unit used when printing latency durations. For example, if this unit is MILLISECONDS, then the latencies will be displayed in milliseconds. Valid values: all TimeUnit enum constants.
Default: "MILLISECONDS".
The expected total number of reads. Optional, but if set, the console reporter will also print the overall achievement percentage. Setting this value to -1 disables this feature.
Default: -1.
The expected total number of writes. Optional, but if set, the console reporter will also print the overall achievement percentage. Setting this value to -1 disables this feature.
Default: -1.
Enable or disable JMX reporting. Note that to enable remote JMX reporting, several properties must also be set in the JVM during launch. This is accomplished via the DSBULK_JAVA_OPTS environment variable.
Driver metrics can also be exposed; note however that by default, all driver metrics are disabled. You can enable them with the following driver settings:
datastax-java-driver.advanced.metrics.session.enabledshould contain a list of session-level metric names to enable;datastax-java-driver.advanced.metrics.node.enabledshould contain a list of node-level metric names to enable. Driver metrics appear under a folder named after the session name (by default in DSBulk, the session name is simply "driver").
Default: true.
The job name to use. DSBulk will add a label "job" with this value to each exported metric. This is also the job name used when pushing metrics to a PushGateway. The default is "DSBulk". See https://github.com/prometheus/pushgateway#about-the-job-and-instance-labels for more information.
Default: "DSBulk".
A set of static labels to add to each exported metric, in both pull and push modes. Note that DSBulk automatically adds the following labels:
operation_idis set to the current operation ID (a.k.a. execution ID, seeengine.executionId);jobis set to the job name (as defined bymonitoring.prometheus.job, by default "DSBulk");application_nameis set to "DataStax Bulk Loader" followed by the operation ID;application_versionis set to the DSBulk's version;driver_versionis set to the DataStax Java driver version;client_idis set to DSBulk's client UUID.
The last four labels correspond to values that DSBulk also passes to the driver, which in turn uses the same info to connect to Cassandra. This makes it possible to correlate data sent by the driver to Cassandra with data sent by DSBulk to Prometheus.
-prometheus,
--monitoring.prometheus.pull.enabled
--dsbulk.monitoring.prometheus.pull.enabled <boolean>
Enable or disable exposing metrics to Prometheus in the traditional pull model (scraping). If enabled, all DSBulk and metrics will be accessible at an (unsecured) HTTP endpoint. Driver metrics can also be exported, but they are disabled by default; see monitoring.jmx for details about how to enable them.
Default: false.
The hostname that the metrics HTTP server should bind to. Leave empty to have the server bind to the wildcard address (0.0.0.0).
Default: <unspecified>.
The port that the metrics HTTP server should bind to.
Default: 8080.
Enabled or disable pushing metrics to a PushGateway. If enabled, DSBulk will push metrics to this URL at the end of the operation. Note that not all metrics are exported when pushing to a PushGateway; only some high-level ones are, including the total time elapsed, the number of records processed and the number of rows written or read. In particular, driver metrics are currently not pushed.
Default: false.
--monitoring.prometheus.push.groupBy.instance
--dsbulk.monitoring.prometheus.push.groupBy.instance <boolean>
Whether to add an instance grouping key to exported metrics. If enabled, DSBulk adds an "instance" grouping key with its value set to the machine's IP address to the exported metrics. This will effectively group metrics by instance, rather than by job. See https://github.com/prometheus/pushgateway#about-the-job-and-instance-labels for more information.
Default: false.
--monitoring.prometheus.push.groupBy.keys
--dsbulk.monitoring.prometheus.push.groupBy.keys <map<string,string>>
A set of static extra keys to add to the grouping keys. Note that grouping keys are also added as labels to each exported metric in push mode.
--monitoring.prometheus.push.groupBy.operation
--dsbulk.monitoring.prometheus.push.groupBy.operation <boolean>
Whether to add the operation ID as a grouping key to exported metrics. If enabled, DSBulk adds an "operation_id" grouping key with its value set to the current operation ID (see engine.executionId) to the exported metrics. This will effectively group metrics by operation, rather than by job.
Default: false.
The password to authenticate against the push gateway, using basic HTTP auth. Leave empty to use unautheticated HTTP requests.
Default: <unspecified>.
The base URL of a Prometheus PushGateway server, e.g. http://pushgateway.example.org:9091 (don't include the "/metrics" path).
Default: "http://localhost:9091".
The username to authenticate against the push gateway, using basic HTTP auth. Leave empty to use unautheticated HTTP requests.
Default: <unspecified>.
The time unit used when printing throughput rates. For example, if this unit is SECONDS, then the throughput will be displayed in rows per second. Valid values: all TimeUnit enum constants.
Default: "SECONDS".
Whether or not to track the throughput in bytes. When enabled, DSBulk will track and display the number of bytes sent or received per second. While useful to evaluate how much data is actually being transferred, computing such metrics is CPU-intensive and may slow down the operation. This is why it is disabled by default. Also note that the heuristic used to compute data sizes is not 100% accurate and sometimes underestimates the actual size.
Default: false.
Runner-specific settings. Runner settings control how DSBulk parses command lines and reads its configuration.
Whether to prompt for passwords when they are missing from configuration files. When this option is true (the default value), if a login or username is present in the configuration, but not its corresponding password, DSBulk will prompt for it.
Prompting from passwords require interactive shells; if the standard input is not connected to a terminal, no passwords will be prompted, even if this option is true. You should only disable this feature if DSBulk mistankenly assumes that it is running in an interactive shell.
Default: true.
Settings applicable for the count workflow, ignored otherwise.
Which kind(s) of statistics to compute. Only applicaple for the count workflow, ignored otherwise. Possible values are:
global: count the total number of rows in the table.ranges: count the total number of rows per token range in the table.hosts: count the total number of rows per hosts in the table.partitions: count the total number of rows in the N biggest partitions in the table. When using this mode, you can chose how many partitions to track with thenumPartitionssetting.
Default: ["global"].
The number of distinct partitions to count rows for. Only applicaple for the count workflow when stats.modes contains partitions, ignored otherwise.
Default: 10.
The settings below are just a subset of all the configurable options of the driver, and provide an optimal driver configuration for DSBulk for most use cases.
See the Java Driver configuration reference for instructions on how to configure the driver properly.
Note: driver settings always start with prefix datastax-java-driver; on the command line only, it is possible to abbreviate this prefix to just driver, as shown below.
The driver session name. DSBulk simply calls it "driver". The session name is printed by all driver log messages, between square brackets.
Default: "driver".
The contact points to use for the initial connection to the cluster.
These are addresses of Cassandra nodes that the driver uses to discover the cluster topology. Only one contact point is required (the driver will retrieve the address of the other nodes automatically), but it is usually a good idea to provide more than one contact point, because if that single contact point is unavailable, the driver cannot initialize itself correctly.
This must be a list of strings with each contact point specified as "host" or "host:port". If the specified host doesn't have a port, the default port specified in basic.default-port will be used. Note that Cassandra 3 and below and DSE 6.7 and below require all nodes in a cluster to share the same port (see CASSANDRA-7544).
Valid examples of contact points are:
- IPv4 addresses with ports:
[ "192.168.0.1:9042", "192.168.0.2:9042" ] - IPv4 addresses without ports:
[ "192.168.0.1", "192.168.0.2" ] - IPv6 addresses with ports:
[ "fe80:0:0:0:f861:3eff:fe1d:9d7b:9042", "fe80:0:0:f861:3eff:fe1d:9d7b:9044:9042" ] - IPv6 addresses without ports:
[ "fe80:0:0:0:f861:3eff:fe1d:9d7b", "fe80:0:0:f861:3eff:fe1d:9d7b:9044" ] - Host names with ports:
[ "host1.com:9042", "host2.com:9042" ] - Host names without ports:
[ "host1.com", "host2.com:" ]
If the host is a DNS name that resolves to multiple A-records, all the corresponding addresses will be used. Avoid using "localhost" as the host name (since it resolves to both IPv4 and IPv6 addresses on some platforms).
The heuristic to determine whether or not a contact point is in the form "host" or "host:port" is not 100% accurate for some IPv6 addresses; you should avoid ambiguous IPv6 addresses such as fe80::f861:3eff:fe1d:1234, because such a string can be seen either as a combination of IP fe80::f861:3eff:fe1d with port 1234, or as IP fe80::f861:3eff:fe1d:1234 without port. In such cases, DSBulk will not change the contact point. This issue can be avoided by providing IPv6 addresses in full form, e.g. if instead of fe80::f861:3eff:fe1d:1234 you provide fe80:0:0:0:0:f861:3eff:fe1d:1234, then the string is unequivocally parsed as IP fe80:0:0:0:0:f861:3eff:fe1d with port 1234.
Note: on Cloud deployments, DSBulk automatically sets this option to an empty list, as contact points are not allowed to be explicitly provided when connecting to DataStax Astra databases.
Default: ["127.0.0.1:9042"].
The default port to use for basic.contact-points, when a host is specified without port. Note that Cassandra 3 and below and DSE 6.7 and below require all nodes in a cluster to share the same port (see CASSANDRA-7544). If this setting is not specified, the default port will be 9042.
Default: 9042.
-b,
--driver.basic.cloud.secure-connect-bundle
--datastax-java-driver.basic.cloud.secure-connect-bundle <string>
The location of the secure bundle used to connect to a Datastax Astra database. This setting must be a path on the local filesystem or a valid URL.
Examples:
"/path/to/bundle.zip" # path on *Nix systems
"./path/to/bundle.zip" # path on *Nix systems, relative to workding directory
"~/path/to/bundle.zip" # path on *Nix systems, relative to home directory
"C:\\path\\to\\bundle.zip" # path on Windows systems,
# note that you need to escape backslashes in HOCON
"file:/a/path/to/bundle.zip" # URL with file protocol
"http://host.com/bundle.zip" # URL with HTTP protocol
Note: if you set this to a non-null value, DSBulk assumes that you are connecting to an DataStax Astra database; in this case, you should not set any of the following settings because they are not compatible with Cloud deployments:
datastax-java-driver.basic.contact-pointsdatastax-java-driver.basic.request.consistencydatastax-java-driver.advanced.ssl-engine-factory.*
If you do so, a log will be emitted and the setting will be ignored.
Default: null.
How long the driver waits for a request to complete. This is a global limit on the duration of a session.execute() call, including any internal retries the driver might do. By default, this value is set very high because DSBulk is optimized for good throughput, rather than good latencies.
Default: "5 minutes".
The consistency level to use for all queries. Note that stronger consistency levels usually result in reduced throughput. In addition, any level higher than ONE will automatically disable continuous paging, which can dramatically reduce read throughput.
Valid values are: ANY, LOCAL_ONE, ONE, TWO, THREE, LOCAL_QUORUM, QUORUM, EACH_QUORUM, ALL.
Note: on Cloud deployments, the only accepted consistency level when writing is LOCAL_QUORUM. Therefore, the default value is LOCAL_ONE, except when loading in Cloud deployments, in which case the default is automatically changed to LOCAL_QUORUM.
Default: "LOCAL_ONE".
--driver.basic.request.serial-consistency
--datastax-java-driver.basic.request.serial-consistency <string>
The serial consistency level. The allowed values are SERIAL and LOCAL_SERIAL.
Default: "LOCAL_SERIAL".
--driver.basic.request.default-idempotence
--datastax-java-driver.basic.request.default-idempotence <boolean>
The default idempotence for all queries executed in DSBulk. Setting this to false will cause all write failures to not be retried.
Default: true.
The page size. This controls how many rows will be retrieved simultaneously in a single network roundtrip (the goal being to avoid loading too many results in memory at the same time). If there are more results, additional requests will be used to retrieve them (either automatically if you iterate with the sync API, or explicitly with the async API's fetchNextPage method). If the value is 0 or negative, it will be ignored and the request will not be paged.
Default: 5000.
--driver.basic.load-balancing-policy.class
--datastax-java-driver.basic.load-balancing-policy.class <string>
The load balancing policy class to use. If it is not qualified, the driver assumes that it resides in the package com.datastax.oss.driver.internal.core.loadbalancing.
DSBulk uses a special policy that infers the local datacenter from the contact points. You can also specify a custom class that implements LoadBalancingPolicy and has a public constructor with two arguments: the DriverContext and a String representing the profile name.
Default: "com.datastax.oss.driver.internal.core.loadbalancing.DcInferringLoadBalancingPolicy".
-dc,
--driver.basic.load-balancing-policy.local-datacenter
--datastax-java-driver.basic.load-balancing-policy.local-datacenter <string>
The datacenter that is considered "local": the default load balancing policy will only include nodes from this datacenter in its query plans. Set this to a non-null value if you want to force the local datacenter; otherwise, the DcInferringLoadBalancingPolicy used by default by DSBulk will infer the local datacenter from the provided contact points.
Default: null.
--driver.basic.load-balancing-policy.evaluator.class
--datastax-java-driver.basic.load-balancing-policy.evaluator.class <string>
An optional custom filter to include/exclude nodes. If present, it must be the fully-qualified name of a class that implements java.util.function.Predicate<Node>, and has a public constructor taking two arguments: a DriverContext instance and a String representing the current execution profile name.
The predicate's test(Node) method will be invoked each time the policy processes a topology or state change: if it returns false, the node will be set at distance IGNORED (meaning the driver won't ever connect to it), and never included in any query plan.
By default, DSBulk ships with a node filter implementation that honors the following settings:
datastax-java-driver.basic.load-balancing-policy.evaluator.allow: a list of host names or host addresses that should be allowed.datastax-java-driver.basic.load-balancing-policy.evaluator.deny: a list of host names or host addresses that should be denied.
See the description of the above settings for more details.
Default: "com.datastax.oss.dsbulk.workflow.commons.policies.lbp.SimpleNodeDistanceEvaluator".
-allow,
--driver.basic.load-balancing-policy.evaluator.allow
--datastax-java-driver.basic.load-balancing-policy.evaluator.allow <list<string>>
An optional list of host names or host addresses that should be allowed to connect. See datastax-java-driver.basic.contact-points for a full description of accepted formats.
This option only has effect when the setting datastax-java-driver.basic.load-balancing-policy.evaluator.class refers to DSBulk's default node filter implementation: com.datastax.oss.dsbulk.workflow.commons.policies.lbp.SimpleNodeDistanceEvaluator.
Note: this option is not compatible with DataStax Astra databases.
Default: [].
-deny,
--driver.basic.load-balancing-policy.evaluator.deny
--datastax-java-driver.basic.load-balancing-policy.evaluator.deny <list<string>>
An optional list of host names or host addresses that should be denied to connect. See datastax-java-driver.basic.contact-points for a full description of accepted formats.
This option only has effect when the setting datastax-java-driver.basic.load-balancing-policy.evaluator.class refers to DSBulk's default node filter implementation: com.datastax.oss.dsbulk.workflow.commons.policies.lbp.SimpleNodeDistanceEvaluator.
Note: this option is not compatible with DataStax Astra databases.
Default: [].
The native protocol version to use. If this option is absent, the driver looks up the versions of the nodes at startup (by default in system.peers.release_version), and chooses the highest common protocol version. For example, if you have a mixed cluster with Apache Cassandra 2.1 nodes (protocol v3) and Apache Cassandra 3.0 nodes (protocol v3 and v4), then protocol v3 is chosen. If the nodes don't have a common protocol version, initialization fails. If this option is set, then the given version will be used for all connections, without any negotiation or downgrading. If any of the contact points doesn't support it, that contact point will be skipped. Once the protocol version is set, it can't change for the rest of the driver's lifetime; if an incompatible node joins the cluster later, connection will fail and the driver will force it down (i.e. never try to connect to it again).
Default: null.
The name of the algorithm used to compress protocol frames. The possible values are: lz4, snappy or none to indicate no compression (this is functionally equivalent to omitting the option).
Default: "none".
--driver.advanced.connection.connect-timeout
--datastax-java-driver.advanced.connection.connect-timeout <string>
The timeout to use when establishing driver connections. This timeout is for controlling how long the driver will wait for the underlying channel to actually connect to the server. This is not the time limit for completing protocol negotiations, only the time limit for establishing a channel connection.
Default: "30 seconds".
--driver.advanced.connection.init-query-timeout
--datastax-java-driver.advanced.connection.init-query-timeout <string>
The timeout to use for internal queries that run as part of the initialization process, just after we open a connection. If this timeout fires, the initialization of the connection will fail. If this is the first connection ever, the driver will fail to initialize as well, otherwise it will retry the connection later.
Default: "30 seconds".
--driver.advanced.connection.pool.local.size
--datastax-java-driver.advanced.connection.pool.local.size <number>
The number of connections in the pool for nodes considered as local.
Default: 8.
--driver.advanced.connection.pool.remote.size
--datastax-java-driver.advanced.connection.pool.remote.size <number>
The number of connections in the pool for nodes considered as remote. Note that the default load balancing policy used by DSBulk never considers remote nodes, so this setting has no effect when using the default load balancing policy.
Default: 8.
--driver.advanced.connection.max-requests-per-connection
--datastax-java-driver.advanced.connection.max-requests-per-connection <number>
The maximum number of requests that can be executed concurrently on a connection. This must be between 1 and 32768.
Default: 32768.
The class of the authentication provider. If it is not qualified, the driver assumes that it resides in one of the following packages:
com.datastax.oss.driver.internal.core.authcom.datastax.dse.driver.internal.core.auth
The DSE driver provides 3 implementations out of the box:
PlainTextAuthProvider: uses plain-text credentials. It requires theusernameandpasswordoptions, and optionally, anauthorization-id(for DSE clusters only).DseGssApiAuthProvider: provides GSSAPI authentication for DSE clusters secured withDseAuthenticator. Read the javadocs of this authenticator for detailed instructions.
You can also specify a custom class that implements AuthProvider and has a public constructor with a DriverContext argument (to simplify this, the driver provides two abstract classes that can be extended: PlainTextAuthProviderBase and DseGssApiAuthProviderBase).
Default: null.
-u,
--driver.advanced.auth-provider.username
--datastax-java-driver.advanced.auth-provider.username <string>
The username to use to authenticate against a cluster with authentication enabled. Providers that accept this setting:
PlainTextAuthProvider
Default: null.
-p,
--driver.advanced.auth-provider.password
--datastax-java-driver.advanced.auth-provider.password <string>
The password to use to authenticate against a cluster with authentication enabled. Providers that accept this setting:
PlainTextAuthProvider
Default: null.
--driver.advanced.auth-provider.authorization-id
--datastax-java-driver.advanced.auth-provider.authorization-id <string>
An authorization ID allows the currently authenticated user to act as a different user (proxy authentication). Providers that accept this setting:
DsePlainTextAuthProviderDseGssApiAuthProvider
Default: null.
--driver.advanced.ssl-engine-factory.class
--datastax-java-driver.advanced.ssl-engine-factory.class <string>
The class of the SSL engine factory. If it is not qualified, the driver assumes that it resides in the package com.datastax.oss.driver.internal.core.ssl. The driver provides a single implementation out of the box: DefaultSslEngineFactory, that uses the JDK's built-in SSL implementation.
You can also specify a custom class that implements SslEngineFactory and has a public constructor with a DriverContext argument.
Default: null.
--driver.advanced.ssl-engine-factory.cipher-suites
--datastax-java-driver.advanced.ssl-engine-factory.cipher-suites <list<string>>
The cipher suites to enable when creating an SSLEngine for a connection. This setting is only required when using the default SSL factory. If it is not present, the driver won't explicitly enable cipher suites on the engine, which according to the JDK documentations results in "a minimum quality of service".
Default: null.
--driver.advanced.ssl-engine-factory.hostname-validation
--datastax-java-driver.advanced.ssl-engine-factory.hostname-validation <boolean>
Whether or not to require validation that the hostname of the server certificate's common name matches the hostname of the server being connected to. This setting is only required when using the default SSL factory. If not set, defaults to true.
Default: true.
--driver.advanced.ssl-engine-factory.truststore-path
--datastax-java-driver.advanced.ssl-engine-factory.truststore-path <string>
The locations used to access truststore contents. If either truststore-path or keystore-path are specified, the driver builds an SSLContext from these files. This setting is only required when using the default SSL factory. This setting is only required when using the default SSL factory. If neither option is specified, the default SSLContext is used, which is based on system property configuration.
Default: null.
--driver.advanced.ssl-engine-factory.truststore-password
--datastax-java-driver.advanced.ssl-engine-factory.truststore-password <string>
The password used to access truststore contents. This setting is only required when using the default SSL factory.
Default: null.
--driver.advanced.ssl-engine-factory.keystore-path
--datastax-java-driver.advanced.ssl-engine-factory.keystore-path <string>
The locations used to access keystore contents. If either truststore-path or keystore-path are specified, the driver builds an SSLContext from these files. This setting is only required when using the default SSL factory. If neither option is specified, the default SSLContext is used, which is based on system property configuration.
Default: null.
--driver.advanced.ssl-engine-factory.keystore-password
--datastax-java-driver.advanced.ssl-engine-factory.keystore-password <string>
The password used to access keystore contents. This setting is only required when using the default SSL factory.
Default: null.
The class of the retry policy. If it is not qualified, the driver assumes that it resides in the package com.datastax.oss.driver.internal.core.retry. DSBulk uses by default a special retry policy that opinionately retries most errors up to max-retries times.
You can also specify a custom class that implements RetryPolicy and has a public constructor with two arguments: the DriverContext and a String representing the profile name.
Default: "com.datastax.oss.dsbulk.workflow.commons.policies.retry.MultipleRetryPolicy".
-maxRetries,
--driver.advanced.retry-policy.max-retries
--datastax-java-driver.advanced.retry-policy.max-retries <number>
How many times to retry a failed query. Only valid for use with DSBulk's default retry policy (MultipleRetryPolicy).
Default: 10.
--driver.advanced.resolve-contact-points
--datastax-java-driver.advanced.resolve-contact-points <boolean>
Whether to resolve the addresses passed to basic.contact-points.
If this is true, addresses are created with InetSocketAddress(String, int): the host name will be resolved the first time, and the driver will use the resolved IP address for all subsequent connection attempts. If this is false, addresses are created with InetSocketAddress.createUnresolved(): the host name will be resolved again every time the driver opens a new connection. This is useful for containerized environments where DNS records are more likely to change over time (note that the JVM and OS have their own DNS caching mechanisms, so you might need additional configuration beyond the driver).
This option only applies to the contact points specified in the configuration. It has no effect on dynamically discovered peers: the driver relies on Cassandra system tables, which expose raw IP addresses. Use a custom address translator (see advanced.address-translator) to convert them to unresolved addresses (if you're in a containerized environment, you probably already need address translation anyway).
Default: true.
--driver.advanced.address-translator.class
--datastax-java-driver.advanced.address-translator.class <string>
The class of the translator. If it is not qualified, the driver assumes that it resides in the package com.datastax.oss.driver.internal.core.addresstranslation.
The driver provides the following implementations out of the box:
PassThroughAddressTranslator: returns all addresses unchanged
You can also specify a custom class that implements AddressTranslator and has a public constructor with a DriverContext argument.
Default: "PassThroughAddressTranslator".
--driver.advanced.timestamp-generator.class
--datastax-java-driver.advanced.timestamp-generator.class <string>
The class of the microsecond timestamp generator. If it is not qualified, the driver assumes that it resides in the package com.datastax.oss.driver.internal.core.time.
The driver provides the following implementations out of the box:
AtomicTimestampGenerator: timestamps are guaranteed to be unique across all client threads.ThreadLocalTimestampGenerator: timestamps that are guaranteed to be unique within each thread only.ServerSideTimestampGenerator: do not generate timestamps, let the server assign them.
You can also specify a custom class that implements TimestampGenerator and has a public constructor with two arguments: the DriverContext and a String representing the profile name.
Default: "AtomicTimestampGenerator".
--driver.advanced.continuous-paging.page-size
--datastax-java-driver.advanced.continuous-paging.page-size <number>
The page size. The value specified here can be interpreted in number of rows or in number of bytes, depending on the unit defined with page-unit (see below). It controls how many rows (or how much data) will be retrieved simultaneously in a single network roundtrip (the goal being to avoid loading too many results in memory at the same time). If there are more results, additional requests will be used to retrieve them. The default is the same as the driver's normal request page size, i.e., 5000 (rows).
Default: 5000.
--driver.advanced.continuous-paging.page-size-in-bytes
--datastax-java-driver.advanced.continuous-paging.page-size-in-bytes <boolean>
Whether the page-size option should be interpreted in number of rows or bytes. The default is false, i.e., the page size will be interpreted in number of rows.
Default: false.
--driver.advanced.continuous-paging.max-pages
--datastax-java-driver.advanced.continuous-paging.max-pages <number>
The maximum number of pages to return. The default is zero, which means retrieve all pages.
Default: 0.
--driver.advanced.continuous-paging.max-pages-per-second
--datastax-java-driver.advanced.continuous-paging.max-pages-per-second <number>
Returns the maximum number of pages per second. The default is zero, which means no limit.
Default: 0.
--driver.advanced.continuous-paging.max-enqueued-pages
--datastax-java-driver.advanced.continuous-paging.max-enqueued-pages <number>
The maximum number of pages that can be stored in the local queue. This value must be positive. The default is 4.
Default: 4.
--driver.advanced.continuous-paging.timeout.first-page
--datastax-java-driver.advanced.continuous-paging.timeout.first-page <string>
How long to wait for the coordinator to send the first page.
Default: "5 minutes".
--driver.advanced.continuous-paging.timeout.other-pages
--datastax-java-driver.advanced.continuous-paging.timeout.other-pages <string>
How long to wait for the coordinator to send subsequent pages.
Default: "5 minutes".
The heartbeat interval. If a connection stays idle for that duration (no reads), the driver sends a dummy message on it to make sure it's still alive. If not, the connection is trashed and replaced.
Default: "1 minute".
How long the driver waits for the response to a heartbeat. If this timeout fires, the heartbeat is considered failed.
Default: "1 minute".
--driver.advanced.metrics.session.enabled
--datastax-java-driver.advanced.metrics.session.enabled <list>
The session-level metrics to enable. Available metrics are:
- bytes-sent
- bytes-received
- connected-nodes
- cql-requests
- cql-client-timeouts
Default: [].
The node-level metrics to enable. Available metrics are:
- pool.open-connections
- pool.in-flight
- bytes-sent
- bytes-received
- cql-messages
- errors.request.unsent
- errors.request.aborted
- errors.request.write-timeouts
- errors.request.read-timeouts
- errors.request.unavailables
- errors.request.others
- retries.total
- retries.aborted
- retries.read-timeout
- retries.write-timeout
- retries.unavailable
- retries.other
- ignores.total
- ignores.aborted
- ignores.read-timeout
- ignores.write-timeout
- ignores.unavailable
- ignores.other
- errors.connection.init
- errors.connection.auth
Default: [].