本文整理汇总了Scala中org.apache.spark.util.Utils类的典型用法代码示例。如果您正苦于以下问题:Scala Utils类的具体用法?Scala Utils怎么用?Scala Utils使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Utils类的2个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Scala代码示例。
示例1: HashAwarePartitioner
//设置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
}
}
开发者ID:lmd1993,项目名称:bigsiftParallel,代码行数:19,代码来源:HashAwarePartitioner.scala
示例2: reflect
//设置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)
}
}
}
开发者ID:nagyistge,项目名称:crossdata-spark2,代码行数:27,代码来源:Reflect.scala
注:本文中的org.apache.spark.util.Utils类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论