|Community||Chat with us at Datastax and Cassandra Q&A|
|Scala Docs||Most Recent Release (2.5.1): Spark-Cassandra-Connector, Spark-Cassandra-Connector-Driver|
|Latest Production Release||2.5.1|
|Latest Preview Release||3.0.0-beta|
Lightning-fast cluster computing with Apache Spark™ and Apache Cassandra®.
This library lets you expose Cassandra tables as Spark RDDs and Datasets/DataFrames, write Spark RDDs and Datasets/DataFrames to Cassandra tables, and execute arbitrary CQL queries in your Spark applications.
joinWithCassandraTablecall for RDDs, and optimizes join with data in Cassandra when using Datasets/DataFrames
The connector project has several branches, each of which map into different supported versions of Spark and Cassandra. For previous releases the branch is named "bX.Y" where X.Y is the major+minor version; for example the "b1.6" branch corresponds to the 1.6 release. The "master" branch will normally contain development for the next connector release in progress.
|Connector||Spark||Cassandra||Cassandra Java Driver||Minimum Java Version||Supported Scala Versions|
|3.0||3.0||2.1.5*, 2.2, 3.x, 4.0||4.7||8||2.12|
|2.5||2.4||2.1.5*, 2.2, 3.x, 4.0||4.7||8||2.11, 2.12|
|2.4.2||2.4||2.1.5*, 2.2, 3.x||3.0||8||2.11, 2.12|
|2.4||2.4||2.1.5*, 2.2, 3.x||3.0||8||2.11|
|2.3||2.3||2.1.5*, 2.2, 3.x||3.0||8||2.11|
|2.0||2.0, 2.1, 2.2||2.1.5*, 2.2, 3.x||3.0||8||2.10, 2.11|
|1.6||1.6||2.1.5*, 2.2, 3.0||3.0||7||2.10, 2.11|
|1.5||1.5, 1.6||2.1.5*, 2.2, 3.0||3.0||7||2.10, 2.11|
|1.2||1.2||2.1, 2.0||2.1||7||2.10, 2.11|
|1.1||1.1, 1.0||2.1, 2.0||2.1||7||2.10, 2.11|
|1.0||1.0, 0.9||2.0||2.0||7||2.10, 2.11|
*Compatible with 2.1.X where X >= 5
API documentation for the Scala and Java interfaces are available online:
This project is available on Spark Packages; this is the easiest way to start using the connector: https://spark-packages.org/package/datastax/spark-cassandra-connector
This project has also been published to the Maven Central Repository. For SBT to download the connector binaries, sources and javadoc, put this in your project SBT config:
libraryDependencies += "com.datastax.spark" %% "spark-cassandra-connector" % "2.5.1"
DataStax Academy provides free online training for Apache Cassandra and DataStax Enterprise. In DS320: Analytics with Spark, you will learn how to effectively and efficiently solve analytical problems with Apache Spark, Apache Cassandra, and DataStax Enterprise. You will learn about Spark API, Spark-Cassandra Connector, Spark SQL, Spark Streaming, and crucial performance optimization techniques.
New issues may be reported using JIRA. Please include all relevant details including versions of Spark, Spark Cassandra Connector, Cassandra and/or DSE. A minimal reproducible case with sample code is ideal.
Questions and requests for help may be submitted to the user mailing list.
The DataStax Community provides a free question and answer website for any and all questions relating to any DataStax Related technology. Including the Spark Cassandra Connector. Both DataStax engineers and community members frequent this board and answer questions.
To protect the community, all contributors are required to sign the DataStax Spark Cassandra Connector Contribution License Agreement. The process is completely electronic and should only take a few minutes.
To develop this project, we recommend using IntelliJ IDEA. Make sure you have installed and enabled the Scala Plugin. Open the project with IntelliJ IDEA and it will automatically create the project structure from the provided SBT configuration.
Checklist for contributing changes to the project:
To run unit and integration tests:
./sbt/sbt test ./sbt/sbt it:test
By default, integration tests start up a separate, single Cassandra instance and run Spark in local mode. It is possible to run integration tests with your own Cassandra and/or Spark cluster. First, prepare a jar with testing code:
Then copy the generated test jar to your Spark nodes and run:
export IT_TEST_CASSANDRA_HOST=<IP of one of the Cassandra nodes> export IT_TEST_SPARK_MASTER=<Spark Master URL> ./sbt/sbt it:test
To generate the Reference Document use
./sbt/sbt spark-cassandra-connector-unshaded/run (outputLocation)
outputLocation defaults to doc/reference.md
Copyright 2014-2017, DataStax, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
© 2020 Anant Corporation, All Rights Reserved. All logos, trademarks and registered trademarks are the property of their respective owners.