spark

Partitioner

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.

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

Instance Constructors

  1. new Partitioner()

Abstract Value Members

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

  2. abstract def numPartitions: Int