hector

12熱

2答えて

カッサンドラ接続のヘルスチェック（ヘクター使用）？私のアプリケーションの運用監視のために

は、私は、SELECT 1一般的に使用される「SQL接続の検証」クエリに類似したものを探しています。ヘクター・ドライバを使用して、Cassandraのに、。私はCluster.getKnownPoolHosts（）と.getConnectionManager（）。getActivePools（）を見るようなことを試みました。しかし、彼らのステータスは、私が実際にクエリを使ってCassandra

3熱

1答えて

Hector Cassandraの列ファミリから、set rowIDのスーパー列のすべての値を取得する方法

スーパー列名に応じて異なる行ID値を取得したいとします。その目的のために、私はこのコード SuperColumnQuery<String, String, String, String> superColumnQuery = HFactory.createSuperColumnQuery(keyspaceOperator, se, se,se,se); superColu

0熱

1答えて

はカサンドラクラスタ

の作成に失敗しました。このコード行でクラスタを作成するために簡単です：実行したときに Cluster c = HFactory.getOrCreateCluster("MyTest Cluster","localhost:9160"); は、罰金コンパイル、私は次のエラーを得ました。任意の提案を感謝します。 Error: [java] INFO connection.CassandraHost

1熱

1答えて

スーパー列の家族の中で二次索引の任意の代替カサンドラ

私のデータモデルは、今私はstartDate_mobileNo、CALL_TYPEとendDateにをフィルタリングし、検索結果を作りたい、このよう #keyspace_name{ #columnfamily1 {startDate_mobileNo: // row key { Call_TYpe: // super column

2熱

1答えて

cassandraまたはhector用のastyanaxで非同期式の処理を行う方法はありますか？

私はすでに完全なhadoop分散ファイルシステムを設定するのではなく、それを使用しているので、いくつかのファイルをcassandraに流し込みたいと思います。 atyanaxまたはhectorに非同期型のputがあるので、完了時のコールバックを提供します.1000ミリ秒のネットワーク遅延を避けることができます.1000件のエントリを書きます（いくつかの行と列を分割してストリームします）。並行してい

0熱

1答えて

CassandraクライアントHectorからJavaドライバへの移行 - ConnectionListenerの置き換え

現在、CassandraクライアントをHectorからJavaドライバに移行していますが、既に切断されている同じDCへのクライアント要求が繰り返されるのを避けるためにConnectionListenerの置換を見つけることができません何らかの理由で。コード： if(getClusterConnectionListenerForDCId(dcId).isAllHostsInThisDCClus

9熱

1答えて

CassandraカウンターカラムファミリーのTTLはサポートされていますか？

CassandraはCounter列ファミリのTTLをサポートしていますか？具体的には、HectorをCassandraのクライアントとして使用しており、TTLをパラメータとして受け取っているAPIが見つかりませんでした。少なくともHFactory.createCounterColumnにはTTL引数がありません。

3熱

1答えて

Hectorを使用してCassandraに再接続するにはどうすればよいですか？

は、私は次のコードを持っている： StringSerializer ss = StringSerializer.get(); String cf = "TEST"; CassandraHostConfigurator conf = new CassandraHostConfigurator("localhost:9160"); conf.setCassandraThriftSocketTim

6熱

2答えて

Cassandra CompositeType

私はHectorとCassandraのチュートリアルで、DynamicCompositeTypeがあることを知りました。誰もが create column family Composite with comparator ='DynamicCompositeType (t=>TimeUUIDType,s=>UTF8Type)' and default_validation

7熱

2答えて

Cassandraの利用状況

"me.prettyprint.hector.api.exceptions.HUnavailableException ::：整合性レベルを処理するのに十分なレプリカが存在しない可能性があります。"私はRF = 1、読み取り整合性レベル= 1と6ノードリング/クラスタ内のノードの1つがダウンしているとき。この例外を除いて私のすべての読み込みに失敗しています。何か案が？理想的には、ダウンしているノー