Skip to content
This repository was archived by the owner on Jul 31, 2023. It is now read-only.

Commit f5238ea

Browse files
xwu-intelsrowen
authored andcommitted
[GRAPHX][MINOR] Fix typo setRest => setDest
### What changes were proposed in this pull request? Fix typo def setRest(dstId: VertexId, localDstId: Int, dstAttr: VD, attr: ED) to def setDest(dstId: VertexId, localDstId: Int, dstAttr: VD, attr: ED) ### Why are the changes needed? Typo ### Does this PR introduce any user-facing change? No ### How was this patch tested? N/A Closes apache#27594 from xwu99/fix-graphx-setDest. Authored-by: Wu, Xiaochang <[email protected]> Signed-off-by: Sean Owen <[email protected]>
1 parent 8b73b92 commit f5238ea

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: graphx/src/main/scala/org/apache/spark/graphx/impl/EdgePartition.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -465,7 +465,7 @@ class EdgePartition[
465465
if (edgeIsActive) {
466466
val dstAttr =
467467
if (tripletFields.useDst) vertexAttrs(localDstId) else null.asInstanceOf[VD]
468-
ctx.setRest(dstId, localDstId, dstAttr, data(pos))
468+
ctx.setDest(dstId, localDstId, dstAttr, data(pos))
469469
sendMsg(ctx)
470470
}
471471
pos += 1
@@ -511,7 +511,7 @@ private class AggregatingEdgeContext[VD, ED, A](
511511
_srcAttr = srcAttr
512512
}
513513

514-
def setRest(dstId: VertexId, localDstId: Int, dstAttr: VD, attr: ED): Unit = {
514+
def setDest(dstId: VertexId, localDstId: Int, dstAttr: VD, attr: ED): Unit = {
515515
_dstId = dstId
516516
_localDstId = localDstId
517517
_dstAttr = dstAttr

0 commit comments

Comments
 (0)