-
2 votesanswersviews
在CQL查询中使用Cassandra 'com.datastax.bdp.search.solr.Cql3SolrSecondaryIndex'
com.datastax.bdp.search.solr.Cql3SolrSecondaryIndex是Datastax为Solr集成引入的自定义Cassandra索引类型 . 我的主要问题是:_1565043已经尝试了一些带有索引列过滤器的CQL查询,但它们总是以RPC超时结束 . My use case: 我有一个表,其中查询通常涉及多列的过滤器 . 自从Cassandra 's native... -
1 votesanswersviews
使用QueryBuilder通过Cassandra进行分页
DataStax documentation表示要翻阅所有数据,以下CQL查询很有用: SELECT * FROM test WHERE token(k) > token(42); 是否可以使用 QueryBuilder 构建此查询?它提供了token方法,但这似乎只适用于列名,而不适用于值 . 理想情况下,值(在示例中为42)的类型为 Object ,就像在eq / gte / lte函... -
2 votesanswersviews
Cassandra Prepared Statement - 绑定参数两次
我有一个我想要预编码的cql查询 . cql字符串如下所示: SELECT * FROM :columnFamilyName WHERE <some_column_name> = :name AND <some_id> = :id; 我的应用程序在数据交换驱动程序之上有两层抽象 . 在一个层中,我想绑定前两个参数,而在另一个层中,我想绑定最后一个参数 . 问题是,如果我... -
2 votesanswersviews
Cassandra cppdriver查询字符串缓冲区溢出?
我一直在为CQL3.0编写Cassandra cppdriver的包装器,我遇到了一些奇怪的行为,我不确定它是典型的还是错误的 . 作为参考,我正在使用9月4日(来自存储库)的cppdriver代码版本,libuv0.10以及发布在datastax网站上的歌曲/播放列表示例(http://www.datastax.com/documentation/cql/3.1/cql/ddl/ddl_musi... -
0 votesanswersviews
Cassandra可编程列的多个准备语句
由于基础设施的限制,我们无法将运行的Cassandra版本升级到> 2.2,因此我们必须使用2.0.7 . 遗憾的是,此版本不支持使用 UNSET . 由于我们正在编写的数据具有可空列,据我所知,我们可以创建自己的 null 概念(即空字符串,空数据结构),或创建多个PreparedStatements(相同的查询,但忽略了包含 null 值,因为我们不希望将 null 绑定到Prepar... -
1 votesanswersviews
具有轻量级事务的Cassandra Datastax BatchStatement
我在使用Datastax java驱动程序组合BatchStatement和Lightweight Transactions时遇到了困难 . 考虑以下: String batch = "BEGIN BATCH " + "Update mykeyspace.mytable set record_version = 102 where id = '" + i... -
0 votesanswersviews
可以通过Cassandra Datastax驱动程序加载文件中的语句吗?
是否有可能使用Cassandra Datastax驱动程序从文件加载/执行查询?我找不到任何类/方法来做到这一点 .据我所知,驱动程序可以创建Batch语句,所以我只需要可以加载.cql文件并创建BatchStatement对象的机制 .提前致谢 . -
2 votesanswersviews
在java中,如何在cassandra数据库的单个批处理中执行类似的插入查询?
我的java代码如下: public void execute() { Batch batch = QueryBuilder.unloggedBatch(); SimpleStatement simpleStatement; simpleStatement.setConsistencyLevel(ConsistencyLevel.QUORUM); simpleStatement = new ... -
11 votesanswersviews
Cassandra:批量写入优化
我得到批量写入请求,让我们说来自客户端的20个密钥 . 我可以在一个批处理中将它们写入C *,也可以以异步方式单独写入它们并等待将来完成它们 . 批量写入似乎不是一个goo选项,因为我的插入率很高,如果键属于不同的分区,协调员将不得不做额外的工作 . 在datastax java驱动程序中是否有一种方法,我可以使用该方法对可能属于同一分区的密钥进行分组,然后将它们分成小批量,然后在异步中进行不定... -
1 votesanswersviews
Cassandra批量插入单分区键
我们正在使用datastax驱动程序与Cassandra交谈 . 我们有以下列系列 . CREATE TABLE IF NOT EXISTS "DATA".xxx ( key text, column1 bigint, value blob, PRIMARY KEY (key, column1) ) WITH COMPACT STORAGE AN... -
1 votesanswersviews
Cassandra UUID与TimeUUID有什么区别?
能否请您帮助我理解Cassandra UUID与TimeUUID数据类型值之间的区别? 非常感谢 -
1 votesanswersviews
使用Spring Data Cassandra配置SSL时出错
我正在使用Spring Data Cassandra项目v1.3.0 am我无法为我的Cassandra集群配置SSL(v2.0.17) . Sprint Data Cassandra文档称它使用DataStax Java驱动程序(2.0.X)支持Cassandra 2.X,因此不存在问题 . 这是我的Java cassandra配置初始化cassandra集群bean: @Autowired ... -
1 votesanswersviews
Cassandra UDT版本2
我想用cassandra c驱动程序 . 它仍然在版本2上运行 . (二进制协议版本2)我想使用它连接到cassandra 2.1是否可以创建一个预准备语句并在其中插入UDT值 . 或UDT只能与协议版本3一起使用 问候 -
1 votesanswersviews
运行远程cqlsh以在Cassandra Cluster上执行命令
所以我的Ubuntu机器上有一个包含6个节点的Cassandra集群,现在我有另一台运行Windows Server 2008的机器 . 我在这台新的Windows机器上安装了DataStax Apache Cassandra,我希望能够运行所有的CQL命令Windows机器到Ubuntu机器上 . 所以就像远程命令执行一样 . 我尝试使用cqlsh在cmd中打开cqlsh,其中包含我的一个节点和... -
1 votesanswersviews
Cassandra JMX Bean监控提示
有没有办法使用JMX Bean监视cassandra集群中的提示? 我在看:http://cassandra.apache.org/doc/latest/operating/metrics.html#hintsservice-metrics,我看到以下指标 Metric Name : org.apache.cassandra.metrics.HintedHandOffManager.<Met... -
0 votesanswersviews
如何在datastax中实现rdd.bulkSaveToCassandra
我正在使用5.0.5的数据集群 . [cqlsh 5.0.1 | Cassandra 3.0.11.1485 | DSE 5.0.5 | CQL规范3.4.0 |原生原型 使用spark-cassandra-connector 1.6.8 我试着实现下面的代码..导入不起作用 . val rdd:RDD [SomeType] = ... //创建一些RDD来保存导入com.datastax.... -
0 votesanswersviews
如何使用spark-cassandra-connector连接火花和 Cassandra ?
你必须原谅我的noobness但我正在尝试设置一个连接到运行python脚本的cassandra的spark集群,目前我正在使用datastax enterprise在solr搜索模式下运行cassandra . 据我所知,为了使用datastax提供的spark-cassandra连接器,您必须在分析模式下运行cassandra(使用-k选项) . 目前我只使用dse spark版本才能使用它,... -
0 votesanswersviews
安装dse-full之后Cassandra没有出现
我有一个工作3节点cassandra集群,我发现在安装过程中我没有安装dse . 所以我在所有三个节点中安装了dse-full和opscenter . 但是在安装之后我发现cassandra节点都没有启动,所以我重新启动了集群节点 . 重新启动后,当我尝试运行caassandra服务时,我面临以下异常: Fatal exception during initialization org.apach... -
1 votesanswersviews
spark工作者如何在cassandra集群中分配负载?
我试图了解cassandra和spark如何协同工作,尤其是当数据跨节点分布时 . 我使用DSE使用两个节点集群进行cassandra spark设置 . 架构是 CREATE KEYSPACE foo WITH replication = {'class': 'SimpleStrategy','replication_factor':1} CREATE TABLE bar ( cust... -
0 votesanswersviews
在Cassandra上启用与同一节点上的Spark
我试图测试Spark,所以我可以总结一下我在Cassandra的一些数据 . 我已经浏览了所有的DataStax教程,他们对于如何实际启用spark非常模糊 . 我能找到的唯一指示是,在安装期间选择“Analytics”节点时会自动启用它 . 但是,我有一个现有的Cassandra节点,我不想使用不同的机器进行测试,因为我只评估笔记本电脑上的所有内容 . Is it possible to jus... -
1 votesanswersviews
Cassandra 和火花
嗨我有一个关于集群拓扑和数据复制的高级问题,关于在数据存储企业中一起使用的cassandra和spark . 我的理解是,如果群集中有6个节点,并且执行了大量计算(例如分析),那么如果需要,您可以拥有3个火花节点和3个cassandra节点 . 或者,您不需要三个节点进行分析,但您的作业运行速度不会很快 . 您不希望在cassandra节点上进行大量分析的原因是因为本地内存已经用于处理cassan... -
0 votesanswersviews
Datastax Spark worker始终在127.0.0.1寻找master
我试图通过使用“dse cassandra -k -s”在分析模式中调出datastax cassandra . 我在单节点设置上使用DSE 5.0沙箱 . 我已经使用SPARK_MASTER_IP配置了spark-env.sh以及SPARK_LOCAL_IP来指向我的LAN IP . export SPARK_LOCAL_IP="172.40.9.79" export SPA... -
1 votesanswersviews
Datastax 6独立分析服务器
我下载了数据传输6并希望启动一个(在Mac El Capitan上)分析(火花很好,但火花搜索会很好) . 我解压缩了gz,配置了目录结构并执行了 dse cassandra -ks . 启动似乎工作得很好,我可以到火花主节点,问题是当我运行 dse spark-sql (或只是火花) . 我经常遇到以下错误:是否可以设置单个节点进行开发? ERROR [ExecutorRunner for a... -
1 votesanswersviews
无法在Cassandra从2.1.0升级到2.1.7的集群中添加节点
我正在将 生产环境 服务器上的cassandra从2.1.0升级到2.1.7(最新的稳定版本) . 我已经为此做了一个并行集群,用于在将 生产环境 转移到datastax cassandra 2.1.7二进制文件之前进行测试 . 我用2.1.7二进制文件创建了两个服务器,并在服务器上复制了我的 生产环境 数据 . 当我启动节点1然后一切似乎都很好,但在启动另一个节点时,我收到错误 . “错误:群... -
0 votesanswersviews
单击Spark控制台时,带有HTTPS的OpsCenter会终止会话
我有一个在2个AWS节点上运行的DataStax Enterprise集群 . DSE以企业模式安装,其中一个节点以分析模式配置 . 一切正常,直到我按照此处列出的步骤为OpsCenter启用HTTPS:http://docs.datastax.com/en/opscenter/5.0/opsc/configure/opscEnablingAuth.html OpsCenter身份验证现在正常运... -
1 votesanswersviews
无法使用SPARK_ENABLED = 1启动DSE
我们运行6节点集群: HADOOP_ENABLED=0 SOLR_ENABLED=0 SPARK_ENABLED=0 CFS_ENABLED=0 现在,我们想为所有人添加Spark . 似乎“添加”不是正确的术语,因为这不会失败 . 无论如何,我们已经完成的步骤:1 . 排空其中一个节点2.将/ etc / default / dse更改为SPARK_ENABLED = 1和HADOOP_ENA... -
2 votesanswersviews
Cassandra Spark Datastax Replica
我在Cassandra有3个 table 聚集成几个节点,火花 Worker 坐在他们每个人的顶部 . 让我们称这些表为A,B和C. A和B很大但它们具有相同的分区键,因此当我将它们连接在一起时,数据局部性就会得到保持 . 现在我想加入另一个表C,它有不同的分区键,但不像其他两个那么大 . 如果必须的话,我也准备将表复制到我的所有节点 . 如何将它们连接在一起,以最小的shuffle维护数据位置?... -
2 votesanswersviews
Cassandra UDT嵌套集InvalidTypeExeception
我正在使用Cassandra 2.1中的UDT进行实验,并在使用InvalidTypeExeception时遇到困难 . 我将表格设置为: session.execute("CREATE TYPE mykeyspace.address (" + " street text," + ... -
1 votesanswersviews
Cassandra中的用户定义类型(UDT)行为
如果有人在使用UDT(用户定义类型)方面有一些经验,我想了解向后兼容性如何工作 . 说我有以下UDT CREATE TYPE addr ( street1 text, zip text, state text ); 如果我修改“addr”UDT以获得更多属性(例如zip_code2 int和name text): CREATE TYPE addr ( street1 text, ... -
0 votesanswersviews
Cassandra - 如何重新修改键空间和表格?获得警告 - 重新准备已经准备好的查询通常是一种反模式
得到警告: 重新准备已准备好的查询通常是一种反模式,可能会影响性能 . 考虑只准备一次声明 . 我看到了各种类似的问题,例如Datastax: Re-preparing already prepared query warning,但它们没有解决重新分配查询使用的键空间或表的问题 . 我通常可以重用查询,但它需要为每个键空间和表缓存它,我不想管理状态 . 或者,我可以在执行查询之前重新绑定键空间和...