腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
使用
java
将
记录
快速
插入
到
cassandra
表
中
、
我是新来
Cassandra
的,所以我可能错过了一些东西。我的目标是
使用
Java
(DataStax驱动程序)尽可能快地
插入
500,000行。ArrayList
中
可能存在重复项,因此
插入
过程应该执行insert/update语句(换句话说,
java
列表可能包含重复项,但db
表
应该只包含不同的值)。select查询在不到1秒的时间内从
cassandra
返回500k
记录
,但是
插入
到</e
浏览 48
提问于2020-10-17
得票数 1
1
回答
在具有不同主键的多个
表
中
插入
相同的
记录
、
我有15个字段的数十亿条
记录
,我想将它们
插入
到
Cassandra
中
(
使用
Java
api)。由于我的查询搜索关键字可以是
记录
的五个不同字段之一(即,对字段3或7或8或13或14的搜索查询),因此我在
Cassandra
中
创建了5个相同的
表
,
使用
不同的主键(类似于enter link description现在我读取一条
记录
(或一批
记录
)并调用&qu
浏览 15
提问于2018-12-27
得票数 0
1
回答
使用
Java
将
图像
插入
到
cassandra
blob
中
、
、
、
我希望
将
图片作为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
回答已采纳
1
回答
使用
Spark并发删除和
插入
到
Cassandra
、
我
使用
以下代码
将
预测结果保存到
使用
spark
Cassandra
连接器的
Cassandra
DB
中
: CassandraJavaUtil.javaFunctions(sensorDataRDD).writerBuilder我需要先删除所有以前的
记录
。删除操作应该在
Cassandra
表
中
的一个特殊列上进行,并提供唯一的键。我不确定
如何
删除所有以前的
记录
,以确保当我
使用</em
浏览 0
提问于2017-06-22
得票数 1
1
回答
在写入时同时读取
cassandra
、
当数据被
插入
到
表
中
时,我正在尝试立即读取
cassandra
表
。该
表
将
时间戳作为主键之一(而不是分区键)。我们有一个spark任务,每15秒读一次kafka,写一次
cassandra
。当spark作业开始
插入
数据时,服务器组件几乎立即从
cassandra
读取数据。由于
插入
到
cassandra
的数据非常庞大,我们正在分页读取数据。在阅读页面时,我们观
浏览 2
提问于2016-05-13
得票数 0
2
回答
写入
Cassandra
的Spark作业在最后阶段挂起
、
我
使用
Spark
将
2100万条
记录
插入
到
Cassandra
表
中
。spark作业大约需要一个小时,并成功
插入
所有
记录
,但在最后阶段(62/63)挂起。spark.driver.memory 10gspark.executor.instances 40
将
记录
插入</em
浏览 1
提问于2018-06-23
得票数 0
1
回答
Spark任务失败时中的重复
记录
、
、
当spark任务失败并重新启动时,我面临
Cassandra
表
中
的重复
记录
。我尝试
插入
的
表
的架构。TABLE duplicate_record (object_id bigint,entity_key timeuuid,
表
中
重复
记录
示例所以我们已经有了
Cassandra
中
的现有
记录
和从Oracle生成的新<
浏览 0
提问于2017-03-22
得票数 3
1
回答
如何
在
Cassandra
中
为将来的日期
记录
设置TTL
如何
在
Cassandra
中
为将来的日期设置
记录
的TTL? 我需要为将来的日期设置TTL,该日期
将
仅在所述秒数内有效。例如:我
将
一条
记录
插入
到
cassandra
表
中
,该
记录
将在从现在起5天后的30分钟内有效。
浏览 25
提问于2019-11-09
得票数 0
1
回答
何时在
Cassandra
中
使用
UUID而不是毫秒时间戳?
、
、
、
我在
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
2
回答
使用
Apache
将
批量
记录
从Db2
插入
到
Cassandra
、
我
使用
Apache Nifi
将
DB2加载数据连接到
Cassandra
。我的Db2
表
有超过200+k的
记录
,但是只有400no被
插入
到
cassandra
target
中
。为剩余的
cassandra
批处理语句获取错误,不能
插入
超过65535条
记录
。尝试在yaml文件中进行一些更改,但没有帮助,得到相同的错误。我可以在Nifi中将批次更改为批量吗?或者,如果我需要从Db2加载所有
浏览 16
提问于2019-04-02
得票数 0
1
回答
从
Cassandra
表列批量复制
到
文件
、
我需要将
cassandra
数据库列复制
到
一个文件
中
。复制
到
文件->进程,->将其写入新的数据库
表</em
浏览 0
提问于2019-03-19
得票数 0
回答已采纳
1
回答
CrudRepository(Spring )
中
的保存方法不能在日期类型字段中保存空值?
、
、
我在我的项目中
使用
Spring数据
Cassandra
,我需要在
Cassandra
表
中保存一个日期值,列类型在DB
中
是date,我可以在其中保存值,但是我不能将它设置为null。当我打电话给 任何人都请帮忙。 谢谢
浏览 4
提问于2015-08-21
得票数 2
2
回答
卡桑德拉-
表
中
的TTL和用TTL
插入
数据之间的区别是什么?
、
、
我有一个
Cassandra
2.1集群,在这个集群
中
,我们通过
Java
插入
数据,而TTL作为持久化数据的要求是30天。但是,这会导致问题,因为带有墓碑的旧数据文件保存在磁盘上。我在datastax上遇到过这种情况
Cassandra
允许您为整个
表
设置default_time_to_live属性。
使用
常规TTL标记的列和行将如上文所述进行处理;但是,当
记录
超过
表
级TTL时,
Cassandra
将
立即删除
浏览 7
提问于2017-12-28
得票数 1
回答已采纳
1
回答
我的大量表(2k+)是否会导致我的写入超时异常?
、
我正在运行带有Datastax
Java
驱动程序3.8.0的操作系统
Cassandra
3.11.9。我有一个
Cassandra
关键字空间,它有多个
表
作为查找
表
/搜索索引。每当我收到发送到端点的新POST请求时,我都会解析该对象并将其
插入
到
相应的
Cassandra
表
中
。我还将
插入
放到每个相应的查找
表
中
。我尝试
将
insert请求序列化<e
浏览 2
提问于2021-02-20
得票数 3
1
回答
如何
使用
python-
cassandra
-driver
插入
带有自定义时间戳的数据
、
、
我有一个
将
数据
插入
到
cassandra
表
中
的任务,但是我不想覆盖以前
插入
的
记录
,但是
插入
cql会覆盖现有数据。幸运的是,我发现了一个“
使用
时间戳”的操作,具有较大时间戳的cql
将
覆盖较小的cql,否则不会。因此,通过“
使用
时间戳”,我可以
使用
自定义的时间戳来确定是否覆盖。它在Cqlsh
中
运行良好。但是在python-
cassandra</
浏览 2
提问于2015-09-23
得票数 0
1
回答
Spark
Cassandra
write Dataframe,
如何
在
插入
时发现数据库
中
已存在哪些键
、
、
、
、
我已经编写了以下
JAVA
方法,通过Apache Spark
将
多个POJO的数据持久化
到
Apache
Cassandra
数据库。这看起来工作正常,但是Spark没有提供任何关于
记录
是否被
插入
(键在
cassandra
中
不存在)或是否被更新(键已经存在于DB
中
)的信息。有没有一种成本最低的方法(我想避免在数据帧中加载
表
的内容和检查重复的键),以便在
插入
时找出数据库
中
已经存在的
记录
浏览 12
提问于2019-11-01
得票数 1
2
回答
CqlStorage()不能处理pig
中
的更高
记录
(pig
中
的CqlStorage()抛出异常)
、
、
、
、
我正在
使用
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元无门槛券
手把手带您无忧上云
相关
资讯
如何使用flink-connector-postgres-cdc将Kafka写数据到PostgreSQL数据库动态表中
诞生于FaceBook的大数据存储
Java数据库操作实践:数据插入的简易指南
读过本文才算真正了解Cassandra数据库
Java中非常重要的概念:Java集合
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券