Repository: spark Updated Branches: refs/heads/master 68707225f -> b3e6eca81
[SPARK-6357][GraphX] Add unapply in EdgeContext This extractor is mainly used for Graph#aggregateMessages*. Author: Takeshi YAMAMURO <[email protected]> Closes #5047 from maropu/AddUnapplyInEdgeContext and squashes the following commits: 87e04df [Takeshi YAMAMURO] Add unapply in EdgeContext Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/b3e6eca8 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/b3e6eca8 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/b3e6eca8 Branch: refs/heads/master Commit: b3e6eca81f79ba3c9205211797fa825b199bac83 Parents: 6870722 Author: Takeshi YAMAMURO <[email protected]> Authored: Mon Mar 16 23:54:54 2015 -0700 Committer: Reynold Xin <[email protected]> Committed: Mon Mar 16 23:54:54 2015 -0700 ---------------------------------------------------------------------- .../org/apache/spark/graphx/EdgeContext.scala | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/b3e6eca8/graphx/src/main/scala/org/apache/spark/graphx/EdgeContext.scala ---------------------------------------------------------------------- diff --git a/graphx/src/main/scala/org/apache/spark/graphx/EdgeContext.scala b/graphx/src/main/scala/org/apache/spark/graphx/EdgeContext.scala index f70715f..d8be02e 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/EdgeContext.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/EdgeContext.scala @@ -49,3 +49,20 @@ abstract class EdgeContext[VD, ED, A] { et } } + +object EdgeContext { + + /** + * Extractor mainly used for Graph#aggregateMessages*. + * Example: + * {{{ + * val messages = graph.aggregateMessages( + * case ctx @ EdgeContext(_, _, _, _, attr) => + * ctx.sendToDst(attr) + * , _ + _) + * }}} + */ + def unapply[VD, ED, A](edge: EdgeContext[VD, ED, A]) = + Some(edge.srcId, edge.dstId, edge.srcAttr, edge.dstAttr, edge.attr) +} + --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
