public enum RepartitionStrategy extends java.lang.Enum<RepartitionStrategy>
RDD.repartition(int)
method. This results in each value being
randomly mapped to a new partition. This results in approximately equal partitions, though random sampling issues can
be problematic when the number of elements in a RDD is smallEnum Constant and Description |
---|
Balanced |
SparkDefault |
Modifier and Type | Method and Description |
---|---|
static RepartitionStrategy |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static RepartitionStrategy[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final RepartitionStrategy SparkDefault
public static final RepartitionStrategy Balanced
public static RepartitionStrategy[] values()
for (RepartitionStrategy c : RepartitionStrategy.values()) System.out.println(c);
public static RepartitionStrategy valueOf(java.lang.String name)
name
- the name of the enum constant to be returned.java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is null