Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1563#discussion_r153139798
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonSessionState.scala
---
@@ -189,8 +201,16 @@ class CarbonOptimizer(
extends SparkOptimizer(catalog, conf, experimentalMethods) {
override def execute(plan: LogicalPlan): LogicalPlan = {
- // In case scalar subquery add flag in relation to skip the decoder
plan in optimizer rule, And
- // optimize whole plan at once.
+ val transFormedPlan: LogicalPlan =
CarbonOptimizerUtil.transformForScalarSubQuery(plan)
+ super.execute(transFormedPlan)
+ }
+}
+
+object CarbonOptimizerUtil
+{
--- End diff --
move it previous line
---
