Skip to content

[SPARK-19239][PySpark] Check parameters whether equals None when specify the column in jdbc API #16599

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
libratiger wants to merge 5 commits into from
Closed

[SPARK-19239][PySpark] Check parameters whether equals None when specify the column in jdbc API #16599

Changes from 1 commit
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
94c44ba
[SPARK-19239][PySparK] Check the lowerBound and upperBound whether eq…
Jan 16, 2017
43602b5
update the None equal comparison
Jan 17, 2017
f2dad9c
Update numPartitions check to keep API consistent
Jan 17, 2017
e9a1bca
Update the document for numPartition
Jan 17, 2017
d851382
Fix the python style
Jan 17, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Fix the python style
  • Loading branch information
DjvuLee committed Jan 17, 2017
commit d8513820d990d4235069a88249056b76bd35f60b
4 changes: 2 additions & 2 deletions python/pyspark/sql/readwriter.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -432,8 +432,8 @@ def jdbc(self, url, table, column=None, lowerBound=None, upperBound=None, numPar
if column is not None:
assert lowerBound is not None, "lowerBound can not be None when ``column`` is specified"
assert upperBound is not None, "upperBound can not be None when ``column`` is specified"
assert numPartitions is not None, "numPartitions can not be None " \
"when ``column`` is specified"
assert numPartitions is not None, \
"numPartitions can not be None when ``column`` is specified"
return self._df(self._jreader.jdbc(url, table, column, int(lowerBound), int(upperBound),
int(numPartitions), jprop))
if predicates is not None:
Expand Down