Class/Object

org.apache.spark

Partitioner

Related Docs: object Partitioner | package spark

Permalink

abstract class Partitioner extends Serializable

An object that defines how the elements in a key-value pair RDD are partitioned by key. Maps each key to a partition ID, from 0 to numPartitions - 1.

Note that, partitioner must be deterministic, i.e. it must return the same partition id given the same partition key.

Source
Partitioner.scala
Linear Supertypes
Serializable, Serializable, AnyRef, Any
Known Subclasses
HashPartitioner, RangePartitioner
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Partitioner
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Partitioner()

    Permalink

Abstract Value Members

  1. abstract def getPartition(key: Any): Int

    Permalink

  2. abstract def numPartitions: Int

    Permalink