用Spark在Cassandra中写RDD [实体]
我正在尝试编写一个RDD,其中包含Cassandra中的公共类带有Spark, class Test(private var id: String, private var randomNumber: Integer, private …
如何将PDF存储在Cassandra中?
我想将一些PDF文件保存到Cassandra。我正在Python的Cassandra工作。一些答案表明,我使用斑点做。但是我不太确定该怎么做。 BLOB的DataStax文档仅谈论…
X64 JDK-1.8是否会在Mac中使用Apple Silicon(M1)芯片工作?
我试图在我的Dev-stetup Mac和M1Pro芯片中与Cassandra 3.x一起运行JDK 8。目前,ARM64 JDK-8目前不可用。…
是否有一种方法可以配置Cassandra将端口7000用于节点通信,但使用端口443连接到其他节点?
有没有办法告诉Cassandra:“听端口7000进行节点内连接,但是当您尝试连接到其他Cassandra主机时,请使用其他端口,例如443?” 基本上与elasticsearc…
我们如何在单独的OpenShift/Kubernetes群集中添加第二个Cassandra DC?
我们在2个不同的OpenShift群集中部署了2个Cassandra数据中心(每个OpenShift群集一个)。 每个Cassandra数据中心都有一个种子POD(POD-0), 我们使用…
Pyspark Transformer无法处理带有空格的数据帧列
使用Pyspark读取来自Cassandra数据库的数据。 软件包: from pyspark.ml.feature import SQLTransformer from transform.Base import Transform 我已…
为什么Cassandra Python查询结果用下划线替换了列名称的空间?
我正在使用Cassandra Python驱动程序。 版本详细信息: [cassandra-driver (3.25.0)] [cqlsh 6.8.0 | Cassandra 4.0.4 | CQL spec 3.4.5 | Native pro…
我如何将DSBulk卸载生成的文件限制为只有一个CSV文件?
我已经在EC2实例中运行以下命令以从Cassandra卸载数据并将其存储在EC2中的某个位置,但是我观察到,对于每个DSBULK卸载命令,它都会生成2个JSON文件,…
我如何找到正确的数据设计和正确的工具/数据库/查询以下要求
我有一种要求,但无法弄清楚如何解决。我的数据集的格式以下 id, atime, grade 123, time1, A 241, time2, B 123, time3, C 或列出列表格式: [[123,t…
如何创建没有双引号的没有空格的Cassandra列?
我正在创建Cassandra表,其中一些列可以具有白色空间,例如“获得%的标记”, 我可以像下面的表格一样创建表 CREATE TABLE test1 (Time text ,"Marks…
如何在Cassandra Java驱动程序V4中编程启用跨代码故障转移?
在dataStax驱动程序3.x中,我们获得了DCAWAREROUNDROBIN策略,如果本地数据中心中的节点失败。 DataStax文档,提到: Cross-datacenter failover is e…
如何使用DataStax Java驱动程序4.x实现令牌感知负载平衡策略?
我们的应用程序当前使用 Cassandra-Driver-Core-3.1.0 ,并实现令牌感知负载平衡策略。我们将驱动程序升级到 Java-Driver-core-4.13.0 ,驱动程序无法…