public class DefaultRepartitioner extends java.lang.Object implements Repartitioner
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MAX_PARTITIONS |
Constructor and Description |
---|
DefaultRepartitioner()
Create a DefaultRepartitioner with the default maximum number of partitions,
DEFAULT_MAX_PARTITIONS |
DefaultRepartitioner(int maxPartitions) |
Modifier and Type | Method and Description |
---|---|
<T> org.apache.spark.api.java.JavaRDD<T> |
repartition(org.apache.spark.api.java.JavaRDD<T> rdd,
int minObjectsPerPartition,
int numExecutors) |
java.lang.String |
toString() |
public static final int DEFAULT_MAX_PARTITIONS
public DefaultRepartitioner()
DEFAULT_MAX_PARTITIONS
public DefaultRepartitioner(int maxPartitions)
maxPartitions
- Maximum number of partitionspublic <T> org.apache.spark.api.java.JavaRDD<T> repartition(org.apache.spark.api.java.JavaRDD<T> rdd, int minObjectsPerPartition, int numExecutors)
repartition
in interface Repartitioner
public java.lang.String toString()
toString
in class java.lang.Object