datastax-enterprise

5熱

1答えて

私は数千万の行のデータを持っています。スパークストリーミングを使用して、1週間または1日以内にこれらのすべてを分析することは可能ですか？データ量の点でストリーミングを開始するには限界がありますか？私はストリームがおそらくそれ以上処理できないので、上限と何かを私のデータベースに入れるべきか分からない。私はまた、データを分離するためにウィンドウ操作を使用する異なる時間ウィンドウ1,3,6時間などを持っ

5熱

2答えて

CQLバイナリプロトコルを有効にするYAMLException：ubuntuでDataStax 3.0のインストールでプロパティを見つけることができません

C＃クライアント（礼儀CassandraSharp）からVM内で実行されているUbuntuデスクトップにインストールされたDataStax 3.0エンタープライズに接続しようとしています。がドキュメントを1として、（「カサンドラは、（）1.2-RC2のように、デフォルトではCQLバイナリプロトコルを有効にしません。あなたは、カサンドラ・シャープを使用するためにcassandra.yamlでこの機

7熱

1答えて

Datastax - PreparedStatementはスレッドセーフですか？

com.datastax.driver.core.PreparedStatementインスタンスをアプリケーション内のシングルトンにする必要がありますか？もしそうなら、接続が失われたらどうなりますか？ PreparedStatementが無効になり、手動で「reprepare」する必要がありますか？ PreparedStatementの使い方の簡単な例（同じメソッドでprepare + exec

2熱

1答えて

私のSparkで完成したアプリケーションがまだ私のワーカーのディスクスペースを使用しているのはなぜですか？

My Datastax Sparkで完成したアプリケーションが私の作業者のディスクスペースを使用しています。したがって、私のスパークはディスクスペースが残っていないため実行できません。これは私のspark workerディレクトリです。これらの青い線の付いたアプリケーションの合計は92GBですが、完成したアプリケーションなのでもう存在しないはずです。問題がどこにあるのか分かりません。これは私の

1熱

1答えて

私は（EU-中央-1）AWSフランクフルト地域にDatastaxのOpsCenter（5.2.4）を使用して、ここでドキュメントを次の新しいカサンドラクラスタを作成したいDataStaxのOpsCenter

を使用して、フランクフルト地域に新しいカサンドラクラスタを作成します。http://docs.datastax.com/en/latest-opsc/opsc/online_help/opscCreateClusterCloud.html [新しいクラスタを作成]をクリックすると、プロビジョニングタイプとして[ローカル]オプションのみが使用できます。「雲」が欠落しています。私は比較するのアイル

1熱

1答えて

DSEのCassandraカウンタとSolrインデックスを組み合わせる最良の方法

DSE documentationによれば、DSE Searchはカウンタ列をサポートしていません。私は基本的なCFを（ckey、count）としています（countはカウンタです）。カウンターがあるので、「Solrのインデックスがカウンターではサポートされていません！」と create table change_count (ckey text, count counter) primar

5熱

2答えて

カサンドラ単一ノードでのコミットとリカバリ

私はカサンドラの初心者です - 私はカサンドラのコミットとクラッシュリカバリに関する情報を単一のノードで検索していました。そして、誰かが詳細を明らかにすることを望む。私はCassandraをテストしています。そのため、単一ノードで設定してください。私はdatastaxにstresstoolを使用して何百万もの行を挿入しています。停電やシステムの停止が発生した場合はどうなりますか？ Cassand

0熱

1答えて

ローカルのspark-cassandraコネクタがSparkクラスタを表示します

私はsparkとcassandraの新機能です。私は、データストアで提供されているspark-cassandra-connectorを使用して、新しい行をcassandraテーブルに追加しようとしている単純なjavaプログラムを試しています。私はラップトップコンピュータでdseを実行しています。 Javaを使用して、私はスパークを介してデータをcassandra DBに保存しようとしています。さ

5熱

1答えて

java.lang.UnsupportedOperationException： '空ではないCassandraテーブルへの書き込みは許可されていません

私は私のスパークストリーミングプログラムで処理されるストリーミングデータを受信し、各インターバルの出力が私の既存のカッサンドラテーブル。現在、私のスパークストリーミングプログラムは、私のcassandraテーブルに保存する必要があるデータフレームを生成します。私は現在直面してる問題は私がコマンド私は彼が=「APPEND」モードを通過したリンク http://rustyrazorblade.com