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 #1469: [WIP] Spark-2.2 Carbon Integration - Phase 1
Date Sun, 26 Nov 2017 07:44:26 GMT
Github user ravipesala commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1469#discussion_r153062388
  
    --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonAnalysisRules.scala
---
    @@ -201,8 +237,10 @@ case class CarbonIUDAnalysisRule(sparkSession: SparkSession) extends
Rule[Logica
       override def apply(logicalplan: LogicalPlan): LogicalPlan = {
     
         logicalplan transform {
    -      case UpdateTable(t, cols, sel, where) => processUpdateQuery(t, cols, sel, where)
    -      case DeleteRecords(statement, table) => processDeleteRecordsQuery(statement,
table)
    +      case UpdateTable(t, cols, sel, alias, where) => processUpdateQuery(t, cols,
sel, alias, where)
    +      case DeleteRecords(statement, alias, table) => processDeleteRecordsQuery(statement,
    +        alias,
    +        table)
    --- End diff --
    
    format it properly. like
    ```
    case DeleteRecords(statement, alias, table) =>
            processDeleteRecordsQuery(
              statement, 
              alias, 
              table)
    ```


---

Mime
View raw message