spark-cassandra-connector

0熱

1答えて

Spark Cassandra Connectorにはどのバージョンを使用する必要がありますか？

私はspark-cassandraコネクタ、Cassandra Driver、Scalaバージョンにどのバージョンを使用すべきか混乱しています。どんな助けもありがとう。

4熱

2答えて

cassandraデータベースには、user_idというタイトルの列が含まれているテーブルが多数あります。値user_idは、テーブル・ユーザーに格納されているユーザーを参照します。一部のユーザーが削除されると、user_idというタイトルの列を含むすべての表の孤立したレコードを削除したいと考えています。明示的にテーブルのリストを定義しないために、CassandraSQLContextまたは他の

0熱

1答えて

Cassandra Spark Connector

私のcassandra CFはパーティションキーとして日付とIDを持っています。クエリー中に私は日付しか知りませんので、IDの範囲をループします。私の質問は、コネクタが次のコードをどのように実行するかを中心にしています。 SparkDriverコードがどのように見える - SparkConf conf = new SparkConf().setAppName("DemoApp") .conf

0熱

2答えて

スパークストリーミングフィルタリング私はストリーミングデータをフィルタ処理しようとすると、id列の値に基づいています

ストリーミングデータiが異なるテーブルにデータを保存したい私は2つのテーブルを持っていますtestTable_odd（ID、DATA1、DATA2） testTable_even（ID、DATA1） id値が奇数である場合、値はその後もあるならば、私はtestTable_oddテーブルにレコードを保存すると、私はtestTable_evenにレコードを保存したい。ここで難しい部分は私の2つの

3熱

1答えて

データフレームのorg.apache.spark.mllib.linalg.Vectorをcassandraに保存する方法

org.apache.spark.mllib.linalg.Vectorを含むデータフレームを列の1つに保存する必要があります。データフレームからcassandraにテーブルを作成している間、エラーが発生しています。 java.lang.Exception: Cassandra Writer Failed. java.lang.IllegalArgumentException: Unsupport

0熱

1答えて

Cassandra ClusterはSpark経由でノードを見ることができません

私はSpark経由で書き込みをしようとしています。私は、クラスタ内の6つのノードを持っており、それに私がデータを書き込みしたい鍵空間を作った：：私はスパークから書き込みをしようとしている CREATE KEYSPACE traffic WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '2'} AND d

0熱

1答えて

スパークコネクタ - タプル

のリストを使用した場合、データを取得することができない私は私のJavaBean public class LiveResultsFrmCassandra implements Serializable{ UUID id; String userdn; String queryid; private List<Tuple4<String, String

1熱

1答えて

カッサンドラは異なるランで異なる結果を示しています

私はスパークからカッサンドラに2億本のレコードを摂取しました。 spark-cassandraコネクタを使用する。私は次の2つの問題に直面しました。申し訳ありませんが、件名は1つの質問のみを参照しています。 1）com.datastax.driver.core.exceptions.WriteFailureException：一貫性LOCAL_QUORUMでの書き込みクエリ中のカサンドラの失敗（

2熱

1答えて

スパークが原因とClassNotFoundExceptionに失敗します。com.datastax.spark.connector.rdd.partitioner.CassandraPartition（内部の詳細）

私はscala 2.11でspark 2.0.0（ローカルスタンドアロン）とspark-cassandra-connector 2.0.0-M1を使用しています。私は、IDEのプロジェクトに取り組んでいますし、毎回私は、スパークのコマンドを実行して、私は ClassNotFoundException: com.datastax.spark.connector.rdd.partitioner.Cas