spark 自定义partitioner_spark-shell 找不到partitioner

package inpv

import org.apache.spark.Partitioner

class PvPartitioner(numParts: Int) extends Partitioner {
    override def numPartitions: Int = numParts

    override def getPartition(key: Any): Int = {
        val code = (key.toString().hashCode % numPartitions)
        if (code < 0) {
            code + numPartitions
        } else {
            code
        }
    }

    override def equals(other: Any): Boolean = other match {
        case p: PvPartitioner =>
            p.numPartitions == numPartitions
        case _ =>
            false
    }

    override def hashCode: Int = numPartitions
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25