Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1563#discussion_r153140542
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonSessionState.scala
---
@@ -212,6 +232,21 @@ class CarbonOptimizer(
PredicateSubquery(tPlan, p.children, p.nullAware, p.exprId)
}
}
- super.execute(transFormedPlan)
+ transFormedPlan
+ }
+}
+
+object SessionStateFactory {
+ def getSessionState(sparkSession: SparkSession, className: String):
HiveSessionState = {
--- End diff --
I think you can add this func in CarbonSession directly instead of creating
a new object
---
