Scala中方法内的匿名函数
Posted
技术标签:
【中文标题】Scala中方法内的匿名函数【英文标题】:Anonymous function inside a method in Scala 【发布时间】:2017-11-08 02:45:54 【问题描述】:我正在查看其中一个示例代码(如下所示)。我注意到这个方法中定义的看起来像一个匿名函数(下面的行//sn-p 中的这个注释是什么)。这到底是什么以及如何调用它?
def initHasher(requestFilePath: String) =
import spark.implicits._
val hashes = spark.read.option("delimiter", ",").option("header", "true").csv(requestFilePath)
.select($"Hash", $"Count").rdd
.map(r => (r.getString(0), r.getString(1))).collectAsMap()
val broadcastedHashes = spark.sparkContext.broadcast(hashes)
// What is this?
(str: String) =>
if (str != null && str.length > 0)
val hash = sha256hash(str)
broadcastedHashes.value.get(hash) match
case None => hash
case Some(count) => sha256hash(str + ":" + count)
else
null
【问题讨论】:
【参考方案1】:initHasher
初始化一个散列器并将其作为函数返回(您所看到的匿名函数)。它会这样使用:
// initialize your hasher here
val hasher = initHasher(requestFilePath)
// now you can use the hasher
val hash = hasher("my string")
【讨论】:
以上是关于Scala中方法内的匿名函数的主要内容,如果未能解决你的问题,请参考以下文章