Github user aniketadnaik commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1352#discussion_r138813057
--- Diff:
integration/spark2/src/test/scala/org/apache/spark/carbondata/streaming/CarbonSourceSchemaValidationTest.scala
---
@@ -0,0 +1,43 @@
+package org.apache.spark.carbondata.streaming
+
+import org.apache.hadoop.mapreduce.Job
+
+import org.apache.spark.sql.common.util.QueryTest
+import org.apache.spark.sql.{CarbonSource, SparkSession}
+import org.apache.spark.sql.streaming.CarbonStreamingOutputWriterFactory
+import org.apache.spark.sql.test.TestQueryExecutor
+import org.apache.spark.sql.types.{IntegerType, StringType, StructField,
StructType}
+
+import org.scalatest.{BeforeAndAfterAll, FunSuite}
+
+
+class CarbonSourceSchemaValidationTest extends QueryTest with
BeforeAndAfterAll {
+
+ override def beforeAll() {
+ sql("DROP TABLE IF EXISTS _carbon_stream_table_")
+ }
+
+ test("Testing validate schema method with correct values ") {
+
+ val spark = SparkSession.builder
+ .appName("StreamIngestSchemaValidation")
+ .master("local")
+ .getOrCreate()
+
+ val carbonSource = new CarbonSource
+ val job = new Job()
+ val storeLocation = TestQueryExecutor.storeLocation
+
+ println(s"Resource Path: $resourcesPath")
--- End diff --
yes.
---
