Stack Overflow
Stack Overflow

Questions tagged [cassandra-jdbc]

A JDBC-compliant driver for Cassandra using CQL.

A JDBC-compliant driver for Cassandra using CQL.

50 questions
5
votes
2 answers

CREATE KEYSPACE IF NOT EXISTS in CQL

I am using below CQL syntax to create keyspace only if does not exists : CREATE KEYSPACE IF NOT EXISTS Test WITH replication = {'class':'SimpleStrategy', 'replication_factor':1}; but it is giving error : Exception in thread "main"…
Sanjiv
  • 1,795
  • 1
  • 29
  • 45
5
votes
1 answer

Thrift transport error occurred during processing of message

I am running cassandra 1.2.6 and Apache Spark 0.8.0. Here I am creating a RDD from Cassandra using Spark's newAPIHadoopRDD. When I run the job from spark appln I find that cassandra is logging the below error messages INFO 21:36:28,629 Listening for…
user2081818
  • 309
  • 2
  • 10
3
votes
2 answers

How to convert Cassandra UDT to Optional type

I have a User table and its corresponding POJO @Table public class User{ @Column(name = "id") private String id; // lots of fields @Column(name = "address") @Frozen private Optional
address; // getters and…
pandaforme
  • 153
  • 1
  • 9
3
votes
0 answers

Unable to Connect to Cassandra Database from R using JDBC

I am trying to connect R with Cassandra. Following is my code: library(RJDBC) #Load in the Cassandra-JDBC diver cassdrv <- JDBC("org.apache.cassandra.cql.jdbc.CassandraDriver", …
D. Venkata Naresh
  • 361
  • 2
  • 14
3
votes
2 answers

Unsorted Map type in Cassandra

I am using map type column in Cassandra 2.1.7. My requirement is that I have to preserve the order of values which I am inserting in Cassandra for later retrieval. For that I have used LinkedHashMap in Java which serves its purpose. Now, while…
tom
  • 719
  • 1
  • 11
  • 30
3
votes
1 answer

Error While Inserting Data into Cassandra

I am learning Apache Kafka-storm-cassandra Integration. I am reading JSON string from the Kafka cluster using Kafka Spout.Then passing it to bolt which parses the JSON and emits the needed value to the 2nd bolt which writes it to Cassandra DB. But I…
Ritesh Sinha
  • 820
  • 5
  • 22
  • 50
3
votes
1 answer

Cassandra batch size

I have 6 Cassandra nodes mainly used for writing (95%). What's the best approach to inserting data - individual inserts or batches? reason says batches are to be used, while keeping the "batch size" under 5kb to avoid node instability:…
Buffalo
  • 3,861
  • 8
  • 44
  • 69
3
votes
1 answer

InvalidRequestException Keyspace keyspace1 does not exist

I'm trying to connect to a Datastax Community Edition server 2.1.2 via JDBC but I keep getting the following error no matter what I try to do, even when issuing a very basic command like select * from…
isapir
  • 21,295
  • 13
  • 115
  • 116
2
votes
0 answers

Huge performance drop in cassandra-orm after million records

I'm using cassandra-orm plugin (cassandra-orm:0.4.5) for migrating clicks from Postgres DB to Cassandra. (I know I could use raw data import, but I want to make use of groupBy and explicit indexes maintained by the plugin). The migration procedure…
Tomas Bartalos
  • 1,256
  • 12
  • 29
2
votes
2 answers

Dynamic cassandra connection in storm bolt

I am running a Storm topology that reads data from Kafka broker and writes into Cassandra. One of my Cassandra bolts performs read and write operations. My keyspace always set dynamically. Now I want to get a connection to Cassandra using a…
kannadhasan
  • 339
  • 4
  • 17
2
votes
1 answer

How to import data from an xml file into cassandra directly

I am trying to insert a data from an xml file into Cassandra database directly. It has 1089090 records on it. I tried to read it pragmatically using java and got this exception after about 77000 records. java.sql.SqlNontrasientConnectionException:…
Hasif Subair
  • 436
  • 2
  • 13
  • 29
2
votes
1 answer

Configuring Cassandra as primary data store in WSO2 Identity Server

We have install WSO2 Identity Server 4.6.0 and would like to use Cassandra s the primary data store as well as user store manager. We have not found a clear path to get this implemented. Can anyone give us a clear path on how to configure this data…
mauroj
  • 31
  • 1
2
votes
1 answer

Cassandra timeseries datamodel

Let assume 10 devices(dev01,dev02,dev03..etc). It send data with some interval time,we collect those data,so our data schema is dev01 :int signalname :string signaltime :date/time[with YY-MM-DD HHMMSS.mm] Extradata :String I want to push…
kannadhasan
  • 339
  • 4
  • 17
2
votes
1 answer

Apache Cassandra JDBC connection error

I want to connect to cassandra 1.2.4 on a remote server through jdbc. package cassandraclient; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; import…
user2332500
  • 21
  • 1
  • 2
2
votes
1 answer

Errors when creating table using cassandra-jdbc-1.2.1 jar

I am having some difficulty creating a column family (table) in cassandra via the cassandra-jdbc driver. The cql command works correctly in cqlsh, but doesn't when using cassandra jdbc. I suspect this is something to do with the way I have defined…
Mahesh
  • 118
  • 1
  • 12
1
2 3 4