Github user ndwangsen commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2627#discussion_r210787370
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala ---
@@ -237,6 +237,21 @@ object CarbonEnv {
getCarbonTable(tableIdentifier.database,
tableIdentifier.table)(sparkSession)
}
+ /**
+ * This method returns corresponding CarbonTable, it will return None if
it's not a CarbonTable
+ */
+ def getCarbonTableOption(
--- End diff --
the getCarbonTable will throw a exception when get a non-carbon table
---
