org.apache.spark.graphx
Extractor mainly used for Graph#aggregateMessages*.
Extractor mainly used for Graph#aggregateMessages*. Example:
val messages = graph.aggregateMessages( case ctx @ EdgeContext(_, _, _, _, attr) => ctx.sendToDst(attr) , _ + _)