case class KeyUnpackPartitioner[K](p: Partitioner[K])(implicit evidence$1: ClassTag[K]) extends Partitioner[K] with Product with Serializable
A partitioner for keys K that detect the K even if it is inside a pair.
Given a partitioner for keys K, this implements a partitioner that
is able to use the given partitioner for K in case K is the key of the RDD
passed or the key of the RDD passed is made of a pair (K, _). In this case
the second member of the pair is discarded and the resulting partition
is calculated on the first member K directly.
- K
the type of the keys to be partitioned
- p
the actual partitioner used to calculate the partition for a key
K
- Note
In some cases it is need to repartition some status component from (Ko, Ki) tuple types to Ko. In this case partitioning on only the first component of key, in case this is a tuple could be beneficial. Please note also that currently the partitioner does not offer a real type safety respect to (Ko, Ki) tuple types, that it is why it derives from org.apache.spark.Partitioner instead of Partitioner.
- Alphabetic
- By Inheritance
- KeyUnpackPartitioner
- Product
- Equals
- Partitioner
- Partitioner
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new KeyUnpackPartitioner(p: Partitioner[K])(implicit arg0: ClassTag[K])
- p
the actual partitioner used to calculate the partition for a key
K
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getPartition(key: Any): Int
Implements the Spark org.apache.spark.Partitioner interface by forwarding the calls to getPartitionForKey.
Implements the Spark org.apache.spark.Partitioner interface by forwarding the calls to getPartitionForKey.
If the object passed is not of type
Kor can't be converted to it (e.g. java.lang.Integer to Int), a IllegalArgumentException is thrown. This should be considered a bug that should not happen because the processing library uses Partitioner of typeKonly for RDDs for which it is aware and sure to have keys of typeK.Basically, this function is a no-op call that forwards to getPartitionForKey, but the important point here is to have a type-safe Partitioner in the processing library.
- key
the key for which the partition must be calculated
- returns
the partition, identified by one scala.Int, in which the key should be located
- Definition Classes
- KeyUnpackPartitioner → Partitioner → Partitioner
- Note
This is called by Spark and should not be called by developer's code, as it may be unsafe.
- def getPartitionForKey(key: K): Int
Gets the partition for a given key of type
K.Gets the partition for a given key of type
K. This is the function that must be implemented by children partitioners.- key
the key for which the partition must be calculated
- returns
the partition, identified by one scala.Int, in which the key should be located
- Definition Classes
- KeyUnpackPartitioner → Partitioner
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def numPartitions: Int
- Definition Classes
- KeyUnpackPartitioner → Partitioner
- val p: Partitioner[K]
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)