sdf_partition_sizes {sparklyr} | R Documentation |
Compute the number of records within each partition of a Spark DataFrame
Description
Compute the number of records within each partition of a Spark DataFrame
Usage
sdf_partition_sizes(x)
Arguments
x |
A |
Examples
## Not run:
library(sparklyr)
sc <- spark_connect(master = "spark://HOST:PORT")
example_sdf <- sdf_len(sc, 100L, repartition = 10L)
example_sdf %>%
sdf_partition_sizes() %>%
print()
## End(Not run)
[Package sparklyr version 1.8.6 Index]