ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[GRAPHX][MINOR] Fix typo setRest => setDest

Browse source 
### 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 #27594 from xwu99/fix-graphx-setDest.

Authored-by: Wu, Xiaochang <xiaochang.wu@intel.com>
Signed-off-by: Sean Owen <srowen@gmail.com>
This commit is contained in:
Wu, Xiaochang 2020-02-16 09:51:02 -06:00 committed by Sean Owen
parent 8b73b92aad
commit f5238ea6cb
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
graphx/src/main/scala/org/apache/spark/graphx/impl/EdgePartition.scala
View file

@ -465,7 +465,7 @@ class EdgePartition[
if (edgeIsActive) {
val dstAttr =
if (tripletFields.useDst) vertexAttrs(localDstId) else null.asInstanceOf[VD]
ctx.setRest(dstId, localDstId, dstAttr, data(pos))
ctx.setDest(dstId, localDstId, dstAttr, data(pos))
sendMsg(ctx)
}
pos += 1
@ -511,7 +511,7 @@ private class AggregatingEdgeContext[VD, ED, A](
_srcAttr = srcAttr
}
def setRest(dstId: VertexId, localDstId: Int, dstAttr: VD, attr: ED): Unit = {
def setDest(dstId: VertexId, localDstId: Int, dstAttr: VD, attr: ED): Unit = {
_dstId = dstId
_localDstId = localDstId
_dstAttr = dstAttr