問題タブ [spring-data-cassandra]

Spring Data Cassandra 1.0.0 を使用しています。私は自分のエンティティを永続化して読み返すことができました。ただし、エンティティの 1 つのフィールドのみを返すクエリを実行したいと考えています。

これは私が試したことです：

cassandraOperationsはCassandraTemplateインスタンスです。

だから私はテーブルmessage_timeから選ぶだけです。data_messageこれはtimestamp列なのでDate.class、select()メソッドに a を渡しますが、これにより次の例外が発生します。

1 つのフィールドだけを照会するにはどうすればよいですか?

PS: このクエリを実行するためのより効率的な方法をご存じでしたら、それもお知らせいただければ幸いです。

spring-data-cassandra私は初めてセットアップしていますが、次のようなクラスがあります。

これにより、起動時にエラーが発生します。

バックグラウンドから来て、spring-data-jpa単に注釈Locationを付けるだけで@Embeddable以前は十分でした。では動作しないようspring-data-cassandraです。で複合エンティティを使用するにはどうすればよいspring-data-cassandraですか?

自分で注釈を付けlocationてシリアライズを行う必要がありますか? @Transientクラスに で注釈を付けようとしましたが、 on が見つからない@Persistentというエラーが発生しました。なぜ主キーが必要なのか理解できません...PrimaryKeyLocation

次のシナリオを想像してみてください。Spark アプリケーション (Java 実装) は、Cassandra データベースを使用してロード、RDD への変換、およびデータの処理を行っています。また、アプリケーションは、カスタム レシーバーによって処理されるデータベースからの新しいデータをストリーミングしています。ストリーミング プロセスの出力は、データベースに格納されます。実装は、データベースとの統合から Spring Data Cassandra を使用しています。

CassandraConfig:

DataProcessor.main メソッド:

初期ロードには大量のデータが含まれることが予想されます。このため、データはページ分割され、ロードされ、rddBuffer に配布されます。

次のオプションも利用できます。

1. Spark-Cassandra の例 ( https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala )。最小限のドキュメントしかありません。この例では。
2. Calliope プロジェクト ( http://tuplejump.github.io/calliope/ )

Spark と Cassandra を統合するためのベスト プラクティスを教えてください。私の実装で従うべき最良のオプションは何ですか?

アパッチ スパーク 1.0.0、アパッチ カサンドラ 2.0.8

私はSpring Data cassandraを使用しています。以下に定義されている@Tableがあります。

私のdaoコードでは、列挙値を設定して保存しています。しかし、私はエラーが発生します。

しかし、保存アクションの実行中にこのエラーが報告されました

クエリ ビルダに不明なタイプの無効な値 CONNECTOR...

spring Data は、列挙型から cassandra の文字列データ型への変換を処理しませんか?

ここで失敗しているものへのポインタ。

spring-data-cassandra モジュールを使用しています。

@Table アノテーションを使用したアノテーション付き Bean と、@PrimaryKeyClass

主キー クラスには 5 つの主キー列があります (2 つのパーティション化されたものと 3 つのクラスター化されたもの)。私の列の2つには name プロパティがあります。

CassandraTemplate挿入操作を使用すると、すべて正常に動作しますがcassandraTemplate.deleteAsynchronously(List<entities> list)、列名を使用している場合、名前プロパティを使用して解析されず、フィールド名を維持します。

単一のオブジェクトに対して通常の削除操作を使用しようとし、 f​​orceQuote = true プロパティを使用しようとしましたが、どちらも役に立ちませんでした。

誰かが前にこの問題に遭遇しましたか?

spring-data-cassandra プロジェクトで読み取り/書き込みの一貫性レベルをまったく設定しない場合、読み取りの一貫性レベルはどうなりますか? 書き込みはどうですか？

(私はここでこの質問をしましたが、Google グループは現在ロックされています)

findAll()リポジトリでは、返す前にすべての結果をフェッチしますか? 私がこれを尋ねている理由はOutOfMemoryException、かなり大きなデータセット (ディスク上で約 15 GB) で呼び出したときに得たからです。が返されたIterable<T>ので、データセット全体を簡単に反復処理できるように、バックグラウンド バッチ処理を行うことを期待していました。

メソッドでより大きなクエリ結果が許可されない場合は、JIRA で問題を報告すると思います。