Github user TomaszGaweda commented on a diff in the pull request:
https://github.com/apache/spark/pull/21875#discussion_r205224686
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala
---
@@ -183,6 +183,9 @@ class JDBCOptions(
}
// An option to execute custom SQL before fetching data from the remote
DB
val sessionInitStatement = parameters.get(JDBC_SESSION_INIT_STATEMENT)
+
+ // An option to allow/disallow pushing down predicate into JDBC data
source
+ val pushDownPredicate = parameters.getOrElse(JDBC_PUSHDOWN_PREDICATE,
"true").toBoolean
--- End diff --
Super Nit: Shouldn't it be in plural, pushDownPredicates? There may be many
predicates
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
