scala - 合法代码在 Scalding 中无法编译

Question

我正在 Scalding 中编写 MapReduce 作业，并且在编译对我来说完全合法的代码时遇到了困难。

val persistenceBins = List[Int](1000 * 60 * 60, 2 * 1000 * 60 * 60, 4 * 1000 * 60 * 60)
val persistenceValues = persistenceBins.map(bin: Int => (bin, getPersistenceValues(connections, bin)) )

连接是 RichPipe。getPersistenceValues 定义在与上述代码相同的类中，如下所示：

def getPersistenceValues(connections: RichPipe, binSize: Int): RichPipe = { ... }

我不断收到以下错误：

Error:(45, 87) ')' expected but '(' found.
val persistenceValues = persistenceBins.map(bin: Int => (bin, getPersistenceValues(connections, bin)) )
                                                                                  ^
Error:(45, 107) ';' expected but ')' found.
val persistenceValues = persistenceBins.map(bin: Int => (bin, getPersistenceValues(connections, bin)) )
                                                                                                      ^

我不知道发生了什么事。这些错误对我来说毫无意义。我究竟做错了什么？

Answer 1

在您的情况下，您不能跳过括号。此代码应该可以帮助您了解问题所在。

scala> val persistenceBins = List[Int](1000 * 60 * 60, 2 * 1000 * 60 * 60, 4 * 1000 * 60 * 60)
persistenceBins: List[Int] = List(3600000, 7200000, 14400000)

scala> val persistenceValues = persistenceBins.map((bin: Int) => (bin, 0))
persistenceValues: List[(Int, Int)] = List((3600000,0), (7200000,0), (14400000,0))