public interface PartitionCoalescer
|Modifier and Type||Method and Description|
Coalesce the partitions of the given RDD.
PartitionGroup coalesce(int maxPartitions, RDD<?> parent)
maxPartitions- the maximum number of partitions to have after coalescing
parent- the parent RDD whose partitions to coalesce
PartitionGroups, where each element is itself an array of
Partitions and represents a partition after coalescing is performed.