1 
library(RJDBC)




cassdrv <- JDBC("org.apache.cassandra.cql.jdbc.CassandraDriver",
                    list.files("/home/beyhan/Downloads/jars/",pattern="jar$",full.names=T))

    casscon <- dbConnect(cassdrv, "jdbc:cassandra://localhost:9042")

出力

> cassdrv <- JDBC("org.apache.cassandra.cql.jdbc.CassandraDriver",
+ list.files("/home/beyhan/Downloads/jars/",pattern="jar$",full.names=T))
> casscon <- dbConnect(cassdrv, "jdbc:cassandra://localhost:9042")

.jcall(drv@jdrv, "Ljava/sql/Connection;", "connect", as.character(url)[1] のエラー: java.lang.NoClassDefFoundError: org/apache/thrift/transport/TTransportException

4

2 に答える 2

0

当社の Cassandra 用 JDBC ドライバーを使用すると、R で Cassandra データにアクセスできます。明確にするために、ドライバーは Cassandra データへのリレーショナル インターフェイスを作成し、ドライバーを介して SQL クエリを Cassandra に送信できるようにします (内部的に、SQL を CQL に変換します)。 、リクエストを送信し、結果をリレーショナル データベースとして返します）。

ナレッジベースに接続に関する記事がありますが、ここでも転記します。

  1. RJDBC パッケージをロードします。

    library(RJDBC)

  2. ドライバー クラスとクラスパスを設定します。

    driver <- JDBC(driverClass = "cdata.jdbc.cassandra.CassandraDriver", classPath = "MyInstallationDir\lib\cdata.jdbc.cassandra.jar", identifier.quote = "'")

  3. JDBC 接続を初期化します。

    conn <- dbConnect(driver,"Database=MyCassandraDB;Port=7000;Server=127.0.0.1;")

    (サーバー、ポート、およびデータベース接続プロパティを設定して、Cassandra に接続します。)

この時点で、次のような R で利用可能な標準アクションを実行できます。

  • テーブルのリスト:

    dbListTables(conn)

  • Cassandra API でサポートされている SQL クエリを実行します。

    customer <- dbGetQuery(conn,"SELECT City, SUM(TotalDue) FROM Customer GROUP BY City")

  • 結果の表示:

    View(customer)

ドライバーの無料ベータ版をお気軽にダウンロードしてください! ご不明な点がございましたら、お気軽にお問い合わせください。

于 2016-05-17T19:35:09.463 に答える