Github user ravipesala commented on a diff in the pull request: https://github.com/apache/carbondata/pull/1781#discussion_r163765562 --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateUtil.scala --- @@ -900,4 +904,75 @@ object PreAggregateUtil { aggDataMapSchema.getProperties.get("CHILD_SELECT QUERY").replace("&", "=")), CarbonCommonConstants.DEFAULT_CHARSET) } + + def commitDataMaps( --- End diff -- Add comment step by step of flow.
---