Compute the number of records within each partition of a Spark DataFrame
Compute the number of records within each partition of a Spark DataFrame
sdf_partition_sizes(x)
x |
A |
## 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)
Please choose more modern alternatives, such as Google Chrome or Mozilla Firefox.