org.apache.spark.graphx.impl

Class ExistingEdgePartitionBuilder<ED,VD>

Object

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

public class ExistingEdgePartitionBuilder<ED,VD>
extends Object

Constructs an EdgePartition from an existing EdgePartition with the same vertex set. This enables reuse of the local vertex ids. Intended for internal use in EdgePartition only.

Constructor Summary

Constructors

Constructor and Description
ExistingEdgePartitionBuilder(org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<Object,Object> global2local, long[] local2global, Object vertexAttrs, scala.Option<org.apache.spark.util.collection.OpenHashSet<Object>> activeSet, int size, scala.reflect.ClassTag<ED> evidence$3, scala.reflect.ClassTag<VD> evidence$4)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(long src, long dst, int localSrc, int localDst, ED d) Add a new edge to the partition.
EdgePartition<ED,VD>	toEdgePartition()

Methods inherited from class Object

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

Constructor Detail

ExistingEdgePartitionBuilder

public ExistingEdgePartitionBuilder(org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<Object,Object> global2local,
                            long[] local2global,
                            Object vertexAttrs,
                            scala.Option<org.apache.spark.util.collection.OpenHashSet<Object>> activeSet,
                            int size,
                            scala.reflect.ClassTag<ED> evidence$3,
                            scala.reflect.ClassTag<VD> evidence$4)

Method Detail

add

public void add(long src,
       long dst,
       int localSrc,
       int localDst,
       ED d)

Add a new edge to the partition.

toEdgePartition

public EdgePartition<ED,VD> toEdgePartition()