-
-3 votesanswersviews
it.unimi.dsi.fastutil.objects.ObjectArraySet . <init>(Ljava / util / Collection;)V不存在
当我运行我的火花作业来创建我的DSE图时,我遇到了问题: My code : import com.datastax.bdp.graph.spark.graphframe._ object TestGraph extends App with SparkConnection { val graph = spark.dseGraph(cassandraConf.GRAPH_NAME) } ... -
0 votesanswersviews
具有范围边界查询的Cassandra BoundStatement
我正在使用PreparedStatement和boundStatment来执行一些Cassandra查询 . 我正在尝试执行范围查询 . 这是我要创建的查询: getAllRecordsOnIndexRange = getSession.prepare(QueryBuilder.select(documentId, documentName, documentIndex) .f... -
1 votesanswersviews
在Spring Data Cassandra中将实体类作为UDT
我有一个嵌套的POJO作为Cassandra实体,其中一个对象是表示一个表的Cassandra实体类 . 我正在尝试在Spring Data Cassandra中建模并得到以下错误: 只允许原始类型和原始类型的集合或映射 我的实体结构如下 //Definition of Single entity @Table Class A { @Primary Key Variable1 ... -
3 votesanswersviews
无法使用带有datastax java驱动程序的cassandra通过UDT键检索
我正在尝试使用用户定义的类型作为分区键在cassandra中存储对象 . 我使用datastax java驱动程序进行对象映射,虽然我能够插入数据库,但我无法检索该对象 . 如果我更改分区键以使用非udt(例如文本),我可以保存和检索(即使对象上还有其他相同类型的udt) . 从阅读文档看来,UDT被允许作为键 . 我也没能找到任何迹象表明java驱动程序也不支持udts作为键 . 看起来它在对象... -
0 votesanswersviews
使用DataStax驱动程序连接到“旧”列系列时,批量更新失败
我有一个Cassandra进程,它是在早期的Cassandra版本中创建和定义的 . 到目前为止,我们使用了一个hector驱动程序来连接它 . 我正在将驱动程序更改为DataStax以享受CQL新功能并允许异步访问 . 我在进行这种转变的过程中遇到了一些问题 . 虽然我仍然遇到一些问题,但我已经阅读了this upgrade guide,虽然有些亮点 . 最大的一个是我无法使用大于1的协议版本访... -
1 votesanswersviews
在java datastax驱动程序中绑定Cassandra多列IN参数
我正在尝试使用datastax java驱动程序在cassandra中创建以下查询,它运行正常: SELECT * FROM "TEST".my_cf WHERE jobName = 'job1' AND siteId = 'account1' AND date = 12345 and (consumerId) in (('consumer3')); 其中 consume... -
0 votesanswersviews
Spring Data Cassandra和 Map Map
我有一个像这样定义的Cassandra表: create table foo (id int primary key, mapofmaps map<text, frozen<map<text, int>>>); 我在其中放置了一些数据: insert into foo (id, mapofmaps) values (1, {'pets'; {'dog'; 42... -
0 votesanswersviews
Cassandra:QueryBuilder.update包含UDT列表
我们有一个表,其中两列是: user_assignments frozen<list<shift_user_assignment>>, user_offers frozen<list<shift_user_assignment>>, 和 shift_user_assignment 是 CREATE TYPE IF NO... -
9 votesanswersviews
Pandas和Cassandra:numpy数组格式不兼容
我正在使用Python cassandra驱动程序来连接和查询我们的Cassandra集群 . 我想通过Pandas操纵我的数据,cassandra驱动程序的文档中有一个区域提到了这个:https://datastax.github.io/python-driver/api/cassandra/protocol.html NumpyProtocolHander:将结果直接反序列化为NumPy数组... -
1 votesanswersviews
如何从cassandra 2.1中的缓存中清除准备好的语句
我正在尝试使用来自datastax的nodejs驱动程序在cassandra 2.1.2中向用户定义的类型添加字段 . 我在cqlsh中使用 ALTER TYPE 添加了该字段 . 当我尝试添加包含带有新字段值的udt的行时,它将插入null值,而不是我提供的值 . 我强烈怀疑这与集群缓存预准备语句的方式有关 . 因为我记得读过准备好的语句是通过查询的哈希索引的,所以我尝试更改查询中的一些空格以查... -
30 votesanswersviews
写入cassandra datastax驱动程序引发的超时
在进行批量加载数据时,根据日志数据递增计数器,我遇到超时异常 . 我使用Datastax 2.0-rc2 java驱动程序 . 这是服务器无法跟上的问题(即服务器端配置问题),还是客户端厌倦等待服务器响应的问题?无论哪种方式,是否有一个简单的配置更改我可以做到这将解决这个问题? Exception in thread "main" com.datastax.driver.cor... -
1 votesanswersviews
在运行SQL Query之前,来自DSE的Spark是否将所有数据存入RDD?
运行DSE 4.7 所以说我有一个4节点DSE Cassandra / Spark集群...... 我有一张Cassandra表,里面有4,000,000条记录 . 在Spark上运行以下Spark SQL“select * from table where email =?或mobile =?” Spark会将所有数据加载到RDD中,然后根据where子句进行过滤吗?每个spark节点每个节点都... -
0 votesanswersviews
DSE cassandra没有开始
面对一个问题,我们在重启后有5个节点的集群dse试图启动而没有成功,system.log中的最后一条记录在下面...尝试用堆和48和64,节点有128GB . 其中三个开始但这两个不能,日志中只有那个记录没有错误 . INFO [主要] 2017-05-16 21:16:27,507 CassandraDaemon.java:487 - JVM参数:[-Ddse.server_process... -
0 votesanswersviews
没有列的DSE 5.1.10表..重新启动错误
cassandra重启时面临错误 . ERROR [main] 2018-09-04 03:04:53,490 CassandraDaemon.java:723 - 启动时遇到的异常org.apache.cassandra.schema.SchemaKeyspace $ MissingColumns:org中test.test1的架构表中找不到的列 . apache.cassandra.sc... -
0 votesanswersviews
升级后的Cassandra DataStax 5.0 thriftQueries读取失败
最近我们从4.x datastax cassandra迁移到5.1.4 datastax cassandra . 我们使用thriftQueries来编写和读取4.x的数据 . 升级后我们已经能够在cassandra中写入数据但是当我们尝试获取数据时它失败了 . 可能是什么原因?请在下面找到附件日志 . [2018-11-16T20:34:29.020Z] ERROR [L:nemo.inter... -
1 votesanswersviews
Cassandra简单的主键查询
我们想创建一个带有简单主键的Cassandra表,该表由UUID列组成 . 该表将如下所示:CREATE TABLE simple_table( id UUID PRIMARY KEY, col1 text, col2 text, col3 UUID ); 此表可能会存储几十亿行,并且这些行应在使用TTL功能一段时间(几个月)后过期 . 关于这个表的效率我几乎没有问题: 使用主键查询此表的效率... -
1 votesanswersviews
对话消息传递的Cassandra建模
我还在学习理解 Cassandra . 我已经阅读了有关会话消息的类似问题和答案但却不满意,因为它不符合我的需求 . 这些是我想要解决的问题 用户可以向一个或多个用户发送消息 会话表 - 在用户 - 用户之间保存消息 对话表 - 显示与您 Build 对话的所有用户的最近对话消息,标记为已读或未读日期 . 会话消息表 - 用户A可以加载与用户B或用户C的所有会话 会话消息表 ... -
1 votesanswersviews
如何设置cassandra和spark
我的目标是在同一个Cassandra节点上运行Spark worker,并为Spark master提供一个单独的节点 . 现在,我正在尝试Datastax . 在安装Cassandra datastax期间,我可以选择3种不同的节点类型 - Cassandra,搜索和分析 . 在我的3节点集群上,我应该选择2个节点上的事务节点类型和1个节点类型进行分析(Spark master)吗?如何在Ca... -
2 votesanswersviews
Spark Master不以DSE 4.7和OpsCenter 5.1.3开头
我最近从Datastax 4.6.3 => 4.7升级,现在我无法运行Spark . 问题似乎是Spark Master未正确配置 . 我使用OpsCenter 5.1.3,并启动了一个三节点Analytics集群 . 奇怪的是,节点最初的设置SPARK_ENABLED = 0,我必须手动将其设置为1 . 但是,现在没有正确配置spark master . 在/var/log/cassand... -
1 votesanswersviews
使用安装在同一群集上的apache spark将数据从HDFS文件插入另一个群集中的DSE cassandra表
我们在Hadoop集群2.8上安装了Spark 1.6 . 我们有一个单独的Datastax Cassandra集群4.8.6(C * 3.x和spark 1.4.2) . 我们需要将数据从HDFS文件复制到DSE cassandra表中 . 在我们目前的工作中,我们在HDFS Spark集群上提交了一个spark作业(独立模式下的spark-submit),它将数据加载到DSE cassandr... -
2 votesanswersviews
找不到Spark,Cassandra Keyspace
我试图从cassandra键空间读取数据但是当尝试使用pyspark访问它时,Keyspace不可见 . 它在使用DataStax spark shell =>时有效 ubuntu@ip-172-31-60-229:~$ sudo dse -u xxxx -p xxxxx spark --conf spark.driver.cores=4 The log file is at /home/u... -
1 votesanswersviews
Datastax cassandra连接器用于火花发生故障并且难以理解
我的火花流应用程序有以下几行: 我正在尝试将一系列对象写入cassandra中的表(以及文本文件) . 我有以下代码: val rmqReceiver = new RMQReceiver(queueIp, "vehicle-data") val statusMessageStream = myStreamingContext.receiverStream[String](rmq... -
4 votesanswersviews
迷惑火花警告(DSE 4.8.4)
我刚刚在Spark控制台(DSE 4.8.4)上发现了一个奇怪的警告,我不知道它来自哪里 . 它似乎从某个地方拿起数据中心DC1 . 问题是,我没有任何名为DC1的数据中心 . 我有三个数据中心,但没有一个像这样标记 . WARN 2016-01-21 05:26:54 com.datastax.driver.core.ReplicationStrategy $ NetworkTopologyS... -
0 votesanswersviews
Cassandra:当整个数据中心出现故障时会发生什么?
我有一个带有3个数据中心的Cassandra集群,每个数据中心有6个节点 - DC1,DC2和DC3 like this . 可以说我有一个 NetworkTopologyStrategy ,在创建键空间的时候, 创建KEYSPACE测试WITH REPLICATION = {'class':'NetworkTopologyStrategy','DC1':3,'DC2':3,'DC3':3} 这... -
2 votesanswersviews
SELECT *语句中的Cassandra ArrayIndexOutOfBoundsException
我有2个列系列,其数据是使用DataStax驱动程序版本1.0.4通过Java应用程序插入的 . 我使用cqlsh 4.1.1(Cassandra 2.0.5,CQL规范3.1.1,Thrift协议19.39.0)将CQLSH转换为集群中的四个节点之一 . 我可以从一个列族("table_A")执行 SELECT * 但不执行另一个列(table_X) . 我正在尝试执行 SE... -
1 votesanswersviews
Datastax Cassandra Java驱动程序@QueryParameters fetchSize
参考http://docs.datastax.com/en/drivers/java/2.1/com/datastax/driver/mapping/annotations/QueryParameters.html#fetchSize-- 对于cassandra,数据存储区查询参数中fetchSize的默认值-1是什么意思 . 我认为没有分页 . 这是否意味着它试图一次性获取所有记录?试图搜索相当... -
0 votesanswersviews
Datastax Cassandra odbc驱动程序并在cqlsh 3上启动cql2会出现错误,因为cqlsh:error:no such option:-2
我已经为cassndra安装了datastax ODBC驱动程序,并且我已经使用cql 3创建了密钥空间和一些表 . 但ODBC驱动程序没有显示这些表 . 另外在odbc文档中,我读到驱动程序当前不支持Cassandra查询语言(CQL3)的3.0版本,驱动程序将无法识别使用CQL 3定义的键空间和列系列 . 因此,为了使用cql 2我正在使用以下命令在驱动程序文档中建议: ... \ cqlsh... -
0 votesanswersviews
尝试通过单元在Cassandra中创建列族时出现InvalidQueryException
我有一个3节点cassandra集群,通过我在Java中的单元测试,我首先创建一个键空间,然后在该键空间内创建一个列族 . 有时单元测试通过但随机我不断收到以下错误 . 我在2.1.0中使用最新的datastax 2.1.4 java驱动程序和cassandra版本 . com.symc.edp.database.nosql.NoSQLPersistenceException: com.datas... -
2 votesanswersviews
datastax java驱动程序更新无提示失败
我有一个共享(与其他应用程序)Cassandra数据库,它集中在2个不同的节点 . 我正在使用Cassandra Database 2.1.2和Java Datastax驱动程序版本2.1.4 . 我创建了类似于此的Do: package com.me.name.data.model.cassandra; @Table(name = "name") public final ... -
3 votesanswersviews
无法在启用密码身份验证的情况下将java客户端连接到cassandra
我的macbook上有一个默认的Datastax enterprise安装 . 我能够创建我的键空间并设置我的所有应用程序,包括使用solr . 我正在尝试开发一组步骤来为我们的开发群集启用密码身份验证 . 到目前为止,我已更新/usr/local/dse/resources/cassandra/conf/cassandra.yaml并更改了以下属性:authenticator:PasswordA...