org.apache.spark.graphx.impl

Class ReplicatedVertexView<VD,ED>

Object

org.apache.spark.graphx.impl.ReplicatedVertexView<VD,ED>

public class ReplicatedVertexView<VD,ED>
extends Object

Manages shipping vertex attributes to the edge partitions of an EdgeRDD. Vertex attributes may be partially shipped to construct a triplet view with vertex attributes on only one side, and they may be updated. An active vertex set may additionally be shipped to the edge partitions. Be careful not to store a reference to edges, since it may be modified when the attribute shipping level is upgraded.

Constructor Summary

Constructors

Constructor and Description
ReplicatedVertexView(EdgeRDDImpl<ED,VD> edges, boolean hasSrcId, boolean hasDstId, scala.reflect.ClassTag<VD> evidence$1, scala.reflect.ClassTag<ED> evidence$2)

Method Summary

Methods

Modifier and Type	Method and Description
EdgeRDDImpl<ED,VD>	edges()
boolean	hasDstId()
boolean	hasSrcId()
ReplicatedVertexView<VD,ED>	reverse() Return a new ReplicatedVertexView where edges are reversed and shipping levels are swapped to match.
ReplicatedVertexView<VD,ED>	updateVertices(VertexRDD<VD> updates) Return a new ReplicatedVertexView where vertex attributes in edge partition are updated using updates.
void	upgrade(VertexRDD<VD> vertices, boolean includeSrc, boolean includeDst) Upgrade the shipping level in-place to the specified levels by shipping vertex attributes from vertices.
ReplicatedVertexView<VD,ED>	withActiveSet(VertexRDD<?> actives) Return a new ReplicatedVertexView where the activeSet in each edge partition contains only vertex ids present in actives.
<VD2,ED2> ReplicatedVertexView<VD2,ED2>	withEdges(EdgeRDDImpl<ED2,VD2> edges_, scala.reflect.ClassTag<VD2> evidence$3, scala.reflect.ClassTag<ED2> evidence$4) Return a new ReplicatedVertexView with the specified EdgeRDD, which must have the same shipping level.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReplicatedVertexView

public ReplicatedVertexView(EdgeRDDImpl<ED,VD> edges,
                    boolean hasSrcId,
                    boolean hasDstId,
                    scala.reflect.ClassTag<VD> evidence$1,
                    scala.reflect.ClassTag<ED> evidence$2)

Method Detail

edges

public EdgeRDDImpl<ED,VD> edges()

hasSrcId

public boolean hasSrcId()

hasDstId

public boolean hasDstId()

withEdges

public <VD2,ED2> ReplicatedVertexView<VD2,ED2> withEdges(EdgeRDDImpl<ED2,VD2> edges_,
                                                scala.reflect.ClassTag<VD2> evidence$3,
                                                scala.reflect.ClassTag<ED2> evidence$4)

Return a new ReplicatedVertexView with the specified EdgeRDD, which must have the same shipping level.

reverse

public ReplicatedVertexView<VD,ED> reverse()

Return a new ReplicatedVertexView where edges are reversed and shipping levels are swapped to match.

upgrade

public void upgrade(VertexRDD<VD> vertices,
           boolean includeSrc,
           boolean includeDst)

Upgrade the shipping level in-place to the specified levels by shipping vertex attributes from vertices. This operation modifies the ReplicatedVertexView, and callers can access edges afterwards to obtain the upgraded view.

withActiveSet

public ReplicatedVertexView<VD,ED> withActiveSet(VertexRDD<?> actives)

Return a new ReplicatedVertexView where the activeSet in each edge partition contains only vertex ids present in actives. This ships a vertex id to all edge partitions where it is referenced, ignoring the attribute shipping level.

updateVertices

public ReplicatedVertexView<VD,ED> updateVertices(VertexRDD<VD> updates)

Return a new ReplicatedVertexView where vertex attributes in edge partition are updated using updates. This ships a vertex attribute only to the edge partitions where it is in the position(s) specified by the attribute shipping level.