org.apache.spark.graphx.impl

Class VertexPartitionBase<VD>

Object

org.apache.spark.graphx.impl.VertexPartitionBase<VD>

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

ShippableVertexPartition, VertexPartition

public abstract class VertexPartitionBase<VD>
extends Object
implements scala.Serializable

An abstract map from vertex id to vertex attribute. VertexPartition is the corresponding concrete implementation. VertexPartitionBaseOps provides a variety of operations for VertexPartitionBase and subclasses that provide implicit evidence of membership in the VertexPartitionBaseOpsConstructor typeclass (for example, VertexPartition.VertexPartitionOpsConstructor).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
VertexPartitionBase(scala.reflect.ClassTag<VD> evidence$3)

Method Summary

Methods

Modifier and Type	Method and Description
VD	apply(long vid) Return the vertex attribute for the given vertex ID.
int	capacity()
abstract org.apache.spark.util.collection.OpenHashSet<Object>	index()
static <VD> scala.Tuple3<org.apache.spark.util.collection.OpenHashSet<Object>,Object,org.apache.spark.util.collection.BitSet>	initFrom(scala.collection.Iterator<scala.Tuple2<Object,VD>> iter, scala.reflect.ClassTag<VD> evidence$1) Construct the constituents of a VertexPartitionBase from the given vertices, merging duplicate entries arbitrarily.
static <VD> scala.Tuple3<org.apache.spark.util.collection.OpenHashSet<Object>,Object,org.apache.spark.util.collection.BitSet>	initFrom(scala.collection.Iterator<scala.Tuple2<Object,VD>> iter, scala.Function2<VD,VD,VD> mergeFunc, scala.reflect.ClassTag<VD> evidence$2) Construct the constituents of a VertexPartitionBase from the given vertices, merging duplicate entries using mergeFunc.
boolean	isDefined(long vid)
scala.collection.Iterator<scala.Tuple2<Object,VD>>	iterator()
abstract org.apache.spark.util.collection.BitSet	mask()
int	size()
abstract Object	values()

Methods inherited from class Object

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

Constructor Detail

VertexPartitionBase

public VertexPartitionBase(scala.reflect.ClassTag<VD> evidence$3)

Method Detail

initFrom

public static <VD> scala.Tuple3<org.apache.spark.util.collection.OpenHashSet<Object>,Object,org.apache.spark.util.collection.BitSet> initFrom(scala.collection.Iterator<scala.Tuple2<Object,VD>> iter,
                                                                                                                              scala.reflect.ClassTag<VD> evidence$1)

Construct the constituents of a VertexPartitionBase from the given vertices, merging duplicate entries arbitrarily.

initFrom

public static <VD> scala.Tuple3<org.apache.spark.util.collection.OpenHashSet<Object>,Object,org.apache.spark.util.collection.BitSet> initFrom(scala.collection.Iterator<scala.Tuple2<Object,VD>> iter,
                                                                                                                              scala.Function2<VD,VD,VD> mergeFunc,
                                                                                                                              scala.reflect.ClassTag<VD> evidence$2)

Construct the constituents of a VertexPartitionBase from the given vertices, merging duplicate entries using mergeFunc.

index

public abstract org.apache.spark.util.collection.OpenHashSet<Object> index()

values

public abstract Object values()

mask

public abstract org.apache.spark.util.collection.BitSet mask()

capacity

public int capacity()

size

public int size()

apply

public VD apply(long vid)

Return the vertex attribute for the given vertex ID.

isDefined

public boolean isDefined(long vid)

iterator

public scala.collection.Iterator<scala.Tuple2<Object,VD>> iterator()