Hot questions for Cassandra

Top Java Programmings / Cassandra
Categories Question List
Using Cassandra in apache beam How to prevent decrease of Dataflow read parallelism from Cassandra
Exception writing ByteBuffer field into Cassandra
No repackaged dependencies when building Apache Beam Cassandra JAR
Using Cassandra in apache flink flink cluster params - how to set
Flink issues with getting data from cassandra to use as dataset
Using a cassandra database query as the source for a Flink program
The implementation of the AbstractCassandraTupleSink is not serializable
PoolingOptions and Cassandra - java
How to read from Cassandra using Apache Flink?
Flink cassandraOutputFormat tuple needs frozen value
RuntimeException when using Flink's MapFunction with Cassandra "Insert" but not with "Statement"
Using Cassandra in apache kafka Kafka one consumer one partition
Apache Spark - capturing Kafka data on streaming event to trigger workflow
Using Cassandra in apache spark dataset WrappedArray of WrapedArray to java array
Union of sets in spark querying cassandra
Using Cassandra in apache spark sql Inserting Analytic data from Spark to Postgres
CassandraSQLContext key not found
Columns not found in class error
Spark read() works but sql() throws Database not found
Execute Prepared and Batch Statement in SparkSession.SQL
Using Cassandra in apache storm Insert datetime into cassandra
Java Huge csv file processing and storing using Apache Spark/ Kafka/ Storm to Cassandra
InvalidRequestException(why:Unknown identifier
InvalidRequestException(why:line 1:184 mismatched character ')' expecting '-')
Using Cassandra in astyanax Astyanax not respecting configured socket timeout
How to insert value into Column Family using java/astyanax?
Which versions of Cassandra is compatible with Astyanax 3.10.x
Reading rows using AllRowsReader but starting from a specific row
Handling failing seed nodes in Astyanax Cassandra API
Using Cassandra in bigdata Operation Time Out Error in cqlsh console of cassandra
How to create pipeline of functions in Spark that have to be applied on a dataset?
Real time analytic using Apache Spark
cassandra row fetch gives junk characters
Using Cassandra in blob What are the pros or cons of storing json as text vs blob in cassandra?
Converting cassandra blob type to string
Storing data as a blob vs columns in cassandra
Retrieving List<blob> cassandra example
Using Cassandra in caching Apache Ignite - java.lang.ClassNotFoundException: Unknown pair
Apache Ignite Cassandra eviction
Ignite client node wants to connect to cassandra layer
Using Cassandra in cassandra cli Add columns dynamically in cassandra
Cassandra + Java Spring connection trouble
Cassandra UDT and JAVA
Production grade Cassandra client configuration for Java application
Set the log level programmatically using the Java Cassandra Client
Choosing Apache Cassandra client
Using Cassandra in centos Can't start Cassandra (Single-Node Cluster on CentOS7)
Cassandra gets stuck on Initializing IndexInfo
Cassandra 2.0 and later require Java 7u25 or later but i'm using 8u60
Using Cassandra in cluster computing Working of Cassandra-CQL ClusterBuilder's addContactPoints
nodetool status: "error: No nodes present in the cluster. Has this node finished starting up?"
Apache Cassandra 3.10 IllegalArgumentException - Invalid token for Murmur3Partitioner
Using Cassandra in connection Retry connection to Cassandra node upon startup
Cassandra Datastax connection pooling monitor/metrics
Cassandra sstableloader - Connection refused
How to connect my Java application to Cassandra running through docker?
Cassandra connections - Shared 'Cluster' instance or multiple?
Recover PreparedStatements from Connection Loss / Session Reconnect?
How to handle exceptions when connection to Cassandra fails?
cassandra.service exits after a few seconds and nodetool gives 'Connection refused' error
Cassandra-unit : java.io.IOException: Connection reset by peer
How to fix Failed to open native connection to Cassandra at {server ip}:9042
Cassandra won't start on OSX "Reason: Connection refused."
Cassandra terminates connection in the middle?
Spring Boot - How to execute a method when program loses connection to DB?
Cassandra java driver connection error
java.lang.AbstractMethodError in Java Spark and cassandra connection
MaxConnectionsPerHost vs MaxRequestsPerConnection Cassandra driver
Do i have to open a new DB connection for every write in Cassandra?
Cassandra Datastax and Java - best way to set up connection
Error NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:9042
Java connect to Cassandra using JDBC [SQLNonTransientConnectionException: Keyspace names must be composed of alphanumerics and underscores]
cassandra single node connection error
HostDistance concept in cassandra connection pooling
datastax driver connection = apache ignite and cassandra(you may want to increase the driver number of per-host connections)
How to give connection details for cassandra in properties file using datastax java driver
connection to cassandra instance which is running on localhost
Cassandra - com.datastax.driver.core.exceptions.DriverException: Timeout while trying to acquire available connection
Using Cassandra in connector Spark Connector error: WARN NettyUtil: Found Netty's native epoll transport, but not running on linux-based operating system. Using NIO instead
Apache Spark fails to process a large Cassandra column family
Spark Datastax Java API Select statements
Apache Spark taking 5 to 6 minutes for simple count of 1 billon rows from Cassandra
Spark Cassandra connector filtering with IN clause
RDD not serializable Cassandra/Spark connector java API
Which System tables does the spark cassandra connector use?
Write PairDStram to cassandra using Datastax Spark Cassandra Connector
How to save a DataFrame from Spark to Cassandra table by changing the schema and adding additional properties
Issues in reading data with spark cassandra-connector in Spark java API
Error in retrieving data from Cassandra using Apache Spark Connector in java
Querying Data in Cassandra via Spark in a Java Maven Project
Why don't we have a ReaderBuilder defined in Spark-Cassandra-Connector for reading data from cassandra DB
error when use filter(),map(),... in spark java api( org.apache.spark.SparkException )
How to save data from spark streaming to cassandra using java?
Error in using spark-cassandra-connector: java.lang.NoSuchMethodError
Unable to connect to one of the Cassandra nodes using Cassandra Datastax Java Driver
Cassandra : How updates are handled if it happens before commitlog is flushed to Memtable
Spark cassandra connector Java API with Spark 2.0
Could not initialize class com.datastax.spark.connector.types.TypeConverter$ while running job on apache spark 2.0.2 using cassandra connector
Save to cassandra in spark, parallelize method is not availble in java
How to know no of rows Inserted using Spark In cassandra
Dataframe is not saved into Cassandra
Spark and Cassandra: requirement failed: Columns not found in class com.datastax.spark.connector.japi.CassandraRow: [mycolumn...]
Spark using cassandra partitioning with Java API
com.datastax.spark.connector.writer.NullKeyColumnException: Invalid null value for key column year
How to get a JavaDStream of an Object in Spark Kafka Connector?
How to reduce/filter a Column in a Spark DataFrame (Java) based on the length of the Column?
Using Cassandra in cql3 How can we convert com.datastax.driver.core.LocalDate to java.util.Date?
How to get top 5 records in cassandra 2.2
Out of memory error in Cassandra when querying big rows containing a collection (set)
Range Scan in Cassandra-2.1.2 taking a lot of time
QueryBuilder for user defined type in cassandra driver 3.0 (Java)
DataStax accessor bean as bind param
cassandra-spring ingest command doesn't work
How would one model somthing updateable, say like a “status” of a thing in Cassandra CQL3 and be able to query on this status?
Using Cassandra in cqlsh Discrepancy between Cassandra trace and client-side latency
PicklingError when copying a very large cassandra table using cqlsh
Cassandra does not start cause of an AbstractMethodError with JDK to 8u161?
COPY can only be used in cqlsh, and so I can't use it as a CQL command in Java. Is there a similar way to import a CSV into a table?
Count Number of Users in Cassandra column family?
I can't open Cassandra because of insufficient disk space to write
Cassandra: How to query local Table from local node in Java?
CQLSH Protocol Error proceeding from apparent version conflicts
Cassandra read_request_timeout_in_ms set up for external(Client) request
Can we set user defined field length in Cassandra database
Using Cassandra in database Is the IN relation in Cassandra bad for queries?
Can't retrieve by UDT key from cassandra with datastax java driver
Save object in cassandra using spark and java
Accesing Cassandra Database which uses 'PasswordAuthenticator' in Java
saveAll() is too slow. Cassandra Database with Spring boot. why?
Cassandra - Does CQLSSTableWriter support writing to multiple column families concurrently in one JVM instance?
How to ensure that generated id does not exist in database
Questions on Cassandra Bootstrap
Cassandra DB: Storing XML-Files in Cassandra Database possible?
Special character search in Cassandra
How do I migrate data from one Cassandra database to another?
Daily updating a database with data from Cassandra
Using Cassandra in datastax enterprise How to get Cassandra version Programmatically
How to get exact cql from statement using java api from datastax
DSE: Unable to sstablellaoding data from 4.8.9 to 5.0.2
Paging Datastax java driver
Using Cassandra in docker NoClassDefFoundError for io.netty.buffer.PooledByteBufAllocator
Docker runs out of disk space even though containers are small
What is the limitation with one-node Cassandra cluster?
Connectivity issue between containers (I suppose...)
How do I connect my local java application to cassandra running in a container on a server
Using Cassandra in dropwizard Difference between Codahale metrics and Dropwizard metrics
Cassandra's Metrics Monitoring native API
Using MetricsServlet to fetch metrics in Cassandra
Using Cassandra in eclipse how to create a keyspace in cassandra?
java.sql.SQLNonTransientConnectionException:Keyspace names must be composed of alphanumerics and underscores (parsed: '')
Changing in Cassandra Source Is Not Reflecting Outside of Eclipse IDE
Using Cassandra in gremlin gremlin order by query with incr
how to create edge between new vertex and existing vertex using Java API in Titan Graph database
Getting NoFastSuchElementException, when I use valueMap() in gremlin query with java
Sorting in TitanDB with Gremlin
issues with concurrent update in titan graph database
Using Cassandra in hadoop Why the class CqlStorage is not there in latest versions of apache-cassandra-X.X.X.jar
Using CqlOutputFormat for INSERT statement
Spark and Cassandra Java Application Exception Provider org.apache.hadoop.fs.s3.S3FileSystem not found
Cassandra Hadoop reduce output a map column type java
The Apache Projects and Big Data World
Using Cassandra in hibernate OneToMany with @EmbeddedId and kundera
OneToMany relationship not working
hibernate-ogm - 'cassandra_experimental' is no valid datastore provider short name
Using Cassandra in ignite Apache Ignite and Cassandra - NoClassDefFoundError
Using Cassandra in janusgraph JanusGraph with Solr
Can not acquire write lock on EC2-based Cassandra backend
Janusgraph : Cassandra thrift timeout exception
Using Cassandra in jdbc Unsorted Map type in Cassandra
Setting up Cassandra Liquibase
Job in spring batch is getting executed multiple times and not stopping
ProtocolID for 'duration' in Cassandra wire protocol?
Cached loader got a known bad class error: Cassandra database and Apache OFBiz
Not able to run select query after setting TTL in cassandra
Spring Data Cassandra - Retrieve Rows Affected
Cassandra JDBC preparedstatment error
Using Cassandra in jmx Can we monitor Cassandra schema disagreement using JMX
Cassandra JMX java.rmi.server.ExportException: Port already in use: 7199
Error accessing Cassandra MBeans from Java
Monitoring Cassandra CPU usage with JMX/MBeans
Using Cassandra in json Using Datastax Java Driver to query a row as a JSON
Datastax cassandra QueryBuilder insertion error (java)
Get all Cassandra query result in JSON format Using Java API
Using Datastax Java Driver to return JSON
CassandraRepository with String returning value in query method
Error on attempt to recieve JSON data from Cassandra DB via Java + sparkSession
How to insert JSON into cassandra database using java API?
how to serialize a general object to Json and deserialize Json to the object in Java
HttpMessageNotWritableException because of org.codehaus.jackson.map.JsonMappingException while converting java.util.UnmodifiableRandomAccessList
How can I create the Table and insert the json data by using JAVA in CQL?
Using Cassandra in jvm How to set Cassandra (>2.0) JVM heap size of 8GB?
Cassandra - many small or fewer bigger nodes?
Cassandra - failure to start, with error "Insufficient disk space to write 572 bytes"
Using Cassandra in key value store JAVA - Cassandra Set Batch Size
Cassandra - Java driver: QueryBuilder, ask for multiple composite keys in a where clause
Unable to read data from Map of Primitive data type from Cassandra DB using Scala
Cassandra: Get equivalent Java Class for DataType
Using Cassandra in kundera Transactions in kundera-cassandra
Kundera cassandra - Transaction rollback and Entity update
Pagination in kundera-cassandra
kundera-cassandra set cql version on EntityManagerFactory when using spring
Error while retrieving data, Caused by: . org.apache.cassandra.serializers.MarshalException
Using Cassandra in lagom Lagom persistentEntityRegistry.register doesn't work
Running Lagom Service Locator / Kafka / Cassandra separately
Using Cassandra in list How to retrieve the column having datatype as "list" from the table of Cassandra?
java-cassnadra object Frozen annotation for address map<text, frozen<list<frozen<address>>>>,
Spring Cassandra store a List with custom object's
Custom column type in cassandra: List of arrays
Cast List<Rows> to List<long> in java
Using a Datastax Cassandra ResultSet with Java 8 Parallel Streams - Quickly
InvalidTypeException: Value 0 of type class java.util.ArrayList does not correspond to any CQL3 type
Cassandra - using PreparedStatement with ListenableFuture
How to match codec in cassandra for list<varchar> <-> java.util.List
How to read the UDTs from collection(for ex:list) of UDTs with cassandra-driver in java?
Error in getting data from list type using datastax
spring data cassandra saving only a single object in the list
cassandra-driver-core: pass list values to parameterized SimpleStatement
Cassandra-Java-driver : com.datastax.driver.core.exceptions.InvalidTypeException: Invalid type, column is a list but class java.lang.String provided
Cassandra SSTableLoader : failed to list files in <directory_path>
Receive results from Cassandra using linkedlist
How to fix 'Concurrent writes on cassandra lists issue when data in the lists is getting mixed'..?
Saving JavaList to Cassandra table using spark context
Java Spark flatMap seems to be losing items in ArrayList
Using Cassandra in logging java.lang.NoClassDefFoundError: org/apache/spark/Logging
Cassandra query logging through spring configuration
Datastax driver log level
Cassandra 2.1.3. How to extract CommitLog
Spring boot not logging CQL queries
Cassandra console log messages
Using Cassandra in lucene Lucene how to index in Database (Cassandra)
Using Cassandra in maven Cassandra Plugin in Intellij
Spring Boot 1.4: Spring Data Cassandra 1.4.2 is incompatible with Cassandra 3.0?
Importing a new cassandra related POM dependency in project resulting in run time errors
Spark-Cassandra Maven project with java source making scala-lib calls
Failed to bind properties under 'cluster' to com.datastax.driver.core.Cluster
Maven subdependency conflict at runtime with Twilio
Running Maven Project in Google Compute Engine [Debian 8] Build fails
Using Cassandra in mongodb How to export data from Cassandra to mongodb?
Exporting Data from cassandra to mongodb
Cassandra on Java stack vs Mongo Db on JavaScript stack
Using Cassandra in multithreading NoNodeAvailableException: No node was available to execute the query
how to use cassandra session for multiple threads?
Titan Cassandra Multithreaded Transactions Locking
Java two timers
Using Cassandra in nodetool Cassandra deploy cluster failure
Querying Cassandra for node statuses within Java
Using Cassandra in nosql Problems connecting to Cassandra pool from Spring application
Cassandra: Only EQ and IN relation are supported on the partition key (unless you use the token() function)
Batch insertion using object mapper in Cassandra
Cassandra With Java All host(s) tried for query failed
Cassandra CQL driver implementation
PagingState for Statement in CQL
Cassandra time stamp returns 0 rows
Cassandra: Missing column in query results
Cassandra: How to bind PreparedStatement to a map data
Multiple keyspace or table update for cassandra
Is Cassandra broken or have I made a huge mistake?
Using Cassandra in performance Cassandra cluster with bad insert performance and insert stability
Cassandra Read/Get Performance
Cassandra java query performance count(*) or all().size()
Low TTL with Leveled Compaction, should I reduce gc_grace_seconds to improve read performance without impacting delete replication?
Cassandra Bulk-Write performance with Java Driver is atrocious compared to MongoDB
Bad performance using spark against cassandra
Improve performance in Cassandra and java collections
Datastax Object Mapping API Performances
Cassandra 2.1 Cluster Showing Consistently High CPU Usage and Slow Responses
Does Cassandra 2.1 insert performance depends on affected columns?
Cassandra performance is different with respect to two application host
What is SparkSession.read() Dataset<Row> limit reading in Cassandra table? (Spark performance)
Titan Database: performance issue to iterate over thousands vertices in java code
Better way to write huge data in a row in cassandra java
Using Cassandra in persistence Best massive data persistent storage with TTL?
akka cassandra persistence with java example
Caused by: javax.persistence.PersistenceException: org.apache.cassandra.serializers.MarshalException: Unexpected extraneous bytes after map value
spring boot autowired object is getting set to null in ignite persistence cachestore factory class
Apache Ignite - Cassandra persistence issue
How configure Achiles work with entity methods properly?
Using Cassandra in php Can't increment Cassandra counter through Datastax-PHP library
Apply Batch keyword to select statements
Query about DSE search
Using Cassandra in prepared statement How to use prepared statement efficiently using datastax java driver in Cassandra?
How to bind IN-clause values in a CQL 3 prepared statement?
Max number of prepared statement on Cassandra
Thread-safety of Cassandra BoundStatement
Why is my Cassandra Prepared Statement Ingest of Data so slow?
Using Cassandra Prepared Statement using Cassandra Operations Spring Boot
How to bind values to bound statement in a generic way using datastax java driver?
Cassandra BoundStatement with Range Boundary Query
Using Cassandra in rest How to fetch offset id while consuming Kafka from Spark, save it in Cassandra and use it to restart Kafka?
What happens to the prepared statements of an application when cassandra is restarted?
How to pass values in java to Query cassnadra database
Cassandra, Jersey rest api increases Threads, Memory usage and Ports with each rest request
Query regarding Cassandra java BoundStatement with multiple attributes
Using Cassandra in resultset How should I check if resultset is empty or null using datastax cassandra driver for java
Get a BigInteger attribute from Cassandra ResultSet
Can I forget ResultSetFuture in Cassandra java driver without facing memory leak?
How to get nested map from Cassandra Result Set
cqlsh: how to skip first few rows in resultset
InvalidQueryException despite of correct query
ResultSet not returning results of CQL query in DataStax 4.2
DataStax API Cassandra execute method returns empty result set some times
Cassandra JDBC heap
Modify collection with ResultSetFuture
Using Cassandra in scala Spark-Submit: --packages vs --jars
Failing to connect to Cassandra through Phantom (NoHostAvailableException)
Datastax DSE Cassandra, Spark, Shark, Standalone Programm
Cassandra Bound Statements and Memory Leaking
Get the service IPs ports running under mesospehere dcos through program or command
Cassandra Command Line Tutorial
DataStax Cassandra cannot find Logback-Classic
How to compute summary statistic on Cassandra table with Spark DataFrame?
Using Cassandra in scylla Spark writing to Cassandra with varying TTL
Cassandra size limit per partition key
Using Cassandra in solr Unable to start solr aspect of DSE search
Create a property writer in SOLR
No response from Cassandra database using SOLR
Using Cassandra in spark streaming Exception in thread "main" org.apache.spark.SparkException: Only one SparkContext may be running in this JVM (see SPARK-2243)
Using Spark to save data to Cassandra
Cassandra class not found using spark streaming
Error while connecting to Cassandra using spark streaming
Spark Streaming - Java - Insert JSON from Kafka into Cassandra
Error while trying to connect cassandra database using spark streaming
Using Cassandra in spring data com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table schema_keyspaces
Create keyspace, table and generate tables dynamically using Spring Data Cassandra
How to insert java.util.Date values into Cassandra date type column using Spring Data Cassandra?
Spring Data Cassandra: How to query tables with compound keys?
Spring Data for Apache Cassandra converts java.time.LocalDateTime to UTC
How to map domain objects to CQL Tables using Spring Data Cassandra?
how do I check if a column exists in cassandra table in java?
Spring Data Cassandra and PreparedStatementCache
spring-cassandra UDT data insert
spring cassandra data Version 2.1.4 pagination
Max length of varchar / text in cassandra
How to update multiple tables in Spring CassandraRepository
Cassandra 3.5 compatablity with spring data 1.4
How can I use two Cassandra datasources with Spring Boot and Spring Data?
How can I examine the query string generated by Spring Data Cassandra Mapper
How to enable optimistic locking (versioning) in Cassandra using Spring-Data?
Is putting "is_deleted" state field as composite primary key on cassandra table for read is good practice?
unconfigured columnfamily error during insert
cassandraOperations.select ignore null values
Spring Data Cassandra and User Defined Types
How get Cassandra, Spring Boot to call field setters for an entity?
query on two columns in spring data cassandra
cassandra with Spring Data
Spring data cassandra: No property builder found on class User to bind constructor to
spring-data-cassandra CassandraBatchTemplate is not public
Issue while updating a record in 3 node cassandra cluster deployed using kubernetes
Cassandra counter datatype operation in spring repository
java.lang.String cannot be cast to main.java.example.Person
Implementation of hashCode in PrimaryKeyClass of spring-data-cassandra
exceptions that spring cassandra connect and session creation can throw?
Spring boot Cassandra read timeout
Spring boot Cassandra "Error creating bean with name 'session'"
How to stream Select results (not String query results) from CassandraOperations?
Cassandra Multi Tenant running scripts for DB/Table creation
I can not repository.save(mydata) I am looking for a pretty alternative to JOIN with Spring + Cassandra
Repository.findAll() in Spring Data for Apache Cassandra will output error "argument type mismatch"
How add asynchronously version SimpleCassandraRepository to spring data cassanbdra?
Set some trigger that removes rows older than few minutes from DB with Spring Boot
Using Cassandra in spring mvc Spring boot test "No qualifying bean of type available"
Spring not initializing beans
cassandra is storing 'z' (which is a wrong date format in my case )in the field
Using Cassandra in ssl Cassandra SSL with own Certificate Authority
SSL Encryption and Cassandra
ConnectionException when connecting to Cassandra with DataStax Java driver 1.0.5
Cassandra require_client_auth: true problem
cassandra java client using openssl
Using Cassandra in stratio Cassandra Lucene Index boolean syntax
Stratio cassandra-lucene-index plugin + BoundStatements
cassandra lucene - how to score a field higher
Using Cassandra in timestamp Dealing with Cassandra Timestamp
Timestamp in Cassandra
Unable to retrieve the data from datastax having timestamp field
How to insert TimeUUID and TimeStamp with Spark Cassandra connector?
Select in Cassandra with Java (datastax driver) by timestamp
Cassandra CQL does not return anything within a timestamp range
String to Cassandra Timestamp
Only date range scanning Cassandra CQL timestamp
How to convert java.sql.Timestamp to java.util.UUID?
Cassandra DB: Parsing an Instant from Cassandra's Timestamp in Json fails
Group spark Dataset by month from a timestamp in java
Codec not found for requested operation: [timestamp <-> java.util.UUID]
Cassandra: is Timestamp Entry in a Row callable with CQL?
Using Cassandra in timeuuid Java UUID compareTo not working correctly for Type1 UUIDs
Cassandra says "InvalidQueryException: Invalid version for TimeUUID type" when saving java.util.UUID
Cassandra: Selecting a Range of TimeUUIDs using the DataStax Java Driver
how to compress uuid and timeuuid?
get timebased uuid's upto 100s of nanoseconds
How to generate timeuuid in Jmeter beanshell processor?
Cannot insert timeuuid in Cassandra with Kundera
Using Cassandra in titan Titan With Cassandra as Backend : creating , storing and traversing the graph in java
TitanFactory.open() configration
how to configure Titan with multi Data Center deployment?
Titan BluePrints Rexster
Using Cassandra in triggers How can i execute delete operation using cassandra trigger?
cassandra 3.5 fails to load trigger class
How do we use rowUpdateBuilder in cassandra to write to an audit table containing a composite partition key?
Using Cassandra in unit testing Mocking ColumnDefinitions.Definition does return mock, but is behaves like null in the tested code
What is the unit testing paradigm in the Lagom framework?
ExceptionInInitializerError when cassandra unit tests runs on Jenkins but works locally
java.nio.file.FileSystemException : cannot access the file because it is being used by another process
Using Cassandra in uuid Java UUID or QueryBuilder uuid
Recreating a UUID from UUID.toString()
Integer to UUID conversion using padded 0's
Cannot persist to Cassandra with datanucleus on UUID