Github user sounakr commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1469#discussion_r153094754
--- 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 --
Done
---
