aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/sql/dataframe.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/pyspark/sql/dataframe.py')
-rw-r--r--python/pyspark/sql/dataframe.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/python/pyspark/sql/dataframe.py b/python/pyspark/sql/dataframe.py
index 5cfc348a69..7a69c4c70c 100644
--- a/python/pyspark/sql/dataframe.py
+++ b/python/pyspark/sql/dataframe.py
@@ -360,7 +360,7 @@ class DataFrame(object):
>>> df.repartition(10).rdd.getNumPartitions()
10
- >>> data = df.unionAll(df).repartition("age")
+ >>> data = df.union(df).repartition("age")
>>> data.show()
+---+-----+
|age| name|
@@ -919,7 +919,7 @@ class DataFrame(object):
This is equivalent to `UNION ALL` in SQL. To do a SQL-style set union
(that does deduplication of elements), use this function followed by a distinct.
"""
- return DataFrame(self._jdf.unionAll(other._jdf), self.sql_ctx)
+ return DataFrame(self._jdf.union(other._jdf), self.sql_ctx)
@since(1.3)
def unionAll(self, other):