-
0 votesanswersviews
Cassandra 1.2.6 java datastax驱动程序EXCEPTION没有为流0设置处理程序
我从昨天开始在最新版本的cassandra 1.2.6上使用datastax java驱动程序...我交叉检查start_native_transport:在yaml中设置了true ...我的cassandra配置了rpc_address和listen_adress作为计算机主机名....并且使用相同的名称我在客户端连接....但它显示此消息,之后挂起.build(); ... 我还交叉检查了我... -
1 votesanswersviews
cassandra如何选择群集上的哪个节点执行读/写操作?
我正在使用Cassandra datastax java API,我想知道它如何选择群集上的哪个节点来写入或读取数据 . 例如,如果我执行(通过会话)写操作1000次,那么所有操作都将转到同一节点吗?或者它会选择节点随机执行? 如果它允许我们在我们想要的节点上执行读/写操作,则遵循特定的模式(例如循环写入...),这是我们可以选择加速写入过程的最佳选择吗? 非常感谢你 . -
3 votesanswersviews
无法使用最新的cql驱动程序和默认设置连接到cassandra?
我使用的是最新版本的cassandra 3.0.2和最新版本的datastax cassandra核心java驱动程序,它是3.0.0 . cassandra.yaml中的设置保持不变 . 我没有改变那个文件 . 所以无论默认设置如何,它们都保持不变 . 我一直听说rpc_address应该是0.0.0.0,但默认情况下它是localhost,默认情况下broadcast_rpc_address... -
0 votesanswersviews
Cassandra Spark连接器
我的cassandra CF有date和id作为分区Key . 在查询时我只知道日期,所以我循环了id的范围 . 我的问题围绕连接器如何执行以下代码 . SparkDriver代码看起来像 - SparkConf conf = new SparkConf().setAppName("DemoApp") .conf.setMaster("local[*]") ... -
1 votesanswersviews
将单个令牌节点添加到现有数据集cassandra集群和数据传输不起作用
每个节点向现有数据集群集添加新的单个令牌并且数据传输无效 . 随后的过程如下所述 . 如果我所遵循的过程是错误的,请更新我 . 谢谢 我们的AWS EC2 Datacenter中有3个单令牌范围数据存储节点,启用了搜索和图形 . 我们计划在数据中心添加3个节点 . 我们目前正在为密钥空间使用DseSimpleSnitch和Simple网络拓扑 . Also our current replic... -
0 votesanswersviews
Cassandra Java异常 - NoHostAvailableException
我在VM上设置了单个Cassandra节点 . 我必须创建一个70000列的表 . 为此,我编写了读取json文件和创建表的java代码 . 这是我的java代码片段 . 当我运行我的java代码时,它会在创建一些列后抛出异常 . 异常堆栈是 public void createTable(String keyspaceName, String tableName) throws FileNotF... -
2 votesanswersviews
Spark DataFrame和Cassandra
我们一直在使用Spark RDD API(Spark 2.0)来处理在Cassandra中建模的数据 . 请注意,数据是在Cassandra中建模的,以便进行有效的读写操作 . 但是现在还有Spark SQL API,Spark DataFrame API也是一种备用数据访问方法 - http://spark.apache.org/docs/latest/sql-programming-guid... -
1 votesanswersviews
使用Datastax Java驱动程序的com.datastax.driver.core.exceptions.InvalidQueryException
我从CLI创建了这样的列系列 create column family profile with key_validation_class = 'UTF8Type' and comparator = 'UTF8Type' and default_validation_class = 'UTF8Type' and column_metadata = [ {... -
7 votesanswersviews
Cassandra:如何使用CQL插入具有良好性能的新宽行
我正在评估 Cassandra . 我正在使用datastax驱动程序和CQL . 我想存储一些具有以下内部结构的数据,其中每个更新的名称都不同 . +-------+-------+-------+-------+-------+-------+ | | name1 | name2 | name3 | ... | nameN | | time +-------+-------... -
0 votesanswersviews
Datastax Java驱动程序自动发现其连接池中特定数据中心的所有节点?
我最近开始在 Production environment 中使用 Cassandra . 我们有 24 node cluster 与 replication factor of 4 . 含义 2 copies 将在 each datacenter 中出现 . 这意味着我们有一个带有 24 nodes 的交叉colo集群,这意味着 12 nodes in SLC colo 和 12 nodes... -
1 votesanswersviews
使用CQL3批量插入Cassandra中的单个表分区
所以我有一个表,其中包含使用CQL DDL创建的静态模式 create table series ( system varchar, statisticId timeuuid, series varchar, primary key (system, statisticId, series) ) 我将在每个业务请求中插入几行数千行,但它们都属于同一个分区(列族行)... -
8 votesanswersviews
如何使用Datastax Java驱动程序的异步/批量写入功能
我打算使用Datastax Java驱动程序写入Cassandra ..我主要对Datastax java驱动程序的 Batch Writes 和 Asycnhronous 功能感兴趣,但我无法获得任何可以解释如何在我的下面的代码中包含这些功能的教程 . 使用Datastax Java驱动程序.. /** * Performs an upsert of the specified attribu... -
10 votesanswersviews
Cassandra Datastax驱动程序 - 连接池
我正在尝试理解Datastax Cassandra Driver中的连接池,所以我可以在我的Web服务中更好地使用它 . 我有1.0版本的文档 . 它说: Java驱动程序异步使用连接,因此可以在同一连接上同时提交多个请求 . 他们通过连接了解什么?连接到群集时,我们有:构建器,群集和会话 . 其中哪一个是连接? 例如,有这个参数: maxSimultaneousRequestsPerCon... -
1 votesanswersviews
如何使用java查找Cassandra协调器节点
当我使用datastax驱动程序Cluster java类为Cassandra集群创建会话时,我需要找到一个特定会话,哪个数据节点用作协调节点 . 我尝试了session.getState() . getConnectedHosts()但是这给了我集群中的所有数据节点 . 实际上在一个时间点将只使用一个协调器节点 . 任何人都可以帮我找到带有java代码的协调节点 . 谢谢 . -
8 votesanswersviews
如何使用DataStax Java驱动程序设置Cassandra客户端到节点加密?
我在我的Cassandra集群上设置了节点到节点加密 . 现在我想 Build 客户端到节点 . 根据this documentation,它应该像获取我的客户端的SSL证书一样简单并将其导入到每个节点's truststore. I don' t但是这不是我的问题 . 由于我的客户端使用DataStax Java驱动程序,似乎为了从客户端启用SSL,当我构建 Cluster 时,我应该使用wit... -
0 votesanswersviews
如何使用datastax java驱动程序在属性文件中提供cassandra的连接详细信息
Initializer myInitializer = ... // your implementation Cluster cluster = Cluster.buildFrom(myInitializer); 我试图连接到Cassandracluster与 addcontactpoints("192.1.1.1","192.2.2.2").build(... -
1 votesanswersviews
使用datastax java驱动程序连接到本地cassandra节点?
我使用datastax java驱动程序3.1.0连接到cassandra集群,我的cassandra集群版本是2.0.10 . 下面是我用来连接cassandra集群的单例类 . public class CassUtil { private static final Logger LOGGER = Logger.getInstance(CassUtil.class); private... -
1 votesanswersviews
datastax驱动程序可以从单元格/列加载数据而不是表格模式吗?
我遇到问题的表格确实有一个架构 . 在某些时间点,我们通过使用Netflix的'astyanax驱动程序 - 开始为每个插入写入“动态”列(不在模式中),因为它使用thrift API并且很容易支持这样的操作 . 现在我们要迁移到datastax驱动程序 . 但我无法弄清楚如何阅读“动态”专栏 . 我们使用datastax驱动程序提供的映射机制,并且无法映射“未定义”列 . 我看到一个选项是更改表... -
1 votesanswersviews
失败:由对等方重置连接
我一直在使用apache cassandra 3.0.11 Datastax驱动程序:3.1.3 Netty版本:4.1.6.Final 我们在数据库端经常出现以下错误: INFO [SharedPool-Worker-2] 2017-09-11 01:39:31,738 Message.java:615 - Unexpected exception during request; ... -
6 votesanswersviews
Cassandra NoHostAvailableException,但仍有活动节点
我在一个DC中有两个C * 2.0.2节点(在cassandra.yaml中有默认配置)和一个RF = 2的密钥空间 . 两个客户端使用Datastax Java Driver 1.0.3连接到此DC . 客户端使用CL = ONE从/向C *读取和写入数据,没有任何错误 . 但当我关闭一个节点时,两个客户端都会遇到大量异常: com.datastax.driver.core.exceptions... -
0 votesanswersviews
所有TCP连接b / w DataStax驱动程序到Cassandra Remain处于Active关闭状态 . 即TIME_WAIT州 .
The setup: Web server Apache TomcatRestFull网络服务使用DataStax java驱动2.0 Database -2节点Cassandra 2.0.7.31集群-replicas = 1 Problem 发送1500次请求后发送三次以上 . 我在tomcat日志中遇到错误 com.datastax.driver.core.exceptions.NoHo... -
1 votesanswersviews
Datastax java驱动程序的自动故障转移不适用于OutOfMemoryError节点故障
我不确定我是否遗漏了一些东西,但是当由于OutOfMemoryError导致cassandra节点出现故障时,我的DataStax Java驱动程序没有检测到它并仍然向它发送读取请求 . 如果我手动将节点关闭,那么它的工作正常 . 我正在使用默认值来重新连接和重试策略: LoadBalancingPolicy loadBalancingPolicy; if (datacenter ... -
2 votesanswersviews
无法使用RedHat Linux上的Java驱动程序连接到本地Cassandra单节点集群
我正在尝试将我的应用程序部署到服务器(RedHat Linux 6.5) . 作为一个节点集群和Java应用程序的Cassandra应该在同一台服务器上 . 我有问题连接java客户端与cassandra,因为它总是触发异常NoHostAvailable: 16:03:55,274 | -INFO in ch.qos.logback.classic.joran.JoranConfigurator... -
1 votesanswersviews
具有Kerberos安全性的Cassandra Java驱动程序
我试图从启用了kerberos的Datastax java驱动程序连接到cassandra安全集群 . 示例连接代码: cluster = Cluster.builder().addContactPoint(node).withCredentials("username","password").build(); Metadata metadata ... -
1 votesanswersviews
Datastax cassandra驱动程序提供有关主机状态的错误元数据信息
我有一个有2个DC的集群,每个DC包含2个节点 . DC1: 192.168.60.81 192.168.60.82 DC2: 192.168.60.242 192.168.60.247 应用程序连接到192.168.60.81,因此应用程序的本地DC是DC1 . Situation 1: 最初当所有节点都启动时,当我尝试获取 cluster.metadata.allHosts 时,它会向... -
1 votesanswersviews
使用DataStax 1.0.5 java驱动程序和Cassaforte从Cassandra 1.2读取字符串化json对象的映射时出现无效的序列化值错误
我正在使用cassaforte 1.3.0-beta9,Cassandra 1.2(DataStax)和com.datastax.cassandra / cassandra-driver-core 1.0.5(因为2.0不能与Cassandra 1.2一起使用) . 我有一个包含以下架构的表: CREATE TABLE entities ( id text, address_country... -
2 votesanswersviews
数据存储驱动程序映射ORDER BY ASC / DESC
假设下一个Cassandra ColumnFamily: CREATE TABLE myTable ( A text, B text, time timestamp, PRIMARY KEY ((A, B), time) ) WITH CLUSTERING ORDER BY (time ASC) AND bloom_filter_fp_chance = 0.... -
4 votesanswersviews
使用DataStax Java驱动程序1.0.4使用CQL连接到Cassandra时出现异常
我在我的笔记本电脑上运行了Cassandra 1.2.11 . 我可以使用 nodetool 和 cqlsh 连接到它但是当我尝试使用DataStax 1.0.4 Java API使用CQL 3.0进行连接时,我收到以下错误: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for qu... -
3 votesanswersviews
Datastax QueryBuilder插入语句
使用来自Datastax Java Driver for Cassandra的QueryBuilder构建插入语句的正确方法是什么 我正在使用Cassandra 2.x和Java Driver 2.0.0-rc1 我知道我可以使用预准备语句来实现相同的目标,但我期待着使用QueryBuilder @Test public void testTableInsert() { Insert in... -
7 votesanswersviews
如何在Cassandra中使用datastax java驱动程序有效地使用预准备语句?
我需要使用Datastax Java驱动程序查询Cassandra中的一个表 . 以下是我的代码,它的工作正常 - public class TestCassandra { private Session session = null; private Cluster cluster = null; private static class Co...