我一直在Scala中编写代码以找到最短路径。这是我找到最短路径的代码。但是我在下面的代码部分出现错误

if ( (kv1._1 + kv1._2 )< (kv2._1 + kv2._2)) kv1 else kv2


错误是

value < is not a member of AnyVal


这是我的代码:

 val inputRDD = sc.textFile(args(0)).map { line =>
  val a = line.split(",")
  (a(0).toLong, (a(1).toLong, a(2).toLong))
}
var distanceRDD = inputRDD.flatMap(x => {
  val pair1 = if (x._1 == 0) (x._1, 0) else (x._1, Long.MaxValue)
  val pair2 = if (x._2._1 == 0) (x._2._1, 0) else (x._2._1, Long.MaxValue)

  List(pair1, pair2)
}).distinct()

for ( index <- 1 to 4 ) {
  val vertexDistanceRDD=  inputRDD.join(distanceRDD)

  val invertedRDD =vertexDistanceRDD.map(attr => (attr._2._1._2,(attr._2._1._1,attr._2._2)))

  val computedDistBetweenVertRDD =invertedRDD.reduceByKey((kv1, kv2) => {

    if (kv1._2 == kv2._2) if (kv1._1 < kv2._1) kv1 else kv2
    else if (kv1._2.<(kv2._2)){
      if ( kv2._2 != Long.MaxValue) {
        if ( (kv1._1 + kv1._2 )< (kv2._1 + kv2._2)) kv1 else kv2
      }
      else  kv1
    }
    else {
      if ( kv1._2 != Long.MaxValue) {
        if (kv1._1 + kv1._2 < kv2._1 + kv2._2) kv1 else kv2
      }
      else  kv2
    }
  })

  val joinedRDD = computedDistBetweenVertRDD.join(distanceRDD)
  distanceRDD =joinedRDD.map(kv => {
    if (kv._2._2 > kv._2._1._1 + kv._2._1._2) (kv._1,kv._2._1._1 + kv._2._1._2) else (kv._1,kv._2._2)
  })
}


可能是什么原因,我该如何纠正?

最佳答案

表达

if (x._1 == 0) (x._1, 0) else (x._1, Long.MaxValue)


的类型为(Long, AnyVal),因为0Int文字(在这种情况下,不会隐式转换为Long),并且IntLong的最小上限为AnyVal。正确的代码应该是

if (x._1 == 0) (x._1, 0L) else (x._1, Long.MaxValue)
//                     ^ use Long literal there


同样适用于您的第二个if

关于scala - 值<不是AnyVal的成员,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/47212617/

10-12 16:34