//设置package包名称以及导入依赖的类
package org.apache.spark.lineage

import org.apache.spark.Partitioner
import org.apache.spark.util.Utils

class HashAwarePartitioner(partitions: Int) extends Partitioner {

  def numPartitions = partitions

  def getPartition(key: Any): Int = Utils.nonNegativeMod(key.asInstanceOf[Int], numPartitions)

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

//设置package包名称以及导入依赖的类
package org.apache.spark.sql.crossdata.utils

import org.apache.spark.util.Utils

import scala.reflect.ClassTag
import scala.util.control.NonFatal


  def reflect[T, Arg1 <: AnyRef, Arg2 <: AnyRef](
                                                  className: String,
                                                  ctorArg1: Arg1,
                                                  ctorArg2: Arg2)(
                                                  implicit ctorArgTag1: ClassTag[Arg1],
                                                  ctorArgTag2: ClassTag[Arg2]): T = {
    try {
      val clazz = Utils.classForName(className)
      val ctor = clazz.getDeclaredConstructor(ctorArgTag1.runtimeClass, ctorArgTag2.runtimeClass)
      val args = Array[AnyRef](ctorArg1, ctorArg2)
      ctor.newInstance(args: _*).asInstanceOf[T]
    } catch {
      case NonFatal(e) =>
        throw new IllegalArgumentException(s"Error while instantiating '$className':", e)
    }
  }

}