Github user wangyum commented on a diff in the pull request:
https://github.com/apache/spark/pull/21782#discussion_r202622330
--- Diff:
sql/catalyst/src/main/antlr4/org/apache/spark/sql/catalyst/parser/SqlBase.g4 ---
@@ -340,6 +340,7 @@ queryOrganization
: (ORDER BY order+=sortItem (',' order+=sortItem)*)?
(CLUSTER BY clusterBy+=expression (',' clusterBy+=expression)*)?
(DISTRIBUTE BY distributeBy+=expression (','
distributeBy+=expression)*)?
+ (RANGE PARTITION BY rangePartitionBy+=expression (','
rangePartitionBy+=expression)*)?
--- End diff --
`RANGE DISTRIBUTE BY` and `DISTRIBUTE BY` will conflict, so used `RANGE
PARTITION BY` here.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]