diff --git a/python/pyspark/sql/dataframe.py b/python/pyspark/sql/dataframe.py index 8c09bf23f3cc0..2538bd139bb3f 100644 --- a/python/pyspark/sql/dataframe.py +++ b/python/pyspark/sql/dataframe.py @@ -1297,8 +1297,7 @@ def between(self, lowerBound, upperBound): >>> df[df.col1.between(lowerBound, upperBound)].collect() [Row(col1=5, col2=6, col3=8)] """ - jc = (self >= lowerBound) & (self <= upperBound) - return Column(jc) + return (self >= lowerBound) & (self <= upperBound) def __repr__(self): return 'Column<%s>' % self._jc.toString().encode('utf8')