Github user Indhumathi27 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2225#discussion_r185501934
--- Diff:
integration/spark-common-test/src/test/scala/org/apache/carbondata/sql/commands/UsingCarbondataSuite.scala
---
@@ -69,4 +73,44 @@ class UsingCarbondataSuite extends QueryTest with
BeforeAndAfterEach {
res3.foreach(row => assert(row.getString(1).trim.toLong > 0))
}
+ test("CARBONDATA-2396 Support Create Table As Select with 'using
carbondata'") {
+ sql("CREATE TABLE src_carbondata3(key INT, value STRING) USING
carbondata")
+ sql("INSERT INTO src_carbondata3 VALUES(1,'source')")
+ checkAnswer(sql("SELECT * FROM src_carbondata3"), Row(1, "source"))
+ sql("CREATE TABLE src_carbondata4 USING carbondata as select * from
src_carbondata3")
+ checkAnswer(sql("SELECT * FROM src_carbondata4"), Row(1, "source"))
+ }
+
+ test("CARBONDATA-2396 Support Create Table As Select [IF NOT EXISTS]
with 'using carbondata'") {
+ sql("DROP TABLE IF EXISTS src_carbondata5")
+ sql("DROP TABLE IF EXISTS src_carbondata6")
+ sql("CREATE TABLE src_carbondata5(key INT, value STRING) USING
carbondata")
+ sql("INSERT INTO src_carbondata5 VALUES(1,'source')")
+ checkAnswer(sql("SELECT * FROM src_carbondata5"), Row(1, "source"))
+ sql(
+ "CREATE TABLE IF NOT EXISTS src_carbondata6 USING carbondata as
select * from " +
+ "src_carbondata5")
+ checkAnswer(sql("SELECT * FROM src_carbondata6"), Row(1, "source"))
+ sql("DROP TABLE IF EXISTS src_carbondata5")
+ sql("DROP TABLE IF EXISTS src_carbondata6")
+ }
+
+ test(
+ "CARBONDATA-2396 Support Create Table As Select with 'using
carbondata' with Table properties")
--- End diff --
@xubo245 "USING org.apache.spark.sql.CarbonSource" has been only changed to
"USING carbondata"
---
