caican00 commented on a change in pull request #35764:
URL: https://github.com/apache/spark/pull/35764#discussion_r826616400
##########
File path:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRelation.scala
##########
@@ -168,6 +177,71 @@ private[sql] object JDBCRelation extends Logging {
partitions
}
+ /**
+ * get the min and max value by the column
+ * @param schema resolved schema of a JDBC table
+ * @param resolver function used to determine if two identifiers are equal
+ * @param timeZoneId timezone ID to be used if a partition column type is
date or timestamp
+ * @param jdbcOptions JDBC options that contains url
+ * @param filters filters in Where clause
+ * @return JDBCPartitioningInfo
+ */
+ def getPartitionBound(
+ schema: StructType,
Review comment:
thanks, updated it.
--
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]
