Dear Spark developers, Could you suggest how to perform pattern matching on the type of the graph edge in the following scenario. I need to perform some math by means of aggregateMessages on the graph edges if edges are Double. Here is the code: def my[VD: ClassTag, ED: ClassTag] (graph: Graph[VD, ED]): Double { graph match { g: Graph[_, Double] => g.aggregateMessages[Double](t => t.sendToSrc(t.attr), _ + _).values.max _ => 0.0 } }
However, it does not work, because aggregateMessages creates context t of type [VD, ED, Double]. I expect it to create context of [VD, Double, Double] because of the type pattern matching. Could you suggest what is the issue? Best regards, Alexander