1

我有一个 Cassandra 实例在我的本地主机上运行。对于这个例子，我使用了 conf\cassandra.yaml 中提供的默认配置

我尝试使用 RCassandra 包将 R 连接到 Cassandra。

基本上，我刚刚在 R 中安装了 RCassandra 包并尝试连接。

library("RCassandra")
RC.connect('localhost','9160')
RC.connect('127.0.0.1','9160')

这些都不起作用。这是我得到的错误：

Error in RC.connect("localhost", port = "9160") : 
  cannot connect to locahost:9160

使用具有相同参数的 Cassandra-cli 可以工作。你能帮忙吗？

谢谢

4

2 回答 2

2

start_rpc: true在 cassandra.yaml 文件中设置。

于 2016-02-17T14:27:06.627 回答
1

无法修复它，但找到了让它工作的方法：启动一个 jdbc 连接，然后启动 RCassandra

  #Load RJDBC

library(RJDBC)

#Load in the Cassandra-JDBC diver
cassdrv <- JDBC("org.apache.cassandra.cql.jdbc.CassandraDriver",
        list.files("C://Users//aab_ITSolutions//apache-cassandra-1.0.10//lib",pattern="jar$",full.names=T))

#Connect to Cassandra node and Keyspace
casscon <- dbConnect(cassdrv, "jdbc:cassandra://localhost:9160/DEMO")

#Query timeseries data
res <- dbGetQuery(casscon, "select * from StockHist limit 10")

library("RCassandra")

connx = RC.connect('localhost',9160)
于 2012-07-26T11:13:39.593 回答