Я пытаюсь понять внутренности Spark, а также плохо знаком с Scala.Я хотел бы спросить значение (index, res) => results(index) = res
в этом утверждении в SparkContext.scala:
runJob[T, U](rdd, func, partitions, (index, res) => results(index) = res)
source: SparkContext.scala
Две вещи, которые смешиваютme - это использование =>
и =
в одном выражении и группировка / приоритет (следует ли интерпретировать сначала =>
или сначала =
, а затем =>
?).
Использование =>
не соответствует ни одному из употреблений =>
, которые я читаю онлайн, и неясно, что делает = res
.
Спасибо!