dsbulk
dsbulk copied to clipboard
DataStax Bulk Loader (DSBulk) is an open-source, Apache-licensed, unified tool for loading into and unloading from Apache Cassandra(R), DataStax Astra and DataStax Enterprise (DSE)
dsbulk version: 1.10.0 I'm unloading 10000000 rows from C* table with by using LIMIT query `dsbulk unload -query "SELECT col1, col2 FROM keyspace.table LIMIT 10000000" -maxRecords 1000000 -header false -verbosity...
We have different scenarios where we needed to use file as source to put it in where clause but its not allowed. ``` [solr2:0] automaton@ip-172-31-19-246:~$ cat test/output-000001.csv str_num,day_no,transaction_uid,trans_typ,sequence_no 006,7,14d6f78c-c468-4b71-84ce-0a8009bf3dc1,SALE,seq3 006,7,14d6f78c-c468-4b71-84ce-0a8009bf3dc1,SALE,seq4...
DSBulk DELETE can not accept any ranges on the clustering column where as SELECT does Also cqlsh can work with the same Consider this is the table from where customer...
dsbulk.cmd uses ```%~DPS0``` which returns the short name. If the folder name is long or contains a space, dsbulk is not able to find the libraries. 
#### Table ``` CREATE TABLE baselines.map_text_dsbulk ( k int PRIMARY KEY, v frozen ); ``` #### Add data to the table and validate ``` token@cqlsh:baselines> create table if not exists...
Hello, I am trying to unload a keyspace table. When using cqlsh to export the table, I have the following output: `111111111,200,0,"{1: 505, 2: 504, 3: 1023, 4: 506, 5:...
When ingesting `VECTOR` data from a JSON, dsbulk (v 1.11) fails for "floats" which are represented with too many digits. They end up being double, which seems to cause unrecoverable...
trying dsbulk with query: ``` SELECT COUNT(1), SUM(size) FROM dummy WHERE ck1='%s' AND pk1='%s' AND toUnixTimestamp(ts)
On a schema like this ``` CREATE TABLE cassio_tutorials.my_vector_db_table ( row_id text PRIMARY KEY, attributes_blob text, body_blob text, metadata_s map, vector vector ); ``` it happens that `dsbulk unload` gets...
LogManager has a method to determine whether an error associated with a processed item is "unrecoverable". This method should imho be completely revisited. E.g. it is considering OverloadedException as unrecoverable,...