Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2181#discussion_r183261488
--- Diff:
integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/createTable/TestCreateTableUsingSparkCarbonFileFormat.scala
---
@@ -153,6 +153,34 @@ class TestCreateTableUsingSparkCarbonFileFormat
extends QueryTest with BeforeAnd
cleanTestData()
}
+ test("Running SQL directly and read carbondata files (sdk Writer Output)
using the SparkCarbonFileFormat ") {
+ buildTestData(false)
+ assert(new File(filePath).exists())
+ sql("DROP TABLE IF EXISTS sdkOutputTable")
+
+ //data source file format
+ if (sqlContext.sparkContext.version.startsWith("2.1")) {
+ //data source file format
+ sql(s"""CREATE TABLE sdkOutputTable USING carbonfile OPTIONS (PATH
'$filePath') """)
--- End diff --
Is `carbonfile` a reserved key word?
---