datastax-java-driver

0热度

1回答

我正在运行Java datastax驱动程序以执行cql查询以在一个查询中一起创建模式和表。接收EOF异常如下。 session.execute("CREATE KEYSPACE testkeyspace WITH REPLICATION = { 'class' : 'org.apache.cassandra.locator.SimpleStrategy', 'replication_factor

0热度

2回答

批量插入是唯一一个在卡桑德拉

记录我使用DataStax Java驱动程序 PreparedStatement pstmt = cqlSession.prepare("INSERT INTO ks_mobapp.messages(pair_id, date, belong_to, message_id, text, sender) VALUES(?, ?, ?, ?, ?, ?);"); BoundState

0热度

3回答

EACH_QUERY与数据中心丢失的容差

我正在寻找一些关于在3个数据中心场景中实现EACH_QUORUM一致性的一些想法，并且容忍1个数据中心丢失的写入。根据我的理解，EACH_QUARUM不允许数据中心丢失。只要数据中心停机，我所有的写入操作都会失败。一种选择是，以“QUORUM”等较低的一致性级别重试请求。我正在寻找的选项是，如果有一种方法可以删除失败的DC并在剩余的两个实时数据中心上实现EACH_QUORUM。从服务器端，只有

1热度

1回答

打开卡桑德拉sstables行数

我打算打开行数和墓碑给定的cf的所有sstables。它实际上是ISSTableScanner，并且像往常一样必须扫描sstable中的每一行。如果给定cf的sstable数量有限，这可以正常工作。但是，如果你有1000个sstables，那么这个方法会导致性能问题，因为它必须打开每个sstable和扫描。是否有任何最好的方式来打开给定cf的所有sstables？我知道Runnable接口用于

0热度

1回答

将Cassandra远程连接安装为服务后失败

起初，我的远程连接工作得非常好，我可以通过C＃访问它，并在其上执行查询。但我希望Cassandra作为服务运行，所以我可以注销并遵循以下链接：Cassandra as a Windows Service并安装了datastax版本。在本地机器上，此功能完美无缺。它作为服务器运行，我也可以执行查询。但是当我在远程机器上运行Cassandra作为服务时。我收到以下错误信息：型“Cassandr

0热度

1回答

Datastax驱动例子

我是一个像Maven这样的依赖管理工具的新手。我正在尝试执行https://github.com/datastax/java-driver上的示例。但是，我有构建错误。例如项目<parent>中的标签pom.xml有以下错误：Plugin execution not covered by lifecycle configuration: org.codehaus.mojo:clirr-maven-

2热度

1回答

Spark DataFrame和Cassandra

我们一直在使用Spark RDD API（Spark 2.0）处理在Cassandra中建模的数据。请注意，数据在Cassandra中进行建模以便高效读写。但是现在也有星火SQL API的星火据帧API，这也是另一个数据访问方法 - http://spark.apache.org/docs/latest/sql-programming-guide.html 火花RDD，我们使用CQL使用Data

0热度

1回答

分页使用自定义的有效载荷选项与Java驱动程序3.1和卡桑德拉

我使用cassansra 3.7和Java 3.1驱动程序。我写了一个java代码来连接cassandra并从数据库中获取数据。我发现，分页将使用自定义负载选项，通过以下这个网址http://datastax.github.io/java-driver/manual/custom_payloads/ 有可能，但我没有发现任何例如使用自定义的有效载荷来实现分页。任何人都可以请让我知道如何使用这个

0热度

1回答

Cassandra Spark连接器

我的cassandra CF具有日期和id作为分区键。查询时我只知道日期，所以我遍历了id的范围。我的问题围绕着连接器如何执行下面的代码。 SparkDriver代码看起来像 - SparkConf conf = new SparkConf().setAppName("DemoApp") .conf.setMaster("local[*]") .set("spark.cassandra.c

1热度

2回答

运行形容架构使用datastax卡桑德拉驱动3.0

当我试图运行使用datastax驱动程序3.0“形容密钥空间keyspacename”命令时，它给我一个错误 Exception in thread "main" com.datastax.driver.core.exceptions.SyntaxError: line 1:0 no viable alternative at input 'DESCRIBE' ([DESCRIBE]...)