问题标签 [cassandra-jdbc]

我正在运行 cassandra 1.2.6 和 Apache Spark 0.8.0。

在这里，我使用 Spark 的 newAPIHadoopRDD 从 Cassandra 创建一个 RDD。

当我从 spark appln 运行作业时，我发现 cassandra 正在记录以下错误消息

在我的示例应用程序中，以下代码段工作正常。

但是当我尝试向 where 子句添加另一个参数时，查询什么也不返回！

当我在 cqlsh 终端中尝试精确查询时，它工作正常。

我需要在 YCSB 中将 Cassandra ONE 的写入和读取一致性级别更改为 QUORUM。是否需要在 Java 客户端程序内部进行更改或作为命令行参数传递。请给我一些建议

我们已经安装了 WSO2 Identity Server 4.6.0，并希望使用 Cassandra 作为主数据存储以及用户存储管理器。

我们还没有找到一个明确的途径来实现这一点。

谁能给我们一个关于如何配置此数据源并将其用作主要和唯一数据源的清晰路径？

谢谢，

我仅在不存在时才使用以下 CQL 语法创建键空间：

但它给出了错误：

请帮我解决这个问题？语法有什么问题？

我正在尝试将 xml 文件中的数据直接插入 Cassandra 数据库。它有 1089090 条记录。

我尝试使用 java 务实地阅读它，并在大约 77000 条记录后得到了这个异常。

java.sql.SqlNontrasientConnectionException：org.apache.thrift.transport.TTTransportException

我正在尝试使用 cassandra-jdbc-1.2.5 连接到 Cassandra 2.0.3。但它给出了错误：

有什么解决办法吗？

线程“主”java.lang.NoSuchMethodError 中的异常：org.slf4j.impl.StaticLoggerBinder.getSingleton()Lorg/slf4j/impl/StaticLoggerBinder；在 org.slf4j.LoggerFactory.bind(LoggerFactory.java:121) 在 org.slf4j.LoggerFactory.performInitialization(LoggerFactory.java:111) 在 org.slf4j.LoggerFactory.getILoggerFactory(LoggerFactory.java:268) 在 org.slf4j。 LoggerFactory.getLogger(LoggerFactory.java:241) 在 org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:254) 在 org.apache.cassandra.cql.jdbc.CassandraDriver.(CassandraDriver.java:52) 在 java.lang。 Class.forName0(Native Method) at java.lang.Class.forName(Class.java:169) at cql.main(cql.java:13) Java 结果：1

我可以在 cassandra 中创建一个动态且可以查询的列吗？

例如 ，

一个客户可以有 1 到 n 个地址，

每个地址都可以称为 ADDRESS1（某个地址）、ADDRESS2（某个地址）、ADDRESS3（某个地址）... ADDRESSN

我如何在 cassandra 中表示这一点，我应该也可以在特定地址上查询客户或地址。

请指教。

Is it possible to import data from Cassandra into Apache Solr?

I am currently importing data from MySQL into Apache Solr using Solr's dataimporthandler. Is it possible to use Cassandra in place of MySQL?

Update 1:

I tried to connect to Cassandra from a simple Java program using the JDBC driver given here (https://code.google.com/a/apache-extras.org/p/cassandra-jdbc/). My idea was, if the java code works, Solr should also be to import from Cassandra. But it didn't work and I got the following error:

log4j:WARN No appenders could be found for logger (org.apache.cassandra.cql.jdbc.CassandraDriver). log4j:WARN Please initialize the log4j system properly. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/cassandra/cql/jdbc/AbstractJdbcType at org.apache.cassandra.cql.jdbc.CassandraConnection.(CassandraConnection.java:146) at org.apache.cassandra.cql.jdbc.CassandraDriver.connect(CassandraDriver.java:92) at java.sql.DriverManager.getConnection(DriverManager.java:664) at java.sql.DriverManager.getConnection(DriverManager.java:270) at CqlConnection.main(CqlConnection.java:14) Caused by: java.lang.ClassNotFoundException: org.apache.cassandra.cql.jdbc.AbstractJdbcType at java.net.URLClassLoader$1.run(URLClassLoader.java:372) at java.net.URLClassLoader$1.run(URLClassLoader.java:361) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:360) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 5 more

我正在运行一个 Storm 拓扑，它从 Kafka 代理读取数据并写入 Cassandra。我的 Cassandra 螺栓之一执行读写操作。我的键空间总是动态设置的。现在我想使用连接池连接到 Cassandra？

我的流中有键空间名称。我需要将数据动态插入适当的键空间/

1）我尝试使用方法内部的连接池方法获得 Cassandra 连接，execute以便每个元组都获得一个 Cassandra 连接。所以在某个时间点后，我的连接达到了我的线程 1024 池连接限制。之后出现连接超时错误。

例子：

2）我尝试prepare在拓扑初始化worker并获得静态连接时使用方法获得连接

如果数据属于一个键空间，则第二种情况有效。但是我的案例数据属于不同的键空间，这里只有一个拓扑会识别键空间并写入该键空间。

风暴中是否有任何散列方法可用于保存键空间连接？

或者

还有其他逻辑吗？