diff options
| -rw-r--r-- | R/pkg/R/functions.R | 2 | ||||
| -rw-r--r-- | python/pyspark/sql/functions.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/R/pkg/R/functions.R b/R/pkg/R/functions.R index 4d94b4cd05..9a545f0647 100644 --- a/R/pkg/R/functions.R +++ b/R/pkg/R/functions.R @@ -1485,7 +1485,7 @@ setMethod("soundex", #' Return the partition ID as a column #' -#' Return the partition ID of the Spark task as a SparkDataFrame column. +#' Return the partition ID as a SparkDataFrame column. #' Note that this is nondeterministic because it depends on data partitioning and #' task scheduling. #' diff --git a/python/pyspark/sql/functions.py b/python/pyspark/sql/functions.py index 45e3c22bfc..245357a4ba 100644 --- a/python/pyspark/sql/functions.py +++ b/python/pyspark/sql/functions.py @@ -543,7 +543,7 @@ def shiftRightUnsigned(col, numBits): @since(1.6) def spark_partition_id(): - """A column for partition ID of the Spark task. + """A column for partition ID. Note that this is indeterministic because it depends on data partitioning and task scheduling. |