AggregatingEdgeContext Class
public class AggregatingEdgeContext extends EdgeContext
Constructor:
AggregatingEdgeContext(scala.Function2 mergeMsg, Object aggregates, org.apache.spark.util.collection.BitSet bitset)
1
ED attr()
2
​
3
The attribute associated with the edge.
4
​
5
VD dstAttr()
6
​
7
The vertex attribute of the edge's destination vertex.
8
​
9
long dstId()
10
​
11
The vertex id of the edge's destination vertex.
12
​
13
void sendToDst(A msg)
14
​
15
Sends a message to the destination vertex.
16
​
17
void sendToSrc(A msg)
18
​
19
Sends a message to the source vertex.
20
​
21
void set(long srcId, long dstId, int localSrcId, int localDstId, VD
22
srcAttr, VD dstAttr, ED attr)
23
​
24
void setRest(long dstId, int localDstId, VD dstAttr, ED attr)
25
​
26
void setSrcOnly(long srcId, int localSrcId, VD srcAttr)
27
​
28
VD srcAttr()
29
​
30
The vertex attribute of the edge's source vertex.
31
​
32
long srcId()
33
​
34
The vertex id of the edge's source vertex.
Copied!
Last modified 1yr ago
Copy link