org.apache.spark.graphx.impl

Class RoutingTablePartition

Object

org.apache.spark.graphx.impl.RoutingTablePartition

All Implemented Interfaces:

java.io.Serializable

public class RoutingTablePartition
extends Object
implements scala.Serializable

Stores the locations of edge-partition join sites for each vertex attribute in a particular vertex partition. This provides routing information for shipping vertex attributes to edge partitions.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RoutingTablePartition(scala.Tuple3<long[],org.apache.spark.util.collection.BitSet,org.apache.spark.util.collection.BitSet>[] routingTable)

Method Summary

Methods

Modifier and Type	Method and Description
static scala.collection.Iterator<scala.Tuple2<Object,Object>>	edgePartitionToMsgs(int pid, EdgePartition<?,?> edgePartition) Generate a `RoutingTableMessage` for each vertex referenced in `edgePartition`.
static RoutingTablePartition	empty()
void	foreachWithinEdgePartition(int pid, boolean includeSrc, boolean includeDst, scala.Function1<Object,scala.runtime.BoxedUnit> f) Runs f on each vertex id to be sent to the specified edge partition.
static RoutingTablePartition	fromMsgs(int numEdgePartitions, scala.collection.Iterator<scala.Tuple2<Object,Object>> iter) Build a `RoutingTablePartition` from `RoutingTableMessage`s.
scala.collection.Iterator<Object>	iterator() Returns an iterator over all vertex ids stored in this `RoutingTablePartition`.
int	numEdgePartitions() The maximum number of edge partitions this `RoutingTablePartition` is built to join with.
int	partitionSize(int pid) Returns the number of vertices that will be sent to the specified edge partition.
RoutingTablePartition	reverse() Returns a new RoutingTablePartition reflecting a reversal of all edge directions.

Methods inherited from class Object

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

Constructor Detail

RoutingTablePartition

public RoutingTablePartition(scala.Tuple3<long[],org.apache.spark.util.collection.BitSet,org.apache.spark.util.collection.BitSet>[] routingTable)

Method Detail

empty

public static RoutingTablePartition empty()

edgePartitionToMsgs

public static scala.collection.Iterator<scala.Tuple2<Object,Object>> edgePartitionToMsgs(int pid,
                                                                         EdgePartition<?,?> edgePartition)

Generate a `RoutingTableMessage` for each vertex referenced in `edgePartition`.

fromMsgs

public static RoutingTablePartition fromMsgs(int numEdgePartitions,
                             scala.collection.Iterator<scala.Tuple2<Object,Object>> iter)

Build a `RoutingTablePartition` from `RoutingTableMessage`s.

numEdgePartitions

public int numEdgePartitions()

The maximum number of edge partitions this `RoutingTablePartition` is built to join with.

partitionSize

public int partitionSize(int pid)

Returns the number of vertices that will be sent to the specified edge partition.

iterator

public scala.collection.Iterator<Object> iterator()

Returns an iterator over all vertex ids stored in this `RoutingTablePartition`.

reverse

public RoutingTablePartition reverse()

Returns a new RoutingTablePartition reflecting a reversal of all edge directions.

foreachWithinEdgePartition

public void foreachWithinEdgePartition(int pid,
                              boolean includeSrc,
                              boolean includeDst,
                              scala.Function1<Object,scala.runtime.BoxedUnit> f)

Runs f on each vertex id to be sent to the specified edge partition. Vertex ids can be filtered by the position they have in the edge partition.