我是新来Cassandra的，所以我可能错过了一些东西。我的目标是使用Java (DataStax驱动程序)尽可能快地插入500,000行。ArrayList中可能存在重复项，因此插入过程应该执行insert/update语句(换句话说，java列表可能包含重复项，但db表应该只包含不同的值)。select查询在不到1秒的时间内从cassandra返回500k记录，但是插入到</e
浏览 48提问于2020-10-17得票数 1
我有15个字段的数十亿条记录，我想将它们插入到Cassandra中(使用Java api)。由于我的查询搜索关键字可以是记录的五个不同字段之一(即，对字段3或7或8或13或14的搜索查询)，因此我在Cassandra中创建了5个相同的表，使用不同的主键(类似于enter link description现在我读取一条记录(或一批记录)并调用&qu
浏览 15提问于2018-12-27得票数 0
我希望将图片作为bytebuffer插入到cassandra表中。我使用Java将图像以bytebuffer的形式存储到变量bb中。如何将字节缓冲区bb中的数据插入到cassandra表中</em
浏览 9提问于2016-10-26得票数 1
1回答
我想使用气流在卡桑德拉表格中插入数据。
就像MySqlOperator在SQL表中安装数据一样，也没有任何操作符或方法将记录插入到Cassandra表中。我只找到这两个操作符:从airflow.providers.apache.cassandra.sensors.record导入CassandraRecordSensor，从airflow.providers.ap
浏览 1提问于2021-07-26得票数 0
回答已采纳
我使用以下代码将预测结果保存到使用spark Cassandra连接器的Cassandra DB中：
CassandraJavaUtil.javaFunctions(sensorDataRDD).writerBuilder我需要先删除所有以前的记录。删除操作应该在Cassandra表中的一个特殊列上进行，并提供唯一的键。我不确定如何删除所有以前的记录，以确保当我使用</em
浏览 0提问于2017-06-22得票数 1
当数据被插入到表中时，我正在尝试立即读取cassandra表。该表将时间戳作为主键之一(而不是分区键)。我们有一个spark任务，每15秒读一次kafka，写一次cassandra。当spark作业开始插入数据时，服务器组件几乎立即从cassandra读取数据。由于插入到cassandra的数据非常庞大，我们正在分页读取数据。在阅读页面时，我们观
浏览 2提问于2016-05-13得票数 0
我使用Spark将2100万条记录插入到Cassandra表中。spark作业大约需要一个小时，并成功插入所有记录，但在最后阶段(62/63)挂起。spark.driver.memory 10gspark.executor.instances 40将记录插入</em
浏览 1提问于2018-06-23得票数 0
1回答
当spark任务失败并重新启动时，我面临Cassandra表中的重复记录。我尝试插入的表的架构。TABLE duplicate_record (object_id bigint,entity_key timeuuid,表中重复记录示例所以我们已经有了Cassandra中的现有记录和从Oracle生成的新<
浏览 0提问于2017-03-22得票数 3
如何在Cassandra中为将来的日期设置记录的TTL？
我需要为将来的日期设置TTL，该日期将仅在所述秒数内有效。例如:我将一条记录插入到cassandra表中，该记录将在从现在起5天后的30分钟内有效。
浏览 25提问于2019-11-09得票数 0
我在cassandra中创建了表，其中的主键是以timeuuid作为数据类型的列。我能够用存储为bigint的毫秒精度时间戳值唯一地标识每条记录。我使用java datastax驱动程序连接cassandra。在将记录插入数据库之前，我要将每条记录的毫秒时间戳转换为UUID。这是开销，可以移除。可以解释使用timeuuid而不是bigint的好处是什么，考虑到<e
浏览 1提问于2020-10-15得票数 2
回答已采纳
1回答
插入期间未配置的列族错误
、、、
下面的用户信息对象映射到我的键空间"user_info“中的一个表"data_collection”。我在卡桑德拉数据库中创建了"user_info“表。我使用spring数据cassandra连接JAVA的cassandra数据库和spring注释，如下所示。return phone; public void setPhone(int phone) {
this.phone = pho
浏览 0提问于2017-09-13得票数 1
回答已采纳
1回答
目前我有两千万条记录，我想把它插入到我的Cassandra db表中。每条记录的大小约为1KB。目前，我所做的是为每条记录创建一个PreparedStatement (com.datastax.driver.core)，并执行它(通过com.datastax.driver.core.Sessions)将数据传输到表中。整个过程大约需要5到6个小时才能完成。对于cassandra，我
浏览 0提问于2016-01-22得票数 0
我使用Apache Nifi将DB2加载数据连接到Cassandra。我的Db2表有超过200+k的记录，但是只有400no被插入到cassandra target中。为剩余的cassandra批处理语句获取错误，不能插入超过65535条记录。尝试在yaml文件中进行一些更改，但没有帮助，得到相同的错误。我可以在Nifi中将批次更改为批量吗？或者，如果我需要从Db2加载所有
浏览 16提问于2019-04-02得票数 0
我需要将cassandra数据库列复制到一个文件中。复制到文件->进程，->将其写入新的数据库表</em
浏览 0提问于2019-03-19得票数 0
回答已采纳
我在我的项目中使用Spring数据Cassandra，我需要在Cassandra表中保存一个日期值，列类型在DB中是date，我可以在其中保存值，但是我不能将它设置为null。当我打电话给
任何人都请帮忙。
谢谢
浏览 4提问于2015-08-21得票数 2
我有一个Cassandra2.1集群，在这个集群中，我们通过Java插入数据，而TTL作为持久化数据的要求是30天。但是，这会导致问题，因为带有墓碑的旧数据文件保存在磁盘上。我在datastax上遇到过这种情况
Cassandra允许您为整个表设置default_time_to_live属性。使用常规TTL标记的列和行将如上文所述进行处理；但是，当记录超过表级TTL时，Cassandra将立即删除
浏览 7提问于2017-12-28得票数 1
回答已采纳
我正在运行带有Datastax Java驱动程序3.8.0的操作系统Cassandra 3.11.9。我有一个Cassandra关键字空间，它有多个表作为查找表/搜索索引。每当我收到发送到端点的新POST请求时，我都会解析该对象并将其插入到相应的Cassandra表中。我还将插入放到每个相应的查找表中。我尝试将insert请求序列化<e
浏览 2提问于2021-02-20得票数 3
我有一个将数据插入到cassandra表中的任务，但是我不想覆盖以前插入的记录，但是插入cql会覆盖现有数据。幸运的是，我发现了一个“使用时间戳”的操作，具有较大时间戳的cql将覆盖较小的cql，否则不会。因此，通过“使用时间戳”，我可以使用自定义的时间戳来确定是否覆盖。它在Cqlsh中运行良好。但是在python-cassandra</
浏览 2提问于2015-09-23得票数 0
我已经编写了以下JAVA方法，通过Apache Spark将多个POJO的数据持久化到Apache Cassandra数据库。这看起来工作正常，但是Spark没有提供任何关于记录是否被插入(键在cassandra中不存在)或是否被更新(键已经存在于DB中)的信息。有没有一种成本最低的方法(我想避免在数据帧中加载表的内容和检查重复的键)，以便在插入时找出数据库中已经存在的记录
浏览 12提问于2019-11-01得票数 1
我正在使用DSE 3.1.2我正在使用Pig将一些预处理结果存储到cql中，我已经创建了一个表并启动了我的脚本，它工作的数据量很少，当增加了更多的记录时，它没有存储到cassandra中，只有90%或输出存储到- 2014-04-29 01:53:49.764; org.apache.hadoop.mapred.Task; Runnning cleanup for the task
如果我手动将其<
浏览 0提问于2014-04-29得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
