Upgrade Spark to 2.0.0

christobill · Aug 8, 2016 · c963cba · c963cba
1 parent 8f5139d
commit c963cba
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/project/Versions.scala b/project/Versions.scala
@@ -57,7 +57,7 @@ object Versions {
   // and install in a local Maven repository. This is all done automatically, however it will work
   // only on Unix/OSX operating system. Windows users have to build and install Spark manually if the
   // desired version is not yet published into a public Maven repository.
-  val Spark           = "2.0.0-preview"
+  val Spark           = "2.0.0"
   val SparkJetty      = "8.1.14.v20131031"
   val JSR166e         = "1.1.0"
   val Airlift         = "0.6"

diff --git a/spark-cassandra-connector/src/main/scala/org/apache/spark/sql/cassandra/package.scala b/spark-cassandra-connector/src/main/scala/org/apache/spark/sql/cassandra/package.scala
@@ -39,9 +39,9 @@ package object cassandra {
     }
   }
 
-  implicit class DataFrameWriterWrapper(val dfWriter: DataFrameWriter) extends AnyVal {
+  implicit class DataFrameWriterWrapper[T](val dfWriter: DataFrameWriter[T]) extends AnyVal {
     /** Sets the format used to access Cassandra through Connector */
-    def cassandraFormat: DataFrameWriter = {
+    def cassandraFormat: DataFrameWriter[T] = {
       dfWriter.format("org.apache.spark.sql.cassandra")
     }
 
@@ -50,7 +50,7 @@ package object cassandra {
         table: String,
         keyspace: String,
         cluster: String = CassandraSourceRelation.defaultClusterName,
-        pushdownEnable: Boolean = true): DataFrameWriter = {
+        pushdownEnable: Boolean = true): DataFrameWriter[T] = {
 
       cassandraFormat.options(cassandraOptions(table, keyspace, cluster, pushdownEnable))
     }