sdf_repartition

Repartition a Spark DataFrame

Description

Repartition a Spark DataFrame

Usage

sdf_repartition(x, partitions = NULL, partition_by = NULL)

Arguments

Argument Description
x A spark_connection, ml_pipeline, or a tbl_spark.
partitions number of partitions
partition_by vector of column names used for partitioning, only supported for Spark 2.0+