| spark_partition_id {SparkR} | R Documentation |
Return the partition ID as a SparkDataFrame column. Note that this is nondeterministic because it depends on data partitioning and task scheduling.
spark_partition_id(x = "missing") ## S4 method for signature 'missing' spark_partition_id()
x |
empty. Should be used with no argument. |
This is equivalent to the SPARK_PARTITION_ID function in SQL.
spark_partition_id since 2.0.0
## Not run: select(df, spark_partition_id())