org.apache.spark

Class RangePartitioner<K,V>

Object

org.apache.spark.Partitioner

org.apache.spark.RangePartitioner<K,V>

All Implemented Interfaces:

java.io.Serializable

public class RangePartitioner<K,V>
extends Partitioner

A Partitioner that partitions sortable records by range into roughly equal ranges. The ranges are determined by sampling the content of the RDD passed in.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RangePartitioner(int partitions, RDD<? extends scala.Product2<K,V>> rdd, boolean ascending, scala.math.Ordering<K> evidence$1, scala.reflect.ClassTag<K> evidence$2)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object other)
int	getPartition(Object key)
int	numPartitions()

Methods inherited from class org.apache.spark.Partitioner

defaultPartitioner

Methods inherited from class Object

getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RangePartitioner

public RangePartitioner(int partitions,
                RDD<? extends scala.Product2<K,V>> rdd,
                boolean ascending,
                scala.math.Ordering<K> evidence$1,
                scala.reflect.ClassTag<K> evidence$2)

Method Detail

numPartitions

public int numPartitions()

Specified by:

numPartitions in class Partitioner

getPartition

public int getPartition(Object key)

Specified by:

getPartition in class Partitioner

equals

public boolean equals(Object other)

Overrides:

equals in class Object