Spark 1.6 aデータフレームをCassandraに挿入

データフレームにcassandraを挿入しようとしています。Spark 1.6 aデータフレームをCassandraに挿入

私は rdd.tosaveToCasssandra（「鍵空間」、「テーブル」）を書く

問題ありませんが、私は私が試みたが、保存されませんでした。また、この機能を

myDataFrame.tosaveToCassandra("keyspace","table")

を書き込むことはできません。

myDataFrame.write.format("org.apache.spark.sql.cassandra").mode('append').options(table="mytable", keyspace="mykeyspace").save()

はPython用

出典

2016-12-22 Beyhan Gül

最初の試行が間違っています。 RDDSのみの場合 2番目の方法は正しいです。なぜそれが保存されなかったと思いますか？ – RussS

私はあなたがオプションを適切に与えたとは思わない。これは、マップを期待しているので、あなたはむしろこの方法を試すことができますpaddedGtpProfiles.write.format（ "org.apache.spark.sql.cassandra"）。mode（SaveMode.Append）.option（ "table"、 "mytable"）。option（ "keyspace"、 "mykeyspace"）。save（） – Srini

エラーが発生しましたか？ – Srini

が現在スパークカサンドラコネクタでカサンドラのためのストリーミングシンクはありませんあなたは2.0

おかげスパークのための新しいAPIから以外の任意のアイデアを持っていますか、あなたが実装する必要がありますあなたの自分の。

出典

2017-10-26 11:27:13

Spark 1.6 aデータフレームをCassandraに挿入

答えて

関連する問題