0
sparkアプリケーションのcassandraテーブルに少量のデータを書き込む必要があります。データはRDDではなく、単なる二重の値です。 Java APIを使用してSparkアプリケーションでこれを行う方法は?Sparkのcassandraテーブルに少量のデータを書き込む
ありがとうございます。
sparkアプリケーションのcassandraテーブルに少量のデータを書き込む必要があります。データはRDDではなく、単なる二重の値です。 Java APIを使用してSparkアプリケーションでこれを行う方法は?Sparkのcassandraテーブルに少量のデータを書き込む
ありがとうございます。
通常の方法でsc.parallelizeを使用してRDDをCassandraに保存することができます。
あなたはドキュメントに似CassandraConnectorプールを使用することができますクエリを実行する必要がある場合:
val connector = CassandraConnector(sc.getConf)
connector.withSessionDo(session => ...)
https://github.com/datastax/spark-cassandra-connector/blob/master/doc/1_connecting.md