Github user gatorsmile commented on a diff in the pull request: https://github.com/apache/spark/pull/18266#discussion_r138475397 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala --- @@ -768,6 +769,35 @@ object JdbcUtils extends Logging { } /** + * Parses the user specified customSchema option value to DataFrame schema, + * and returns it if it's all columns are equals to default schema's. + */ + def parseUserSpecifiedColumnTypes( + schema: StructType, + columnTypes: String, + nameEquality: Resolver): StructType = { --- End diff -- ```Scala def getCustomSchema( tableSchema: StructType, customSchema: String, nameEquality: Resolver): StructType = { ```
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org