Repartition

def hashRepartition(spark: SparkSession, in0: DataFrame) -> DataFrame:
 return in0.repartition(5, col("customer_id"))

object hashRepartition {

 def apply(spark: SparkSession, in: DataFrame): DataFrame =
 in.repartition(5, col("customer_id"))

}

def randomRepartition(spark: SparkSession, in0: DataFrame) -> DataFrame:
 return in0.repartition(5)

object randomRepartition {

 def apply(spark: SparkSession, in: DataFrame): DataFrame =
 in.repartition(5)

}

def RepartitionByRange(spark: SparkSession, in0: DataFrame) -> DataFrame:
 return in0.repartitionByRange(5, col("customer_id").asc())

object RepartitionByRange {

 def apply(spark: SparkSession, in: DataFrame): DataFrame =
 in.repartitionByRange(5, col("customer_id").asc())

}

def Coalesce(spark: SparkSession, in0: DataFrame) -> DataFrame:
 return in0.coalesce(5)

object Coalesce {

 def apply(spark: SparkSession, in: DataFrame): DataFrame =
 in.coalesce(5)

}