問題タブ [pelops]

現在、クライアント ( Pelops ) を使用して UUID (語彙と時間の両方) を Cassandra に挿入しています。Pelops でそれらを削除する機能はまだ実装していません。挿入メカニズムのテストと改良を行っています。

そのため、CLI を使用してテスト UUID 値を削除したいと考えています。delただし、コマンドで UUID の行キーと列を削除できないようです。足りないものはありますか？UUID 行キーを使用assume asして列ファミリーの行を一覧表示するために使用する必要がありますが、表示された行キーを削除してもエントリは削除されません。

UUID キーを使用せずに UUID 値を含む列を表示できますがassume as(UUID キーを含む行に含まれていない場合)、CLI からそれらを削除することもできません。CLI からこれを行うことはできませんか、それとも何か見落としがありますか?

「org.apache.thrift.transport.TTransportException: java.net.SocketException: ソフトウェアが原因で接続が中止されました: ソケット書き込みエラー」

一部のバッチが処理された後にこのエラーが発生する（つまり、一部のデータが cassandra に挿入される） m casssandra の一貫性レベルに pelops クライアントを使用する場合は ONE です

ありがとう、スマート

m pelops を使用して cassandra と通信し、m 1 GB のデータを挿入しようとすると、サーバー上でのパフォーマンスがローカルよりも遅いことに疑問に思っています。 mutator.execute m を使用して .1 GB のデータ処理を挿入すると、25 分以上かかります。これに対する解決策があるかどうか、またはこれがcassandraの通常のパフォーマンスかどうかを知りたいですか?

3 ノードのクラスターを作成しました。カサンドラ 7.4 ペロプス 倹約 0.5

ありがとう、よろしく

列ファミリーのすべての行を反復処理し、各行内で列を数え、最大値と行キーを記録する「国勢調査」プログラムを作成しました。私は Hector クライアントでより多くの時間を費やしてきましたが、テストのために Pelops クライアントも作成しました。

基本的なフローは、RangeSlicesQuery を使用して行を反復し、次に各行で SliceQuery を使用して反復し、統計を収集することです。API が異なるだけで、Pelops でも同様に機能します。欠点は、バッファリングを手動で行う必要があり、行と列の両方のバッファ サイズを選択することです...私の現在のデータは 1,200 万行で、最大の列数は ~25K なので、しばらく時間がかかります...私の現在の構成では、取得しています1 秒あたり 25,000 行以上。

Hector の CountQuery を改善して発見する方法を探しています (Thrift クライアント get_count() を使用していると思います)。キーを繰り返し処理し (RangeSlicesQuery.setReturnKeysOnly() を使用)、各行キーで CountQuery を再利用する方が高速であると考えて、コードを修正しました。

遅くなっただけでなく、30 倍も遅くなりました。(1 秒あたり 900 行しか処理されませんでした)...

列を数えるより良い方法はありますか?

私はJavaとScalaでプロジェクトを作成しており、Mavenを使用してコンパイルしています。JavaクラスはPelopsを使用してCassandraデータベースにアクセスし、すべて問題ありません（mavenはプロジェクト全体をコンパイルします）が、ScalaオブジェクトからCassandraにアクセスしようとすると（Java filと同じインポートを使用して）mavenはこのエラーを表示します：

これはどういう意味で、どうすれば解決できますか？Javaファイルからそれが機能する理由はわかりませんが、Scalaソースからはわかりません...

このコード：

そしてここに結果：

しかし、なぜ例外が発生するのか理解できません.linkIDとトピック文字列には正しい値があります。

PS : cassandra のバージョンは 1.0.0 で、pelops のバージョンは 1.3-1.0.x-20111021.060203-2 です。

誰かが私を助けることができますか？

pelops api を使用して cassandra にデータを挿入しようとすると、次のエラーが発生します。

次のjarを使用しています

1. scale7-core-1.3.0.jar
2. scale7-pelops-0.912-0.7.0-rc4-1.jar
3. cassandra-1.0.5 の lib ディレクトリにあるすべての jar

次の関数を呼び出すと例外が発生します

エラー スタックは次のとおりです。

Cassandra と連携するために Pelops を使用しています。mutator を使用して一括データを挿入したい。約 20000 レコードを挿入すると正常に動作しますが、レコード数を超えると、「ピアによる接続リセット: ソケット書き込みエラー」が表示されます。以下のコードを書いています。

しかし、いくつかの限られた数のレコードで機能しています。

次のエラーが表示されます:

Pelopsを使用してCassandraDBの行をバッチ削除する方法を理解しようとしています。

理想的には、削除する必要のある行のKeyRangeを指定できます。それは私の目的にはうまくいくでしょう。

しかし、私の（簡単ではありますが）調査により、これは現在不可能であると私は信じています。RowDeletorはrowKeyのみを受け取り、KeyRangeは受け取りません。これらの調査結果は正しいですか？

List関数の1つの修正バージョンを使用してプログラムでそれを実行できるはずですが、繰り返しになりますが、KeyRangeの方が望ましいでしょう。