Skip to content

Commit 07dff84

Browse files
author
Davies Liu
committed
address comments, fix tests
1 parent f70c08e commit 07dff84

File tree

2 files changed

+8
-7
lines changed

2 files changed

+8
-7
lines changed

python/pyspark/sql/column.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -397,8 +397,8 @@ def over(self, window):
397397
return Column(jc)
398398

399399
def __nonzero__(self):
400-
raise ValueError("Can't convert column into bool: please use '&' for 'and', '|' for 'or', "
401-
"when using Column in a boolean expression.")
400+
raise ValueError("Cannot convert column into bool: please use '&' for 'and', '|' for 'or', "
401+
"'~'for 'not', when using Column in a boolean expression.")
402402
__bool__ = __nonzero__
403403

404404
def __repr__(self):

python/pyspark/sql/tests.py

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -165,11 +165,12 @@ def test_explode(self):
165165
self.assertEqual(result[0][1], "b")
166166

167167
def test_and_in_expression(self):
168-
self.assertEqual(4, self.df.filter(self.df.key <= 10 & self.df.value <= "2").count())
169-
self.assertRaises(ValueError, lambda: self.df.key <= 10 & self.df.value <= "2")
170-
self.assertEqual(2, self.df.filter(self.df.key <= 3 | self.df.value < "2").count())
171-
self.assertRaises(ValueError,
172-
lambda: self.df.filter(self.df.key <= 3 | self.df.value < "2").count())
168+
self.assertEqual(4, self.df.filter((self.df.key <= 10) & (self.df.value <= "2")).count())
169+
self.assertRaises(ValueError, lambda: (self.df.key <= 10) and (self.df.value <= "2"))
170+
self.assertEqual(14, self.df.filter((self.df.key <= 3) | (self.df.value < "2")).count())
171+
self.assertRaises(ValueError, lambda: self.df.key <= 3 or self.df.value < "2")
172+
self.assertEqual(99, self.df.filter(~(self.df.key == 1)).count())
173+
self.assertRaises(ValueError, lambda: not self.df.key == 1)
173174

174175
def test_udf_with_callable(self):
175176
d = [Row(number=i, squared=i**2) for i in range(10)]

0 commit comments

Comments
 (0)