Skip to content

Commit 4bdd520

Browse files
committed
Update SqlParser.scala
1 parent 2d4bfbd commit 4bdd520

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,8 @@ class SqlParser extends StandardTokenParsers with PackratParsers {
140140
protected lazy val query: Parser[LogicalPlan] = (
141141
select * (
142142
UNION ~ ALL ^^^ { (q1: LogicalPlan, q2: LogicalPlan) => Union(q1, q2) } |
143-
UNION ~ opt(DISTINCT) ^^^ { (q1: LogicalPlan, q2: LogicalPlan) => Distinct(Union(q1, q2)) }
143+
UNION ~ opt(DISTINCT) ^^^ { (q1: LogicalPlan, q2: LogicalPlan) => Distinct(Union(q1, q2)) } |
144+
SUBTRACT ^^^ { (q1: LogicalPlan, q2: LogicalPlan) => Subtract(q1, q2) }
144145
)
145146
| insert | cache
146147
)

0 commit comments

Comments
 (0)