Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1473#discussion_r149906040
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CleanFilesCommand.scala
---
@@ -46,12 +47,23 @@ case class CleanFilesCommand(
val relation = catalog
.lookupRelation(databaseNameOp,
tableName)(sparkSession).asInstanceOf[CarbonRelation]
val carbonTable = relation.tableMeta.carbonTable
+ val operationContext = new OperationContext
+ val cleanFilesPreEvent: CleanFilesPreEvent =
+ CleanFilesPreEvent(carbonTable,
+ sparkSession)
+ OperationListenerBus.getInstance.fireEvent(cleanFilesPreEvent,
operationContext)
--- End diff --
Add one more overload method
OperationListenerBus.getInstance.fireEvent(cleanFilesPreEvent) with no
operationContext
---
