Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1469#discussion_r153064203
--- Diff: integration/spark2/src/main/spark2.1/CarbonSessionState.scala ---
@@ -207,3 +213,26 @@ class CarbonOptimizer(
super.execute(transFormedPlan)
}
}
+
+class CarbonSqlAstBuilder(conf: SQLConf, parser: CarbonSpark2SqlParser)
extends
+ SparkSqlAstBuilder(conf) {
+
+ val helper = new CarbonHelperqlAstBuilder(conf, parser)
+
+ override def visitCreateTable(ctx: CreateTableContext): LogicalPlan = {
+ val fileStorage = helper.getFileStorage(ctx.createFileFormat)
+
+ if (fileStorage.equalsIgnoreCase("'carbondata'") ||
+ fileStorage.equalsIgnoreCase("'org.apache.carbondata.format'")) {
+ helper
+ .createCarbontable(ctx.createTableHeader,
--- End diff --
move line up
---
