aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/sql/column.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/pyspark/sql/column.py')
-rw-r--r--python/pyspark/sql/column.py32
1 files changed, 16 insertions, 16 deletions
diff --git a/python/pyspark/sql/column.py b/python/pyspark/sql/column.py
index 320451c52c..3866a49c0b 100644
--- a/python/pyspark/sql/column.py
+++ b/python/pyspark/sql/column.py
@@ -219,17 +219,17 @@ class Column(object):
>>> from pyspark.sql import Row
>>> df = sc.parallelize([Row(r=Row(a=1, b="b"))]).toDF()
>>> df.select(df.r.getField("b")).show()
- +----+
- |r[b]|
- +----+
- | b|
- +----+
+ +---+
+ |r.b|
+ +---+
+ | b|
+ +---+
>>> df.select(df.r.a).show()
- +----+
- |r[a]|
- +----+
- | 1|
- +----+
+ +---+
+ |r.a|
+ +---+
+ | 1|
+ +---+
"""
return self[name]
@@ -346,12 +346,12 @@ class Column(object):
expression is between the given columns.
>>> df.select(df.name, df.age.between(2, 4)).show()
- +-----+--------------------------+
- | name|((age >= 2) && (age <= 4))|
- +-----+--------------------------+
- |Alice| true|
- | Bob| false|
- +-----+--------------------------+
+ +-----+---------------------------+
+ | name|((age >= 2) AND (age <= 4))|
+ +-----+---------------------------+
+ |Alice| true|
+ | Bob| false|
+ +-----+---------------------------+
"""
return (self >= lowerBound) & (self <= upperBound)