Github user sounakr commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1595#discussion_r155430622
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonPreAggregateRules.scala
---
@@ -1223,5 +1224,63 @@ case class CarbonPreInsertionCasts(sparkSession:
SparkSession) extends Rule[Logi
}
}
+ /**
+ * Transform the logical plan with average(col1) aggregation type to
sum(col1) and count(col1).
+ *
+ * @param logicalPlan
+ * @return
+ */
+ private def transformAggregatePlan(logicalPlan: LogicalPlan):
LogicalPlan = {
--- End diff --
Removed. Not needed.
---
