問題タブ [pelops]

私はCQL3CFを持っています

そして、ペロプスを使用すると、Bytes（[0、4、0、0、0、4、0、0、8、0、0、1、55、-56、-41、6、14、0、 0、16、65、50、82、97、84、85、95、82、72、71、115、69、89、115、100、49、0、0、8、0、4、-63、- 24、-121、-16、35、-80、0、0、2、105、103、0]）この例外：

同じ方法で他のバイト配列を挿入できます。

pelopsを使用して、すべてのサーバーがIPv6で実行されているcassandraクラスターからデータを取得しています。このプログラムの実行中に次のエラーが発生します。

ペロプスはIPv6をサポートしていますか？そうでない場合、Hectorに移行する予定ですが、Hectorもこのサポートを持っていますか？

作成した列ファミリーに対して、いくつかの簡単なテスト（挿入と削除）を実行していました。行キーに対して新しい列が挿入されているのに、最近削除された列が挿入されないことを確認しました。

例えば：

rowkey1 :: name1-val1
                 name2-val2

name1を削除した後、もう一度挿入しようとすると、次のようになります。

rowkey1 :: name2-val2であり、name1-val1、name2-val2に戻りません。

（Pelops Javaクライアントを使用して）コードから挿入しようとすると、問題が発生します。挿入に使用するコードスニペットは次のとおりです。

ありがとう

Cassandra db を使用した Java アプリケーションがあります。Cassandra Pelops を使用しています。columnFamily cf1 があり、そこには多くの列があります。それらのいくつかについては、セカンダリ インデックスを作成したので、それらを検索に使用できます。検索目的で、次のような IndexExpression (式) のリストを作成しました。

ここで、追加のチェックを含める必要があります。dateFrom と dateTo の列があります。リクエストは、この 2 つの日付がある間隔内にあるすべての行を返すことです。完全に間隔内にある必要はありません。重要なのは、この間隔内で開始または終了することです。だから、私はどういうわけか次のようなものを実装する必要があります:

IndexExpression を使用して。助言がありますか？私は明確だったと思います！前もって感謝します！

行を削除した後、同じ行キーのデータを再挿入しようとしていますが、挿入されません。例外もスローされません。

削除後、Pelops RowDeletor を使用して行データを削除しています (行キーは列なしで表示されていることに注意してください)。テーブルを切り捨てて再挿入すると、列が挿入されます。

整合性レベルを ANY から ONE、ALL に変更してみました。問題は何か、またはヘクタークライアントに行くべきかについてのアイデアはありますか?

java.lang.NoClassDefFoundError: org/apache/log4/Level を取得しています。

私は Java の専門家ではありませんが、コードを読むことはできます。この例外を取り除くにはどうすればよいですか? この例外は実際には cassandra hector api とは何の関係もありません。なぜ気になるのですか?

ありがとう！

Java クライアントを使用して、Cassandra 列ファミリーの行をコピー/複製するための推奨される方法はありますか?

現在、Cassandra 1.1.8 で Hector (1.0-2) を使用していますが、別のクライアント ライブラリに切り替えても問題ありません。

カサンドラ 1.0.12

名前が transactionRecords の列ファミリーがあり、その行キーは「ApplicationName」です。列ファミリーは、(UUID、transInfo) のような名前と値のペアで、トランザクションを記録するために使用されます。

約 1.5K TPS の高負荷で、1 時間後、SliceRange クエリは非常に遅くなります。sliceRage については、10000 などの制限のみを設定します。開始と終了は空です。sliceRange を使用してトランザクション情報を読み取り、いくつかのビジネス ロジックを実行してから、Cassandra から削除します。

org.scale7.cassandra.pelops.Mutator API を使用して DB に挿入します。 Mutator.writeColumn(columnFamily, rowkey, Mutator.newColumn(uuid, string));

nodetool を使用すると、SliceRange の読み取り時にレイテンシが 10 秒を超えます。

しかし、今では、読み取り時に TimedOutException が発生します。

誰かが同様の問題を抱えていますか？レイテンシーを減らすには？私たちのデータ構造は私たちの目的に適していますか? 助けや提案はありますか？

最近、Cassandra データベースを使い始めました。ローカル マシンで単一ノード クラスタをセットアップできました。

そして今、私は を使用して Cassandra Database にいくつかのサンプル データを書き始めることを考えていましたPelops client。

以下は、これまでに作成したキースペースと列ファミリーです-

以下は私がこれまでに持っているコードです。以前と同じように、いくつかの例外が発生しましたが、それを修正できました。今、別の例外が発生しています

このプログラムを実行しているときはいつでも、この例外が発生します-

そして、この例外は、この行を実行しようとするとすぐに発生します-

mutator.executeライン

上で述べたように、私は Cassandra Database と Pelops クライアントも初めてです。それを扱うのはこれが初めてです。段階的なプロセスでこの問題を解決できる人はいますか? ローカル ボックスで Cassandra 1.2.3 を実行しています。

Cassandra データベースにデータを挿入する方法などの段階的なガイダンスは、Cassandra の仕組みを理解するのに大いに役立ちます。

前もって感謝します。

Cassandra データベースにデータを挿入する必要があるプロジェクトに取り組んでいます。そのために私は を使用していPelops clientます。

を使用して Cassandra データベースに挿入するマルチスレッド コードがありますPelops client。そして、私はそのために使用ExecutorServiceしています。

私のプログラムでは、各スレッドは次のような範囲で動作します

以下は、Cassandraデータベースに挿入するために使用しているコードです-

以下は、CassandraTask class実装するものですRunnable interface

上記のプログラムを実行しているときはいつでも、例外を常に下回っています-

私がここでやっている何が間違っているのか、誰かが私を助けることができますか? ここで私が犯している小さな間違いがあると思いますか？ゆっくりとゆっくりと実行している場合、この例外は発生しません。遅いとは、コードにブレークポイントを設定することを意味します。どういうわけか非常に奇妙です。

Cassandra 1.2.3で作業しています

どんな助けでも大歓迎です。