-
1 votesanswersviews
cassandra如何选择群集上的哪个节点执行读/写操作?
我正在使用Cassandra datastax java API,我想知道它如何选择群集上的哪个节点来写入或读取数据 . 例如,如果我执行(通过会话)写操作1000次,那么所有操作都将转到同一节点吗?或者它会选择节点随机执行? 如果它允许我们在我们想要的节点上执行读/写操作,则遵循特定的模式(例如循环写入...),这是我们可以选择加速写入过程的最佳选择吗? 非常感谢你 . -
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 1.2.6 java datastax驱动程序EXCEPTION没有为流0设置处理程序
我从昨天开始在最新版本的cassandra 1.2.6上使用datastax java驱动程序...我交叉检查start_native_transport:在yaml中设置了true ...我的cassandra配置了rpc_address和listen_adress作为计算机主机名....并且使用相同的名称我在客户端连接....但它显示此消息,之后挂起.build(); ... 我还交叉检查了我... -
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... -
2 votesanswersviews
从Spark工作人员读取和写入Cassandra会引发错误
我正在使用Datastax Cassandra java驱动程序从spark worker写入Cassandra . 代码段 rdd.foreachPartition(record => { val cluster = SimpleApp.connect_cluster(Spark.cassandraip) val session = cluster.connect(... -
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... -
5 votesanswersviews
有关如何将map cql类型与DataStax java驱动程序一起使用的示例
我正在尝试使用datastax java驱动程序来更新和查询具有映射字段的列族 . 有没有人关于如何使用Datastax Java驱动程序使用cql集合的示例? 谢谢 -
1 votesanswersviews
在Cassandra中使用一组值准备好的语句
我正在使用数据存储Cassandra 2.0驱动程序,我正在使用准备和绑定语句 . 假设我想查询这样的内容: SELECT * FROM foo WHERE mykey IN (UUID1, UUID2, UUID3); 其中UUID1,UUID2,UUID3是UUID值 . 使用绑定语句执行此操作的编程方式是什么?目前我正在尝试以下方面: preparedStatement = session... -
0 votesanswersviews
使用datastax将Map记录插入Cassandra
我使用datastax java驱动程序与cassandra进行通信,我要求将 Map 插入到cassandra中,但是以每个 key,value of map 的形式作为单独的记录 . 下面是我的示例表模式 CREATE TABLE emp ( key int PRIMARY KEY, value text ) 以下是我正在使用的示例代码 String insertStatem... -
0 votesanswersviews
cassandra日期类型的Java等效类型(映射)
我正在尝试使用cql在cassandra中使用一个'date'类型的字段在我的键空间中创建一个表 . 查询如下: create table if not exists data( product_type varchar, end_date date, primary key(product_type,end_date) ); 现在我的Java模型类正在使用 com.d... -
5 votesanswersviews
使用datastax java驱动程序2.1.7高速插入cassandra的数据丢失
我是apache-cassandra的新手,我打算将它作为新项目的数据存储库用于其写入性能 . 我已经设置了一个带有三个节点和复制因子3的cassandra集群 . 我的程序A使用datastax的cassandra-driver-core 2.1.7来编写和读取来自cassandra的数据 . 每次执行程序都会使用批处理语句将大约50条记录写入cassandra . 单次执行的测试显示完全没有问... -
1 votesanswersviews
带有DataStax Java驱动程序的单个多线程Java客户端,用于Apache Cassandra,不使用系统资源
我很感激有关多线程优化设置的任何指导, high throughput low latency Java Client using DataStax Java Driver for Apache Cassandra . 我不赞赏“滚动你自己”的基准测试,但是这项任务也是为了实现高TPS的实际应用程序的概念验证 . 设置: Client Side :Java 8客户端,可配置数量的多线程执行程序线... -
1 votesanswersviews
Cassandra Datastax驱动程序准备语句仅评估'now()'一次
我正在使用Cassandra 1.2.4和1.0.0的Datastax java驱动程序(通过Clojure的Alia,但我认为这不重要) . 如果我使用timeuuid列准备一个语句,并将'now()'放在timeuuid的值中,则now()会在编译预准备语句时进行一次评估,然后再也不会 . 想象一下这个准备好的声明:“插入some_table(id,time)值(?,now())” 在准备之后... -
6 votesanswersviews
Datastax PreparedStatements的工作原理
当我们创建PreparedStatement对象时,它是否缓存在服务器端?与Oracle驱动程序中的PreparedStatement相比有何不同?如果重用了准备好的语句,那么将什么数据发送到Cassandra服务器,只有param值? 据我所知,java驱动程序中的一个Session对象拥有多个与集群中多个节点的连接 . 如果我们在多个线程中的应用程序中重用相同的预处理语句,是否会使我们只使用一... -
1 votesanswersviews
Cassandra datastax一致性级别问题
我正在为我的应用程序创建一个cassandra会话对象,并为它创建一些预备语句 . 在每个预准备语句上设置不同的一致性级 statement1 = session.prepare("SELECT key FROM foo WHERE key = ?"); statement1.setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM);... -
3 votesanswersviews
如何使用来自datastax的java api从语句中获取精确的cql
我的代码直接执行没有任何确切查询的边界语句 . 然后如何获取它试图在cassandra数据库中执行的cql? 例如: public <T> void save(T entity) { if (entity != null) { Statement statement = getEntityMapper(entity).saveQuery(entity); ... -
6 votesanswersviews
使用DataStax驱动程序的Cassandra行级锁定支持
当前用户访问同一行时,Cassandra行级锁定支持 考虑到Cassandra作为库存数据库,我们处于推车应用的设计阶段 . 现在的要求是,如果多个用户同时访问Inventory DB中的相同产品行 . 例如: - 产品表:productID productQuantitiy 1000 1如果第一个用户选择产品“1000”并在购物车中添加产品数量为“1”,访问同一产品的其他用户在获得免费之前不应该...