Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1837#discussion_r163757962
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateListeners.scala
---
@@ -20,18 +20,141 @@ package
org.apache.spark.sql.execution.command.preaaggregate
import scala.collection.JavaConverters._
import scala.collection.mutable
-import org.apache.spark.sql.CarbonEnv
-import org.apache.spark.sql.SparkSession
+import org.apache.spark.sql.{SparkSession}
import org.apache.spark.sql.catalyst.TableIdentifier
import org.apache.spark.sql.execution.command.AlterTableModel
-import
org.apache.spark.sql.execution.command.management.CarbonAlterTableCompactionCommand
+import
org.apache.spark.sql.execution.command.management.{CarbonAlterTableCompactionCommand,
CarbonLoadDataCommand}
+import org.apache.spark.sql.parser.CarbonSpark2SqlParser
-import org.apache.carbondata.core.constants.CarbonCommonConstants
import
org.apache.carbondata.core.metadata.schema.table.AggregationDataMapSchema
import org.apache.carbondata.core.util.CarbonUtil
import org.apache.carbondata.events._
-import
org.apache.carbondata.processing.loading.events.LoadEvents.{LoadTablePreExecutionEvent,
LoadTablePreStatusUpdateEvent}
+import
org.apache.carbondata.processing.loading.events.LoadEvents.{LoadMetadataEvent,
LoadTablePreExecutionEvent, LoadTablePreStatusUpdateEvent}
+object CompactionProcessMetaListener extends OperationEventListener {
--- End diff --
Add the comment for usage
---
