問題タブ [hector]

レプリケーション係数2のラックを認識しない配置戦略を使用する3台のマシンのCassandraクラスターがあります。

列ファミリーは次のように定義されます。

残念ながら、本番環境で数日間使用した後、カウンターの値に一貫性がありませんでした。

レプリカ1のクエリ：

レプリカ2のクエリ：

標準の読み取り修復メカニズムでは値が修復されないようであるため、nodetool修復を使用してアンチエントロピー修復を強制しようとしました。カウンター値には影響しませんでした。

データ検査では、カウンターの低い値が正しい値であることが示されたため、Cassandra（またはJavaからCassandraを呼び出すためにAPIとして使用したHector）のいずれかがいくつかの増分を再試行したと思われます。

データを修復し、状況が再発しないようにする方法はありますか？

Hector のバッチ ミューテーションと、Hadoop ジョブを使用してデータを Cassandra にロードすることの長所と短所を強調してくれる人はいますか?

Hector では、次のようなことができることを知っています。

Hadoop では、MR ジョブを使用してデータを Cassandra にロードできます。

それぞれを使用する理由と使用しない理由を探しています。ありがとう！

やあみんな私はHectorを介してCassandra0.8.2データベースにスキーマをロードしようとしています。

（特定のキースペースに）列ファミリーを追加し、その名前、コンパレーターのタイプ、キー検証クラス、およびデフォルトの検証クラスをHectorで指定したいと思います。

ここでドキュメントを確認しました： https ：//github.com/rantav/hector/blob/master/core/src/main/java/me/prettyprint/hector/api/factory/HFactory.java

これを行う関数については、デフォルトの検証クラスを指定するために（Cassandra CLIを介して）列ファミリーを既に作成しておく必要があるようです。CLIを介して列ファミリーを作成する場合は、キー検証クラスを指定します。私はこの仮定で正しいですか？メソッドがありませんか？Hectorを介してCassandra列ファミリーのデフォルトの検証クラスとキー検証クラスを変更することは可能ですか？

エラーを取り除きたいので、現在使用しているキースペースのすべての列ファミリーを取得しようとしています。

InvalidRequestException(why:[column family] already exists in keyspace)

私のロジックは、現在のキースペースにあるすべての列ファミリーを取得し、返されたリストに特定の列ファミリーが表示されるかどうかを確認することです。だから、私は試してみます：

KeyspaceDefinition keyspaceDef = HFactory.createKeyspaceDefinition("test");

..。

List<ColumnFamilyDefinition> lsCf = keyspaceDef.getCfDefs();

の作成に問題があるようです

List<ColumnFamilyDefinition> lsCf = keyspaceDef.getCfDefs();

私がやったSystem.out.println(keyspaceDef.getCfDefs())とそれは戻った

[]

空のリスト-これは私が期待したものです。私が理解できないのは、なぜList<ColumnFamilyDefinition> lsCf = keyspaceDef.getCfDefs();間違っているのかということです。Eclipseは、この行の「リスト」部分に同意しません。それ以外は、彼のコードは正しいようです。誰かがこの線が間違っている理由や私のアプローチが間違っているかどうかを理解するのを手伝ってもらえますか？

完全なコードスニペットは次のとおりです。

エラー：

この単純なアプリは、ヘッダーを含むコンマ delim ファイルを受け取り、Cassandra に挿入します。これは小さなファイルで機能しますが、メモリ不足の例外によってファイルが強制終了されるまで、メモリは増加します。

私は何が欠けていますか？

まず、これを読みました。

Cassandra を再起動できません。クライアントとして Hector を使用して Cassandra 0.8.2 のインスタンスに接続し、スキーマをロードしています。Hector を通じて、2 つの異なるクラスを使用して 2 つの異なる列ファミリー (Articles と TagsArticlesCF) を作成しています。

メイン クラスを使用して、次のように「Articles」および「TagsArticlesCF」という名前の列ファミリーを作成します。

これは、私の列ファミリーがどのように見えるか/どのように作成されるかの例です:

ロードされたデータに対して実行する予定のクエリをサポートする完全なスキーマを Cassandra に追加しようとしています。main メソッドを数回実行して、新しい列ファミリーをデータベースにロードしました。メイン メソッドを数回実行し、いくつかの調整を行った後 (列ファミリーが既に KeyspaceDefinition にあるかどうかを確認)、Cassandra の実行中のインスタンスがダウンしました。

Hector/java を使用していくつかのことに興味があります。

1. (異なるクエリをサポートするために) 異なる列を持つ 10 ほどの列ファミリを用意する予定です。列ファミリーごとにクラスを持つようにクラスを整理するのがベスト プラクティスですか?

2. KeyspaceDefinition と Keyspace の違いは何ですか? なぜ区別がつくのでしょうか？

Cassandra の新しいインスタンスを取得しようとしましたが、ここに遭遇しました。何が起こっているのかをよりよく理解しようとしているので、コメントやこれらのタイプのエラーを回避するための助けをいただければ幸いです。

... (もっと同じ)...

... (もっと同じ) ...

ありがとう！

何が間違っている可能性がありますか？

これのサンプルはどこにありますか?

私のコードのほとんどは、ColumnFamilyTemplate を使用してデータ レコードに対して CRUD を実行します。以下を参照してください。複合キーを定義したら、引き続き ColumnFamilyTemplate を使用して、複合キーを持つデータにアクセスできますか?

Q. hector (cassandra クライアント) を使用しており、UTF8 型の値を列に格納しています。クライアント側では、hector の StringSerializer を使用して値をシリアライズ/デシリアライズしています。通常の文字列 (英数字のみ) では正常に動作しますが、英数字以外の文字 ( —> 、 ; / など) がある場合はシリアル化されますが、逆シリアル化できません。他の誰かがこの問題を見たことがありますか?