問題タブ [hector]

ここでは、JSF 2.0 で Cassandra を使用する際の初心者向けの質問をいくつか紹介します。私は Web アプリケーションを開始していて、Cassandra をバックエンドとして使用したいと考えています。私のアプリはさまざまな地域に展開する必要があるため、同じデータをすべての地域で利用/複製する必要があります。

ベスト プラクティスに関する一般的な情報を知りたいです。

私は次の設定をしています：

• Maven2
• JSF 2.0 (現在はマネージド Bean と JPA を使用)
• グラスフィッシュ 3.2.1

おすすめのドライバーは？

• cassandra-jdbc ドライバーは datastax コミュニティ エディションで実装されていますか?
• または、最も高度なクライアントと思われるヘクターは?

Hectorの場合、JSFプロジェクト内でHectorを適切に使用するにはどうすればよいですか?

• Hector JPA 統合 (使用方法に関する情報が見つかりませんでした)?
• JPAなしでマネージドBeanから直接Hectorを使用していますか?

JSF 2.0 Web アプリケーションでドライバーを最適に使用するにはどうすればよいですか?

• マネージドビーンズ?
• シングルトンビーン？
• POJO?

(私はまだ Java EE にあまり詳しくありませんが、知識を構築する過程にあります)

接続をプールできるようにするには、クラス/Bean をどのように構成すればよいですか?

JSF/Java EE または JSF/POJO を使用して、ベスト プラクティスでセットアップがどのように使用されているかを確認するオープン ソースの例はありますか?

このようなプロジェクトをゼロから始める方法についてどう思いますか?

あなたが私に与えることができるすべてのヒントに感謝します。このプロジェクトを開始するのに十分な情報を見つけるのに 1 か月も苦労しています。

Hector API 関数を使用して Cassandra データベースにアクセスすると、例外が発生します。

me.prettyprint.hector.api.exceptions.HectorException: すべてのホスト プールがダウンとマークされました。再試行の負荷がクライアントに押し出されました。

私のサーバーには Cassandra データベースがバックグラウンドで実行されています。

私は例外を読み上げましたが、事実上文書化されていません。例外は接続の問題によるものと思われます。

どうすれば修正できますか？

cassandra データストアにアクセスするために hector HOM ライブラリを使用しています。このライブラリは Java で記述されており、コレクションを操作する際に何らかのリフレクションを使用します。

取得したい文字列のリストを含む Java モデルがあります。残念ながら、次の例外が発生します。

java.util.list オブジェクトを明示的に作成しようとしましたが、それでも同じ問題が発生します。モデルを作成して永続化するコードは次のとおりです。

モデルは問題なく持続し、cassandra で次のように表示できます。

問題は、オブジェクトを取得するときに、Hector が scala.collection タイプの処理方法を知らないように見えることです。

とにかくこれを回避する方法はありますか？

ありがとう。

列を持つ新しい SuperColumn を作成できます - 問題ありません。新しい列を作成できます - 問題ありません。しかし、既存の SuperColumn に新しい列を追加するにはどうすればよいでしょうか?

ここにリストされているものと非常によく似た問題があります。

単体テスト後に埋め込まれたcassandraをクリーンアップするには?

つまり、いくつかの統合テストを実行するために Cassandra を起動していますが、テスト クラスを実行すると、Cassandra によって生成された CommitLog ファイルを削除できないため、テスト クラスは失敗します。

そこにある回答の提案に従っています。これは、起動時にクリーンアップを実行することですが、その時点ではまだファイルを削除できません（コードをデバッグすると、その時点でファイルを削除することもできませんコマンドラインまたは GUI)。その結果、最初のテスト クラスは成功しましたが、その後のテスト クラスはすべて失敗しました。

詳細:

• 私の同僚は OSX で実行していて、この問題はありません。私はWindows 7を使用しています。
• 私は DOS と Cygwin で、また Eclipse でテストを実行してみました。いずれの場合も、ローカル ユーザーと管理者の両方として実行しました。
• Process Explorer を使用して、単一の Java プロセス以外に問題のファイルを処理しているものがないことを確認しました。
• ファイルを削除できない java.io.Win32FileSystem のネイティブ コールまでコードをデバッグしました。

Cassandra が CommitLog ファイルをシャットダウンまたは削除したことを確認するためにできることはありますか?

ありがとう！

私はカサンドラとヘクターの初心者です。

hectorを使用してCassandraの行のすべての列を取得したいと思います。Webで調べた後、いくつかのサンプルコードを取得しましたが、範囲または列名が必要です。

ここでは、この範囲の列を取得するsetRange（）メソッドで範囲を設定する必要があります。このメソッドで開始と終了を設定することもできますが、これにより特定の範囲の列も提供されます。範囲を設定していない場合は、列名を配列として指定する必要があります。

特定の行のすべての列を取得する方法はありますか？範囲や列の名前は設定せず、行のすべての列が必要です。私のアプリケーションでは列が事前定義されていないためです。

または、setRange（）メソッドで設定できるように、行の合計列数を取得する方法はありますか？

ありがとう。

ばかげた質問のように聞こえるかもしれませんが、実際に調べてみたところ、何も見つかりませんでした。閉じていない接続で誤ってデータベースを停止させないように、データベース接続を閉じることをお勧めします。ただし、接続を「閉じる」ための Hector API 関数はないようです。

Cassandra データベースが接続ではなくコマンドを受け取る可能性は十分にあります。

Cassandra データベースへのデータの挿入に関する多数の例に従いましたが、構成されていない列ファミリーに関する例外が発生するたびに発生します。

だから私はそれらを設定する方法を調べて見つけました

それは列ファミリーを構成しませんでした。

私が見つけたすべての例は、コンテキストのない断片であるため、何をインポートまたは設定すればよいかわかりません。さらに、一部の例では Hector API v2 と元の Hector API が混在しているように見えるため、それらを使用すると、「クラスが見つかりません」または「関数が見つかりません」というコンパイラ エラーが発生します。

Java クライアント 'HECTOR' を使用して、Cassandra に保存されているデータに対して単純な map-reduce ジョブを実行しようとしています。

この美しいブログ投稿で説明されている hadoop-wordcount の例は、既に正常に実行されています。Hadoop サポートの記事も読みました。

しかし、私がやりたいことは、実装に関しては少し異なります (wordcount の例では、mapreduce-site.xml に言及しているスクリプトを使用しています)。Cassandra データで「HECTOR」からローカルではなく、分散モードで map-reduce ジョブを実行する方法を誰かに理解してもらいたいです。

私のコードは、ローカル モードで map-reduce ジョブを正常に実行します。しかし、私が望むのは、それらを分散モードで実行し、結果を新しい ColumnFamily として cassandra キースペースに書き込むことです。

分散モードで実行するには、これをどこかに設定する必要があるかもしれませんが (上記のブログ投稿で述べたように)、どこにあるのか
$PATH_TO_HADOOP/conf/mapred-site.xml
わかりません。

これが私のコードです

}

ここに私が得る警告があります：

しかし、コードは map-reduce タスクを実行して正常に実行されますが、どこにデータを書き込むのかわかりません。

編集: 出力用に cassandra で columnFamily を作成していませんでした。したがって、それは書いていませんでした。したがって、残っている唯一の問題は、分散モードで実行する方法です。

ありがとうございました。

キー「1」の列「a」とキー「2」の列「b」、キー「3」の列「c」と「d」などの値をCassandraから1回のクエリで取得することは可能ですか?

はいの場合、ヘクターはそれをサポートしていますか?

(これらの列はすべて 1 つの列ファミリーにあり、同じ型です。)