問題タブ [cassandra-jdbc]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
cassandra - Cassandra にデータを挿入する際のエラー
Apache Kafka-storm-cassandra Integration を学習しています。Kafka スパウトを使用して Kafka クラスターから JSON 文字列を読み取っています。次に、JSON を解析するボルトに渡し、必要な値を 2 番目のボルトに出力して Cassandra DB に書き込みます。
しかし、これらのエラーが発生しています。
java.lang.RuntimeException: com.datastax.driver.core.exceptions.SyntaxError: 行 1:154 の不一致文字 '' 期待 '''
TableAlreadyExists エラー:
com.datastax.driver.core.exceptions.AlreadyExistsException: テーブル query.productcount は既に com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85) に存在します
私のメイントポロジ:
正規化ボルト:
CassandraWriter ボルト:
必要な変更を提案してください。
よろしくお願いします!!
java - Cassandra のソートされていない Map タイプ
Cassandra 2.1.7 でマップ タイプ列を使用しています。私の要件は、後で取得できるように、Cassandra に挿入する値の順序を保持する必要があるということです。そのために、その目的を果たす Java で LinkedHashMap を使用しました。
さて、デバッグ中に、Javaがキーと値のペアを処理するまで順序が保持されることがわかりましたが、「挿入」CQLコマンドを実行している間、Cassandraは私に尋ねずにマップキーを昇順で再配置します。これは好きではありません:-)
Cassandra でマップ タイプを定義するときに並べ替えオプションを提供する方法を探しましたが、Cassandra ではマップ タイプの柔軟性が制限されていたため、何も得られませんでした。
上記の期待に応えるための回避策を提案してください!
cassandra - datastax cassandra -com.datastax.shaded.netty.channel.ConnectTimeoutException での予期しない接続タイムアウト
アプリケーションの最初の起動時に Session オブジェクトで接続を取得しています。私たちのスケジューラーは、それを使用して Cassandra にデータを挿入し続けます。しかし、ある時点で、接続タイムアウトが発生し、その後、Cassandra およびアプリケーションとの再接続が正常に機能します。
スケジューラで頻繁にタイムアウト。(この投稿では. . .に IP を変更しました)
jdbc - RazorSQL - Cassandra DB に接続できません
RazorSQL を介して CassandraDB に接続しようとしています。私はRazorSQLを初めて使用します。
手順は次のとおりです。
- トップメニュー --> 接続 --> 接続プロファイルの追加 --> 表示されるポップメニューにすべての詳細を入力します (ドライバーの場所、ホスト、ポート番号など)。
RazorSQL の AutoDownload Driver オプションを試してみました。また、さまざまな Cassandra JDBC Drivers も試しました。
cassandra-jdbc-1.2.5、cassandra-jdbc-2.1.1、CassandraJdbcDriver.zip、DataStaxCassandraODBC32。
次のエラー メッセージが表示されます。
エラー: データベースへの接続中にエラーが発生しました:
JDBC URL: jdbc:cassandra://88.198.37.102:9042
org.apache.thrift.transport.TTransportException: 負のフレーム サイズ (-2113929216) を読み取ります!
これを使用して Cassandra DB に接続する方法を教えてください。よろしくお願いします。
r - Unable to Connect to Cassandra Database from R using JDBC
I am trying to connect R with Cassandra. Following is my code:
When I run above code in R, I get following error:
Any ideas how to solve this error? Thanks in advance!
cassandra - Cassandra UDT を Optional 型に変換する方法
User テーブルとそれに対応する POJO があります
UDT「アドレス」をオプションに変換したい。「cassandra-driver-mapping:3.0.0-rc1」と「cassandra-driver-extras:3.0.0-rc1」を使っているので、使えるコーデックはたくさんあります。
CodecRegistry に登録し、TypeCodec を OptionalCodec のコンストラクターに渡します。
しかし、TypeCodec は抽象クラスなので、開始できません。
OptionalCodec を開始する方法を知っている人はいますか?
ありがとう、@オリヴィエ・ミシャラ。あなたの解決策はOKです！
しかし、OptionalCodec を CodecRegistry に設定するのは少し混乱しています。最初にセッションを開始する必要があります。その後、セッションを MappingManager に渡し、正しい TypeCodec を取得してコーデックを登録します。
TypeCodec を取得するために最初にセッションを開始する必要があるのは少し奇妙です!?