我在一个文件夹中卸载了100多个CSV文件。当我试图使用DSBULK并指定所有这些文件的文件夹位置将这些文件加载到cassandra时,我会得到以下错误
Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "unVocity-parsers input reading thread"
我想看看是否还有其他人面临这一问题,以及它是如何得到解决的。
试图从一个巨大的表中卸载数据,下面是使用的命令和输出。 $ /home/cassandra/dsbulk-1.8.0/bin/dsbulk卸载--driver.auth.provider PlainTextAuthProvider --driver.auth.username xxxx --driver.auth.password xxxx -- datastax and java-driver.basic.contact-points 123.123.123.123 -query "select count(*) from sometable with where on clust
我在Cassandra有个问题
SELECT * FROM "A"."B" WHERE ("systemId" = 'CZ3741X5K8');
它有4个字段,一个VARCHAR (systemId是一个VARCHAR字段)和4个blob字段。
我已经使用RazorSQL将select查询的结果导出到一个插入.sql文件中,并且成功了,但是如果我尝试将相同的文件导入到另一个主机中,它不会将数据导入到表中。
script.sql:2:SyntaxException: line 1:257 mismatched character &
我在卡桑德拉有一个表,里面几乎有80 million+记录(可能更多)。我已经更新了schama,它在表中添加了一个新列。现在我需要更新列值。我使用cassandra-driver编写了一个迁移脚本来实现这一点。我尝试过batching、token,但数据太庞大了,需要3小时以上的时间才能更新记录(过程在2-3小时后终止)。处理这种类型的迁移的最佳方法是什么?有没有其他方法可以做到这一点? Token example
我试图在我的Windows机器上安装DataStax大容量加载程序,以便将json文件导入卡桑德拉数据库。我只是按照官方网站的安装说明。它只是打开文件夹。将任何目录中的dsbulk打印到cmd中都会打印以下结果:"dsbulk" is not internal or external command, executable program, or batch file.,但是我将C:\DSBulk\dsbulk-1.7.0\bin添加到路径变量中。任何面对这个问题的人,你做了什么?谢谢:D
我需要使用python驱动程序将CSV文件导入cassandra
import csv
with open('place_ratings.csv') as f_in:
companies = csv.load(f_in)
with open('place_ratings.csv') as f_in:
companies = csv.reader(f_in)
with open('C:\apache-cassandra-3.11.7\MonashMRDB_datasets\place_ratings.csv') as f_in:
几天前,我们删除了3节点cassandra集群(v3.11)中的一些旧数据,这些数据现在将从快照中恢复。是否有可能从快照恢复数据,而不放松自快照获取以来所做的更新?
有两种方法浮现在我的脑海中
a)
通过COPY keypsace.table TO xy.csv创建导出
截断表
从快照恢复表通过sstableloader
通过COPY keypsace.table FROM xy.csv重新导入更新的数据
b)
只需将快照的稳定文件复制到当前表目录中即可。
A)是一个可行的选择吗?我们需要考虑什么才能在所有节点上同步来自/ to命令的副本?对于选项B),我读
我可以使用此命令将所有数据导出到csv: COPY data TO '/usr/local/cassandra/my_data.csv'; 但是现在我想把指定时间的数据导出到csv,比如这个条件: select * from data where upload_time >='2020-10-16 00:00:00.000+00' and upload_time <'2020-10-17 00:00:00.000+0000' allow filtering ; 我应该怎么处理命令?