aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--python/pyspark/sql/dataframe.py9
1 files changed, 0 insertions, 9 deletions
diff --git a/python/pyspark/sql/dataframe.py b/python/pyspark/sql/dataframe.py
index bbe15f5f90..5378c32a1a 100644
--- a/python/pyspark/sql/dataframe.py
+++ b/python/pyspark/sql/dataframe.py
@@ -364,15 +364,6 @@ class DataFrame(object):
return DataFrame(self._jdf.coalesce(numPartitions), self.sql_ctx)
@since(1.3)
- def repartition(self, numPartitions):
- """Returns a new :class:`DataFrame` that has exactly ``numPartitions`` partitions.
-
- >>> df.repartition(10).rdd.getNumPartitions()
- 10
- """
- return DataFrame(self._jdf.repartition(numPartitions), self.sql_ctx)
-
- @since(1.3)
def repartition(self, numPartitions, *cols):
"""
Returns a new :class:`DataFrame` partitioned by the given partitioning expressions. The