carbondata-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipesala <...@git.apache.org>
Subject [GitHub] carbondata pull request #1473: [WIP]Event listener added
Date Thu, 09 Nov 2017 09:36:30 GMT
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


---

Mime
View raw message