問題タブ [datastax-java-driver]

クラスcom.datastax.driver.core.Sessionの単一のインスタンスを格納する単純なmvcアプリケーションがあります。このアプリケーションは、10 ノードのクラスターに接続されています。そのうち 6 つが Cassandra ノード、2 つの Hadoop ノード、および 2 つの Solar ノードです。ノードがクエリ対象ホストのリストに追加されると、ノードのすべての IP アドレスを確認できます。

すべて正常に動作しますが、使用せずにアプリケーションをしばらく実行したままにすると、次のようになります。

上記は、すべてのノードに対して繰り返されます。このすべての後、私は得ます：

その後、それは自分自身を修正するようです。

セッション オブジェクトを作成するには、次のコードを使用しました。

セッション オブジェクトは、クラスのメンバーとして格納されます。Cassandra ノードでは、ほぼ同じ期間のログに異常は見られません。クラスターとセッション オブジェクトの設定に欠けているものはありますか? さらに構成を追加する必要がありますか?

これに加えて、Windows マシンからクライアント アプリケーションを実行していたことを付け加えておきます。クライアント アプリケーションを Linux マシンに移動したとき、同じ問題は発生しませんでした。これは、問題がアプリケーションではなくネットワーク レベルにある可能性があることを示唆しています。

私は単純な列ファミリーを持っています:

cqlsh を使用してすべての行をクエリすると、期待される結果セットが返されます。

ただし、Java API を使用してこれを試すと、0 の結果が返されます。コードは非常に単純です。

私は遊んでみましたが、sub_idのみが主キーになるようにスキーマを変更すると、クエリはJava APIを介して機能します...

私は最新のAPIバージョンを使用しています:

誰もこれを見たことがありますか？私は何か間違ったことをしていますか、それともこれは API のバグですか?

datastax 2.0を使用する予定です。アプリケーションのドライバー。アプリケーションには次のシナリオがあります。2 つの異なるトランザクションがあり、1 つは消費量を増やすため、もう 1 つは消費量を減らすためのもので、同時に実行できます。
例:
マシン 1 からの Repair_Qty = 10 - 新しい修理を行っているので、新しい Repair_Qty は 10 + 1 であると仮定します。つまり、マシン 2 から 11 同時に、他の誰かが修理をキャンセルしています。Repair_Qty は 11-1 = 10 である必要があります。ただし、トランザクションが同時に発生し、トランザクション ロックがないため、新しい Repair Qty は 10-1 = 9 になり、これは誤りです。
datastax Java ドライバーで WRITE-READ_WRITE ロックをサポートするメカニズムがあるかどうかを知りたいです。

助けてください。

よろしく、
アルン

Cassandra でコレクションを処理できる Java API を探しています。列値のリスト/セット/マップなどのコレクションを読み取り/更新/挿入/削除するメソッドがあります。私は現在 Hector クライアントを使用していますが、上記の要件を実行できる方法が見つかりませんでした。API は混合型の列を処理できる必要があります (1 つの列の値を utf8 に、もう 1 つの列の値をコレクションにするなど)。例やチュートリアルも同様に高く評価されます。

CQL テーブル データの挿入、更新に DataStax Java ドライバーを使用しています。私の質問は、更新クエリが成功したことをどのように知るかですResultSet.次のコードは、テーブル内のレコードを更新しています.

Datastax Java Driver for Cassandra から QueryBuilder を使用して挿入ステートメントを作成する正しい方法は何ですか?

Cassandra 2.x と Java Driver 2.0.0-rc1 を使用しています

準備済みステートメントを使用して同じことを達成できることは知っていますが、QueryBuilder を使用することを楽しみにしています

cqlshで手動で試行すると成功するため、クエリ文字列が有効であることを確認できます

ドライバーによって報告されたエラーは、

ここの公式ドキュメントページで例を見つけることができませんでした