SPARKC-641 Use the more concise scala syntax CassandraConnectorConf(SparkConf) instead of CassandraConnectorConf.fromSparkConf(SparkConf) when instantiating CassandraConnector

yohannrub · yohannrub · commit 902f57a662ad · 2021-02-25T20:37:19.000+01:00
diff --git a/connector/src/main/scala/com/datastax/spark/connector/cql/CassandraConnector.scala b/connector/src/main/scala/com/datastax/spark/connector/cql/CassandraConnector.scala
@@ -220,7 +220,7 @@ object CassandraConnector extends Logging {
 
   /** Returns a CassandraConnector created from properties found in the [[org.apache.spark.SparkConf SparkConf]] object */
   def apply(conf: SparkConf): CassandraConnector = {
-    CassandraConnector(CassandraConnectorConf.fromSparkConf(conf))
+    CassandraConnector(CassandraConnectorConf(conf))
   }
 
   /** Returns a CassandraConnector with runtime Cluster Environment information. This can set remoteConnectionsPerExecutor

Original file line number	Diff line number	Diff line change
`@@ -220,7 +220,7 @@ object CassandraConnector extends Logging {`
`220`	`220`
`221`	`221`	`/** Returns a CassandraConnector created from properties found in the [[org.apache.spark.SparkConf SparkConf]] object */`
`222`	`222`	`def apply(conf: SparkConf): CassandraConnector = {`
`223`		`- CassandraConnector(CassandraConnectorConf.fromSparkConf(conf))`
	`223`	`+ CassandraConnector(CassandraConnectorConf(conf))`
`224`	`224`	`}`
`225`	`225`
`226`	`226`	`/** Returns a CassandraConnector with runtime Cluster Environment information. This can set remoteConnectionsPerExecutor`