Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r141343067
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSource.scala ---
@@ -217,22 +229,212 @@ class CarbonSource extends CreatableRelationProvider
with RelationProvider
* be put here. For example, user defined output committer can be
configured here
* by setting the output committer class in the conf of
spark.sql.sources.outputCommitterClass.
*/
- def prepareWrite(
+ override def prepareWrite(
+ sparkSession: SparkSession,
+ job: Job,
+ options: Map[String, String],
+ dataSchema: StructType): OutputWriterFactory = {
+
+ // Check if table with given path exists
+ validateTable(options.get("path").get)
--- End diff --
change `options.get("path").get` to `options("path")`
---
