Skip to content
Snippets Groups Projects
Commit f9d40a58 authored by Reynold Xin's avatar Reynold Xin
Browse files

Added a comment in JdbcRDD for example usage.

parent 404f9ff6
No related branches found
No related tags found
No related merge requests found
...@@ -11,11 +11,13 @@ private[spark] class JdbcPartition(idx: Int, val lower: Long, val upper: Long) e ...@@ -11,11 +11,13 @@ private[spark] class JdbcPartition(idx: Int, val lower: Long, val upper: Long) e
/** /**
* An RDD that executes an SQL query on a JDBC connection and reads results. * An RDD that executes an SQL query on a JDBC connection and reads results.
* For usage example, see test case JdbcRDDSuite.
*
* @param getConnection a function that returns an open Connection. * @param getConnection a function that returns an open Connection.
* The RDD takes care of closing the connection. * The RDD takes care of closing the connection.
* @param sql the text of the query. * @param sql the text of the query.
* The query must contain two ? placeholders for parameters used to partition the results. * The query must contain two ? placeholders for parameters used to partition the results.
* E.g. "select title, author from books where ? <= id and id <= ?" * E.g. "select title, author from books where ? <= id and id <= ?"
* @param lowerBound the minimum value of the first placeholder * @param lowerBound the minimum value of the first placeholder
* @param upperBound the maximum value of the second placeholder * @param upperBound the maximum value of the second placeholder
* The lower and upper bounds are inclusive. * The lower and upper bounds are inclusive.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment