[SPARK-7294] ADD BETWEEN

nemccarthy · May 2, 2015 · 7d62368 · 7d62368
1 parent baf839b
commit 7d62368
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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')