Github user manishgupta88 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1812#discussion_r184398845
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSpark2SqlParser.scala
---
@@ -124,11 +124,13 @@ class CarbonSpark2SqlParser extends
CarbonDDLSqlParser {
protected lazy val alterTable: Parser[LogicalPlan] =
- ALTER ~> TABLE ~> (ident <~ ".").? ~ ident ~ (COMPACT ~ stringLit) <~
opt(";") ^^ {
- case dbName ~ table ~ (compact ~ compactType) =>
+ ALTER ~> TABLE ~> (ident <~ ".").? ~ ident ~ (COMPACT ~ stringLit) ~
+ (WHERE ~> (SEGMENT ~ "." ~ ID) ~> IN ~> "(" ~> repsep(segmentId,
",") <~ ")").? <~
+ opt(";") ^^ {
+ case dbName ~ table ~ (compact ~ compactType) ~ segs =>
val altertablemodel =
AlterTableModel(convertDbNameToLowerCase(dbName), table, None,
compactType,
- Some(System.currentTimeMillis()), null)
+ Some(System.currentTimeMillis()), null, segs)
--- End diff --
Check for code alignment
---
