dilipbiswal commented on code in PR #55629:
URL: https://github.com/apache/spark/pull/55629#discussion_r3177318617
##########
sql/api/src/main/scala/org/apache/spark/sql/errors/QueryParsingErrors.scala:
##########
@@ -203,6 +203,31 @@ private[sql] object QueryParsingErrors extends
DataTypeErrorsBase {
ctx)
}
+ def nearestByJoinWithLateralUnsupportedError(ctx: ParserRuleContext):
Throwable = {
+ new ParseException(
+ errorClass = "UNSUPPORTED_FEATURE.LATERAL_JOIN_NEAREST_BY",
+ messageParameters = Map.empty,
+ ctx)
+ }
+
+ def unsupportedNearestByJoinTypeError(ctx: ParserRuleContext, joinType:
String): Throwable = {
+ new ParseException(
+ errorClass = "NEAREST_BY_JOIN.UNSUPPORTED_JOIN_TYPE",
+ messageParameters =
+ Map("joinType" -> toSQLStmt(joinType), "supported" -> "'INNER', 'LEFT
OUTER'"),
+ ctx)
Review Comment:
QueryParsingErrors lives in sql/api, which can't depend on sql/catalyst
(where NearestByJoinType is defined) I Now i have the constant that is passed
through as a param from AstBuilder rather than referenced directly here. Hope
it is okay ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
