良好的Cassandra表结构
是指在使用Cassandra分布式数据库时，设计和构建表的一种最佳实践。一个良好的Cassandra表结构应该能够提高数据的读写性能、可扩展性和可靠性，同时满足应用程序的需求。
以下是一些构建良好的Cassandra表结构的指导原则：
- 数据模型化：根据应用程序的需求，将数据模型化为适当的表结构。避免关系型数据库中的范式化设计，而是采用反范式化的方式将相关数据存储在一起，以减少数据的读取次数。
- 合理选择分区键：分区键决定了数据在集群中的分布方式。选择一个合适的分区键可以确保数据在集群中均匀分布，并且避免热点数据的问题。通常可以根据查询模式、负载均衡需求和数据的访问频率来选择分区键。
- 使用复合主键：复合主键可以帮助建立更灵活的查询条件。通过将多个列作为主键的一部分，可以根据不同的查询需求创建不同的查询条件。这有助于提高查询的性能和灵活性。
- 列族设计：Cassandra中的列族类似于关系型数据库中的表，但是在Cassandra中，列族的定义更加灵活。在设计列族时，应考虑到数据的访问模式，将经常一起访问的数据存储在同一个列族中。
- 数据冗余和压缩：为了提高读取性能，可以在不同的表之间冗余存储某些数据。这样可以避免频繁的连接操作和查询多个表。此外，对于冗余的数据，可以使用压缩算法来减小存储空间的占用。
- 数据分片和复制：Cassandra通过分片和复制数据来实现分布式的高可用性。合理设置分片策略和副本因子可以确保数据的可靠性和可扩展性。
良好的Cassandra表结构可以应用于许多场景，例如：
- 大规模的数据存储和分析：Cassandra可以支持海量数据的存储和高吞吐量的读写操作，适用于需要处理大量数据的应用场景，如日志分析、用户行为分析等。
- 时间序列数据存储：Cassandra的分布式特性和快速的写入能力使其成为存储时间序列数据的理想选择，如传感器数据、日志数据等。
- 实时数据处理：Cassandra的低延迟读写和分布式特性使其适合实时数据处理场景，如在线推荐系统、实时计算等。
推荐的腾讯云相关产品：
- 云数据库 TcaplusDB：腾讯云提供的多模型分布式数据库，适用于大数据存储和分析场景。
- 云原生数据库 TDSQL-C：腾讯云提供的高性能云原生关系型数据库，适用于在线事务处理场景。
- 分布式缓存 Tcache：腾讯云提供的高性能分布式缓存服务，可与Cassandra配合使用，提高读取性能。
更多产品介绍和详情，请参考腾讯云官方网站：https://cloud.tencent.com
相关·内容
我正在构建一个接近实时/微批处理的数据应用程序，使用Cassandra作为查找存储。每次增量运行有大约40K条记录，而Cassandra表有大约1.5亿条记录。在每次运行中，我需要查找id字段并从Cassandra获取一些属性。这些查找可以是随机的(不是任何时间/地区/国家的依赖)，因此没有明确的分区方案。 我应该如何对Cassandra表进行分区，以确保良好/良好的性能(对于每15-30分钟运行一次的微批)？ 除了分区之外，还有其他技巧吗？
浏览 19提问于2019-09-19得票数 0
2回答
表仍然无法访问，而system_schema.tables 已经包含一个记录--表
我试着同时使用卡桑德拉。卡桑德拉版本：[cqlsh 5.0.1 | Cassandra 3.11.3 | CQL spec 3.4.4 | Native protocol v4]
我有两个使用cassandra-driver==3.16.0的Python脚本，用于消费者和生产者，它们在不同的进程中运行。
当生产者创建并填充表时，使用者等待使用运行CQL语句的Python脚本创建表：
table_exists = False
while not table_exists:
cql = SimpleStat
浏览 1提问于2019-05-16得票数 4
以下是cassandra表模式：
创建表my_table (年文本、月文本、日文本、小时int、分钟int、秒int、主键(年、月、日)、小时、分钟、秒)
如果我使用cassandra cql运行以下查询，它可以工作：
SELECT * FROM my_table WHERE year ='2017' and month ='01' and day ='16' and (hour,min,sec) > (1,15,0) LIMIT 200
但是，当我使用火花-cassandra连接器运行相同的查询时，它无法工作：
sparkSess
浏览 3提问于2017-03-07得票数 0
当我在cassandra.yaml中定义多个file_data_directories时，是否可以指定位置键空间和表？或者由Cassandra自动管理。
谢谢。
浏览 0提问于2015-07-28得票数 0
1回答
我有在php和mysql的故事项目，大数据，许多网络服务，…
我想在node & cassandra中创建新版本，
我需要一些功能，
1.客户端的速度和性能
2.从多个表创建大报告
问题1:从mysql集成到cassandra是对还是错？
问题2:创建产品和组表的最佳实践？
在mysql中：
tblproducts
id,
gid,
name,
...
tblgroups
id,
name,
如何在cassandra中进行更好的设计？
在cassandra中也创建2表？或者有比这更好的主意吗？
浏览 0提问于2020-10-15得票数 1
2回答
我在AWS ec2上有4个节点的Cassandra集群。 操作系统: Ubuntu Cassandra: 3.0.9 我取出了一个节点，并用AWS Linux和Cassandra 3.11.4重新构建了它，在启动过程中，我得到了一个警告，我尝试了几乎所有新的东西，但都无法修复： 警告消息服务-传入-/XX.XX 2019-10-01 23:49:05,221正在从套接字读取IncomingTcpConnection.java:103 - UnknownColumnFamilyException；关闭org.apache.cassandra.db.UnknownColumnFamilyExce
浏览 39提问于2019-10-02得票数 0
我使用Spark从Cassandra数据库检索数据：
DataFrame customers = sqlContext.cassandraSql("SELECT email, first_name, last_name FROM customer " +
"WHERE CAST(store_id as string) = '" + storeId + "'");
在此之后，我进行了一些过滤，并希望将这些数据保存到另一个Cassandra表中，如下所示：
store_id uuid,
report_n
浏览 3提问于2015-11-13得票数 2
回答已采纳
我目前正在我的环境中使用ScyllaDB，由于技术原因，我正在研究迁移到Cassandra。我试图使用可能与ScyllaDB中当前使用的模式相同的模式将Cassandra集群加载到Cassandra集群中。不幸的是，还有一些问题。
环境：
运行在Ubuntu 18.04Cassandra 3.11.4上的ScyllaDB 3.0.7 (= Cassandra 3.0.8)运行在Ubuntu18.04上运行的Ubuntu 18.04cassandra-stress 3.0.18 (部分cassandra-tools pkg)
这一过程如下：
从(desc keyspace_name)prepar
浏览 3提问于2019-10-22得票数 1
回答已采纳
Cassandra表和UDT
CREATE TYPE IF NOT EXISTS phone_type(
code TEXT,
phone TEXT,
);
CREATE TABLE IF NOT EXISTS user_by_phone(
user_id UUID,
phone FROZEN<phone_type>,
password TEXT,
PRIMARY KEY (phone)
);
金刚构造
type PhoneType struct {
Code string `json:"code"`
浏览 3提问于2020-10-05得票数 1
回答已采纳
1回答
我们最近决定将一个应用程序迁移到Cassandra (从Oracle)，因为它可能有助于提高性能，而且由于我有良好的Oracle背景，我不得不承认，我与Cassandra的“思维方式”有斗争。
基本上，我有一张桌子，表上有15个字段，在这些日期中。这些日期之一是用于“订购”，所以我需要能够做“订购”在它上。同时，这个字段可以是空的。
现在我想把这个字段作为主键可以让我按部分完成订单，但是我不能再给它分配空值了.
有什么想法吗？
浏览 4提问于2016-02-01得票数 2
回答已采纳
2回答
Cassandra是否支持字符串上的like属性。我觉得基于cassandra的分区系统，cassandra甚至不支持这种类型的查询。
如果我有模特儿帖子
CREATE TABLE Post (
title text PRIMARY KEY,
description text,
);
如何搜索特定字符串模式的标题和描述？
在cassandra中实现这一点的选项是什么？
我是否需要使用一些文本分析API从title和description中提取所有键字符串，并将其单独存储在不同的表中？
浏览 14提问于2016-07-19得票数 0
回答已采纳
1回答
我使用的是spark-SQL2.4.x版本，Cassandra-3.x版本使用的是datastax-spark-cassandra-connector。还有卡夫卡。
我有一个场景，一些来自kafka主题的财务数据，比如financeDf，我需要重新映射从cassandra表加载的metaDataDf =//中的一些字段，以便向外看。但是这个cassandra表(metaDataDf )可以每小时更新一次。
在spark-sql结构化的流应用程序中，我应该如何每一小时从cassandra表中获取最新的数据？
我不想为我从topic，即financeDf接收到的每个记录加载这个数据metaData
浏览 1提问于2020-01-09得票数 0
3回答
我正在进行一些基准测试，其中包括以下数据流：
卡夫卡->火花流->卡桑德拉
Infrastructure：我的火花流应用程序运行在4个执行器上(每个4g内存有2个核心)。每个执行器运行在一个datanode上，其中安装了Cassandra。4名PrestoDB工作人员也在同一地点工作。我的集群有5个节点，每个节点都有一个英特尔核心i5、32 i5 DDR3内存、500 i5和1G网络。
火花流应用程序：我的火花流批处理间隔为10秒，我的卡夫卡制作人每3秒产生5000个事件。我的流应用程序写入两个Cassandra表。
运行良好的上下文：一切运行良好，流应用程序能够处理这些事件并将它
浏览 7提问于2017-08-02得票数 0
回答已采纳
我刚开始使用Cassandra 3.7，并使用cqlsh终端创建表输入和查看数据。在以前的Cassandra版本中，发行版附带了cassandra-cli，它允许您查看数据是如何在内部存储的。cassandra-cli似乎不在3.7 dist中。cqlsh版本为5.0.1。它应该能够运行cli命令，但当我运行'LIST tablename‘时，我在输入端得不到任何可行的替代命令……在cassandra-cli中运行上述命令可以让您了解数据是如何在内部存储的。如何在cqlsh终端中运行相同的命令？
谢谢!
浏览 15提问于2016-09-01得票数 1
回答已采纳
1回答
我在卡桑德拉有20张桌子。对于一个特定的请求，我需要来自所有20个表的数据。我该怎么做呢？我可以在Cassandra中使用物化视图吗？ 或者我是否应该使用Cassandra触发器并在20个表中的任何一个表中发生变化时在不同的表中创建一个条目？ 或者还有更好的方法吗？
浏览 20提问于2020-08-06得票数 1
回答已采纳
我在Cassandra中有一个表，它以文本格式存储IP。我想从该Cassandra表中删除IP值为内网IP的行。 即位于以下范围内的IP： 172.16.0.0 - 172.31.255.255
192.168.0.0 - 192.168.255.255
240.0.0.0 - 255.255.255.255 我正在使用正则表达式进行查询，但是找不到合适的答案。我该怎么做呢？
浏览 23提问于2021-10-12得票数 1
回答已采纳
1回答
卡桑德拉时间数据类型
、、、
使用DataStax 4.8.11和Cassandra2.1.17，Ubuntu14.04我尝试创建一个时间数据类型为的表。该语法在Cassandra2.2.8/Win7 7上运行良好，但在DataStax 4.8.11上不起作用。
CREATE KEYSPACE tests WITH REPLICATION = {'class' : 'SimpleStrategy', 'replication_factor': 1};
CREATE TABLE testts (
ID int PRIMARY KEY,
浏览 5提问于2016-11-29得票数 2
1回答
我有一个单节点Cassandra数据库，使用一个表存储所有数据。在这个表中，我使用分区键和聚类键来分割数据。我可以使用基于Java的客户端查询这个表来并行地从每个分区读取数据吗？
在我的客户机上，我想启动四个线程，其中每个线程将同时查询单个Cassandra表，并使用一个简单的查询-> 'select * from tablename where column1 = partitionID‘
我意识到实现Cassandra集群要好得多，但目前必须使用单个节点系统。
浏览 0提问于2016-04-25得票数 1
我是Cassandra的新手，我想创建一个社交网站。我想知道我应该如何存储图像？它应该将其存储为文件系统还是存储在Cassandra表中？如果将图像存储在表中，如何构造表？
浏览 1提问于2016-01-13得票数 1
1回答
码头主合成权限拒绝
、、、
每当我尝试运行docker时，我都会得到这个错误-编写-d：
<urlopen error [Errno 13] Permission denied: '/etc/httpd/conf/mime.types'>
我在manjaro的最新版本，码头桌面工作良好，码头信息以及我添加了用户到码头组。
我的船坞-撰写文件：
version: '3'
services:
cass:
image: cassandra:3.11.8
container_name: cass
ports:
- "904
浏览 2提问于2022-09-30得票数 0
我试图动态地向cassandra表添加一个新列。我在用下面的版本-
cqlsh 5.0.1
我用蟒蛇和卡桑德拉互动。我有一个python列表，希望将其作为一个列名添加到Cassandra表中。
Python列表-
['A','B','C','D','E','F','G','H','I','J','K','L','M','N','O','P',
浏览 2提问于2017-06-07得票数 0
2回答
我在试着读卡桑德拉表上的记录
此代码运行良好：
df = spark.read \
.format("org.apache.spark.sql.cassandra") \
.option("spark.cassandra.connection.host", "my_host") \
.option("spark.cassandra.connection.port", "9042") \
.option("spark.cassandra.auth.username",
浏览 12提问于2022-06-12得票数 0
我有一个表，在Cassandra中有超过10,000,000条记录，但出于某种原因，我想要构建另一个具有相同字段和其他几个字段的Cassandra表，我将把以前的数据迁移到其中。现在这两个表在同一个Cassandra星系团中。
我想问一下，如何在最短的时间内完成这项任务？
如果我的新桌子在不同的卡桑德拉，怎么做呢？
如有任何建议，将不胜感激！
浏览 1提问于2015-09-23得票数 0
回答已采纳
我最近开始通过文章学习No-SQL和Cassandra。作者通过这个图表解释了数据模型：
作者还给出了以下列族实例：
Book {
key: 9352130677{ name: “Hadoop The Definitive Guide”, author:” Tom White”, publisher:”Oreilly”, priceInr;650, category: “hadoop”, edition:4},
key: 8177228137{ name”” Hadoop in Action”, author: “Chuck Lam”, publisher:”manning”,
浏览 8提问于2017-01-25得票数 3
回答已采纳
我一直按照关于SSTable的说明使用Java创建本站。
该程序编译和工作良好，没有错误。
但是，当我尝试使用以下命令sstableloader -v -d 127.0.0.1 /path/to/sstable/keyspace/tablename加载表时，它将返回一个错误。下面是它输出的堆栈跟踪：
For input string: "Filter.db"
java.lang.NumberFormatException: For input string: "Filter.db"
at java.lang.NumberFormatExcepti
浏览 0提问于2016-07-06得票数 1
回答已采纳
问题1:来自设备的事件数据存储在Cassandra表中。显然，这是时间序列数据。如果我们需要在当前时间存储更早的过期事件(如果由于某些问题而缓存在设备中)，我们是否会遇到性能问题？如果是，有什么解决方案来避免这种情况？
问题2:在事件传入时立即将事件写入Cassandra表是一种好的做法吗？或者我们是否应该让它排队等待一段时间，以便一次写入多个事件，如果这能显着提高Cassandra写入性能的话？
浏览 2提问于2018-02-09得票数 0
假设我想要将一个表从集群A复制到集群B，并且我在每个集群A节点上使用sstableloader执行此操作(在刷新之后)。有没有办法验证集群B中的表包含集群A中的所有内容？
我正在运行Cassandra 2.0.15。
浏览 1提问于2016-11-12得票数 0
我在Spring boot应用程序中使用Cassandra作为数据源，并希望在应用程序启动之前初始化数据库。
到目前为止，我已经定义了一个类"CassandraConfiguration“来扩展"AbstractCassandraConfiguration”类，你可以在下面的例子中看到，并且我有一个扩展"CassandraRepository“的存储库。当我自己创建键空间和表时，应用程序运行良好。
但是，我希望在应用程序启动时自动创建键空间和表。为了做到这一点，我在resources文件夹下提供了一个schema.cql文件，但我无法使该脚本工作。
有人知道我能做些什么
浏览 7提问于2016-02-02得票数 7
我有15个字段的数十亿条记录，我想将它们插入到Cassandra中(使用Java api)。由于我的查询搜索关键字可以是记录的五个不同字段之一(即，对字段3或7或8或13或14的搜索查询)，因此我在Cassandra中创建了5个相同的表，使用不同的主键(类似于enter link description here中提到的注释)。 现在我读取一条记录(或一批记录)并调用"inserting into Cassandra“5次。 我想知道Cassandra中有没有一种机制，可以让我调用一次"inserting into Cassandra“，并自动将记录存储到5个表中？ 例如，在
浏览 15提问于2018-12-27得票数 0
2回答
我使用.setCassandraConf(c_options_conf)来设置sparkSession来连接cassandra集群，如下所示。
工作良好：
val spark = SparkSession
.builder()
.appName("DatabaseMigrationUtility")
.config("spark.master",devProps.getString("deploymentMaster"))
.getOrCreate()
.setCa
浏览 2提问于2018-10-18得票数 0
回答已采纳
1回答
我们有一个需求，其中我们有一个包含20个字段的关系数据库表T1。我们捕获该表中发生在各个字段(提交日志)上的所有更改/更新，并在Cassandra中相应的表CT1中摄取/应用这些更改/更新，即Cassandra表CT1具有与T1 (关系DB表)完全相同的模式/字段。
对于Cassandra表CT1，我们有额外的要求，我们想要捕获/存储/检索所有字段的所有更改的值，这意味着如果字段f1更改了20次，则应该保存具有相应更改时间戳的所有更改的值。类似地，如果字段f3更改了100次，则应保存其所有值。注意:不同的字段在不同的时间改变，每个字段改变变量的次数，这意味着一个字段可能每天改变1000次，而其
浏览 8提问于2017-07-20得票数 0
我第一次尝试Cassandra，并为简单的会话管理db在本地运行它。卡桑德拉-2.0.4，CQL3，datastax驱动程序2.0.0-rc2
当表中没有数据时，以下计数查询工作良好：
select count(*) from session_data where app_name=? and account=? and last_access > ?
但是，即使将单个行插入到表中，查询也会失败，出现以下错误：
java.lang.AssertionError
at org.apache.cassandra.db.filter.ExtendedFilter$WithClauses.get
浏览 0提问于2014-01-22得票数 1
回答已采纳
我有下面的表结构 @Table(value = "employee")
public class Employee implements MapIdentifiable{
@PrimaryKeyColumn(value = "employee_id", ordinal = 0, type = PrimaryKeyType.PARTITIONED)
private String empId;
@Column(value="info")
@CassandraType(type = DataType.Name.UD
浏览 43提问于2019-07-31得票数 0
回答已采纳
我有表创建表站点(url文本主键，计数int)与数据
com.google 5
com.google.subdomain 10
Cassandra支持在单一查询中选择所有google站点(带有子域)吗？
浏览 0提问于2018-04-29得票数 2
回答已采纳
为什么Cassandra被称为非结构化的，即使表/列族必须用列及其数据类型来定义。 对于具有一些固定列的已定义表，我们可以选择在特定行中填充某些列，而选择不填充其他行。但是在RDBMS中也可以做同样的事情，我们可以在insert语句中保留一些列，而省略的列应该允许null？ 因为mongo将数据存储在json文档中，我们可以在每次插入新文档时存储不同的(键)数据。我们不需要定义任何东西。但是对于cassandra，我们需要重新配置我们的表，以适应添加的新列。 虽然有一些文章，但对我来说还是不清楚。有人能指出原因吗。
浏览 22提问于2020-01-05得票数 0
1回答
在关系数据库中，我有一个表products (pid，...)另一个包含属性(propid、name)，另一个与前面的属性(relationid、pid、propid、value)相关。这意味着我可以将新属性与产品关联起来。我正在尝试在Cassandra中得到一个可以反映我现在所得到的解决方案。向cassandra中现有的表添加列是一种好的做法吗？ 谢谢你的帮忙
浏览 13提问于2019-05-30得票数 0
我有一台带有Cassandra 3.9和2个表的开发机器，其中一个有大约400,000条记录，另一个大约有40,000,000条记录。它们的结构是不同的。
它们中的每一个都在字段x上有一个二级索引，我正在尝试运行一个SELECT MAX(x) FROM table形式的查询。在第一个表上，查询需要几秒钟，在第二个表上，查询超时。
我的经验是使用关系数据库，在那里这些查询是简单而快速的。那么，在Cassandra中，索引看起来不是用来执行这些查询的？有没有别的选择？
浏览 1提问于2016-10-24得票数 2
1回答
我正在尝试使用Datastax中的连接器(v2.0.2，Sparkv2.0.0)：
val df = sparkSession.sparkContext.cassandraTable[MyRec](keyspace, tableName).toDF()
df.write.format("orc").save(hdfsLocation)
它看上去非常简单，并在一段时间内运行良好，但我开始得到这样的例外：
Caused by: com.datastax.driver.core.exceptions.ReadFailureException:
Cassandra failure
浏览 3提问于2017-09-04得票数 0
回答已采纳
我的Cassandra DB中有一个表，其中包含userid、city1、city2和city3列。如果我想检索所有以"Paris“为城市的用户，我的查询应该是什么？我知道Cassandra没有OR，所以我不确定如何构造查询。
浏览 37提问于2019-05-28得票数 0
我的问题在下一个。
我的代码中有下一个简单的模型：
public class Client
{
public Guid Id { get; set; }
public string Name { get; set; }
}
我为它定义了一个映射：
public class CustomMappings : Mappings
{
public CustomMappings()
{
For<Client>().TableName("clients")
.PartitionKey(
浏览 0提问于2019-05-06得票数 2
回答已采纳
1回答
我正在使用Cassandra Java驱动程序。
我有一个用例，在这个用例中，我对具有不同分区键的各个Cassandra表进行批量插入数据。
BatchStatement batch = new BatchStatement();
batch.add (query1, query2, .....)
session.executeAsync(batch);
假设我的批处理语句中有20个查询，15个查询执行良好，5个查询失败。
如何知道哪些查询失败了，哪些查询被执行了.
我之所以使用executeAsync是因为从性能的角度来看。
<Edit1:>
我们使用的是
浏览 1提问于2017-03-20得票数 1
1回答
目前，我们正在使用mongodb作为大型在线销售站点的主要商店，目前我们正致力于多台机器之间的大可伸缩性。
站点后端是用node.js编写的，我们使用猫鼬作为ODM。
我可以看到许多博客文章都是关于令人敬畏的cassandra DB，我开始考虑切换到cassandra。但是，我仍然不确定这是否是一个很好的决定，因为我没有为cassandra和node.js找到任何好的ODM/ORM (编写原始查询可能很痛苦)。同时，编写经过良好测试的ORM/ODM也是一项耗时的任务)。因此，我不知道在这一转变之后，我将得到多少好处。我们使用elasticsearch作为搜索引擎，它与mongodb的结合非常好
浏览 0提问于2014-05-23得票数 2
回答已采纳
我正在对一个表进行读取和更新查询，该表有500000行，并且在处理大约300000行后，有时会出现错误，即使没有节点关闭。
卡桑德拉在一致性查询期间超时(需要1次响应，但只有0次响应)
基础设施详细信息：
具有5个Cassandra节点、5个spark节点和3个Hadoop节点，每个节点具有8核和28 GB内存，而Cassandra 复制因子为3。
Cassandra 2.1.8.621区DSE 4.7.1点星火1.2.1区Hadoop 2.7.1
Cassandra配置：
read_request_timeout_in_ms (ms): 10000
range_request_tim
浏览 1提问于2015-09-01得票数 8
回答已采纳
使用Mac Capitan 10.11.2，并通过发出"cassandra -f“命令在终端中启动Cassandra (版本2.2.3)。
Cassandra开始运行良好，能够使用cqlsh进行连接。然后退出了cqlsh，所以它不再连接到cassandra @端口9042
我现在正在尝试通过执行以下操作来杀死正在运行的cassandra：
ps -ef | grep cassandra
sudo kill -9 PID
但它不会杀死进程，cassandra仍在运行。不知道现在该怎么阻止它。
浏览 0提问于2015-12-20得票数 0
2回答
卡桑德拉柱家族
、、
我正试图连接卡桑德拉，以便进行批量插入。但是，当我试图连接时，我会得到一个错误。
我使用的代码：
from pycassa import columnfamily
from pycassa import pool
cassandra_ips = ['<an ip addr>']
conpool = pool.ConnectionPool('my_keyspace', cassandra_ips)
colfam = columnfamily.ColumnFamily(conpool, 'my_table')
但是，这在最后一行中失败
浏览 7提问于2014-03-07得票数 3
回答已采纳
我在Kubernetes上使用Spark 3.0.1，spark cassandra连接器和cassandra。
我使用spark cassandra Cassandra API来获取Spark Partition的数据局部性特性，首先是Cassandra，然后是joinWithCassandraTable。但是这个重新分区失败了，因为cassandra数据对于Spark容器来说不是本地的。正因为如此，joinWithCassandraTable性能变得非常低。
有没有其他方法可以让joinWithCassandraTable获得良好的性能。
浏览 2提问于2021-06-14得票数 1
1回答
这是一个关于Cassandra架构的初学者问题。
我有一个3节点的Cassandra集群。数据目录位于$CASSANDRA_HOME/ data /data。我加载了一个巨大的数据集。我执行了一次nodetool flush，然后在表上执行了nodetool tablestats，我加载了数据。这表明占用的总空间约为50GiB。我很好奇，检查了每个节点上我的数据目录du $CASSANDRA_HOME/data/data的大小，显示每个节点上大约有1-2 2GB。数据目录怎么会少于单个表占用的空间呢？我是不是遗漏了什么？我的表是用replication factor 1创建的
浏览 3提问于2017-09-23得票数 1
我正在寻找使用自定义表预先填充cassandra数据库的最佳方法。除了使用例如cassandra-stress之外，有没有什么方法可以插入100 to的数据？这只是一个POC，没有真正的dat。我想要实现的是2个数据集，一个包含50 to的数据，另一个包含100 to的数据。
它可以是虚拟数据。
谢谢！
浏览 0提问于2020-09-01得票数 2
Cassandra 3.11.16升级到4.0.5，一切看起来都不错，但是在/etc/cassandra下，cassandra安装程序除了触发器文件夹之外，什么都不生成
当我直接在一台全新的机器上安装c* 4.0.5时，它会正确地生成conf文件，如cassandra.yaml、cassandra-env.sh。os版本为ubuntu18.04，由apt.After安装的cassandra我将conf文件复制到/etc/cassandra，c*运行良好。
浏览 0提问于2022-12-21得票数 0
1回答
我正在努力解决以下问题。我正在使用JobTracker运行DSECassandra2.1.13的分析模式，这是运行良好和工作。我的问题是事情的侧重点。我正在尝试将数据从MySQL加载到cassandra列家族中。这个问题似乎与sqoop导入命令中传递的cassandra参数有关。
./dse sqoop import --connect jdbc:mysql://10.0.0.20/amad \
--username root \
--table aminno_mem_email \
--cassandra-keyspace am_cc \
--
浏览 2提问于2016-02-03得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
