GraphX-Spark: error graph.vertices.filter

Question

Я новичок в scala и spark-graphx. Это метод, который я написал, чтобы извлечь вершину, которая имеет значение мин оценка

def getMinScoreVertex(graph: Graph[(Int,Float,Float,Float,String),Float]):Float={ 
var minValue:Float=Float.PositiveInfinity 
var LowestScoreValue=graph.vertices.filter { case (id,(_,_,_,Score,_)) => Score < minValue} 
return LowestScoreValue } 

Я получаю следующее сообщение об ошибке:

Error:(15, 62) constructor cannot be instantiated to expected type; 
found : (T1, T2, T3, T4, T5) 
required: (org.apache.spark.graphx.VertexId, (Int, Float, Float, Float, String)) 
    (which expands to) (Long, (Int, Float, Float, Float, String)) 
    var LowestScoreValue=graph.vertices.filter { case (_,_,_,Score,_) => Score < minValue} 
Error:(15, 69) not found: value Score 
    var LowestScoreValue=graph.vertices.filter { case (_,_,_,Score,_) => Score < minValue} 
Error:(15, 82) not found: value Score 
    var LowestScoreValue=graph.vertices.filter { case (_,_,_,Score,_) => Score < minValue} 

Любые идеи ?? Спасибо

Answer 1

В благодарность я допустил ошибку, считая, что Score - тип. В большинстве случаев, если вы выполняете сопоставление с образцом, безопасно использовать строчные буквы. (lowercased variables in pattern matching)

val filterResult = graph.vertices.filter { 
    case (_, (_, _, _, score, _)) => score < minValue 
} 

Это не даст ошибку компиляции.

Еще одна вещь: filter - это неправильный выбор для выбора минимального выбора. Он просто отфильтрует VertexRDD, который имеет меньше, чем minValue, и вернет список.