問題タブ [phantom-dsl]

私はファントムウィキで提供されているsmipleコードをいじっています。私が試したのは次のとおりです。

しかし、私のIDEは言い続けCannot resolve symbol where、コンパイラは言いますvalue where is not a member of com.websudos.phantom.builder.query.RootSelectBlock[Students,Student]

私は Scala2.11.6と Phantomを使用し1.10.1ています。すべてのヘルプが大歓迎です!

私はスパークとカサンドラの初心者です。以下のように、spark-cassandra コネクタを使用して cassandra テーブルに挿入しようとしています。

上記の方法（100個のエンティティを含むリスト）を使用して挿入すると、300-1100 milliseconds. ファントムライブラリを使用して同じデータを挿入しようとしました。未満しかかかっていません20-40 milliseconds。

スパークコネクタの挿入にこれほど時間がかかる理由を誰か教えてもらえますか? コードで何か間違ったことをしていますか、それとも挿入操作にspark-cassandra コネクタを使用することはお勧めできませんか?

1 つの列がカスタム オブジェクトのオプション リスト タイプであるテーブルがあります。Websudos ファントムを使用して、この列の cassandra からデータをフェッチする方法。

テーブル スキーマ:

Server{ hostName : String port: Int filter : Option[List[Filter]] }

Filter{ filterKey : String, value : List(String) }

テーブル「サーバー」と「フィルター」の両方のケース クラスを作成しました。

これにより、List[filter] が提供され、さらに Option[List[Filter]] に変換する方法が提供されます。

orderBy 関数が 1 つ以上の s を取るため、複数の orderBy 句を持つファントム v1.5.0 を使用したクエリがありましたOrderingCondition。

1.11.0 (実際には 1.8.0) への更新で、クエリ API が変更され、1 つの順序条件のみが許可されるようになりました。をチェーンしようとするとorderBy、最初の によって返されたSelectQueryで次のエラーが発生します。SelectQueryorderBy

Ordered が Unordered と等しくないことは明らかですが、1 列の合計でしか注文できないことも暗示しているようです。

orderBy複数の を新しい Phantom クエリ API に追加するにはどうすればよいですか?

私はscala（長年のJava開発者）が初めてです。私は暗黙を理解しようとしましたが、基本は理解していると思いますが、暗黙の値が見つからない理由がわかりませんsession。できるだけ多くの情報で問題を説明しようとしました。

次のブログ投稿に従いました: http://blog.websudos.com/2015/04/04/a-series-on-phantom-part-1-getting-started-with-phantom/

テストするまで、すべてがうまくコンパイルされました。次のエラーが発生します。

次のテストクラスを実行すると:

以下に書いた他のクラスもコピーしました。

TwitterMessages.scala

データベース.scala

cassandra にバッチ挿入するための phantom-dsl にバッチ挿入 API はありますか? 検索を試みましたが、コード内に見つかりませんでした。

また、ファントム ライブラリに関する十分なドキュメントが見つかりませんでした。

私は、定期的な書き込みと大量の読み取りを一度に必要とするアプリケーションに取り組んできました。

アプリケーションは、サイズがそれほど大きくないいくつかのテキスト列と、テーブル内で最大の列であるマップを格納しています。

Scala (下にある Datastax Java ドライバー) で Phantom-DSL を使用すると、データ サイズが大きくなるとアプリケーションがクラッシュします。

ここに私のアプリケーションからのログがあります。

そして、ここにcassandra のログがあります。

Cassandra のログは、回答に埋め込むにはかなり大きいため、ペーストビンに投稿しました。

このクラッシュの理由を理解できないようです。タイムアウトを増やし、行キャッシュをオフにしようとしました。

私の理解では、これは基本的な問題であり、この特別なケースに合わせて Cassandra を調整することで解決できます。

カサンドラの使用状況は、さまざまなデータ ソースからのものです。したがって、書き込みはそれほど頻繁ではありません。ただし、一度に 300K を超える行が必要になる可能性があるため、読み取りはサイズが大きく、HTTP 経由で転送する必要があります。