org.apache.spark.graphx.impl

Class VertexPartition<VD>

Object

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

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

All Implemented Interfaces:

java.io.Serializable

public class VertexPartition<VD>
extends VertexPartitionBase<VD>

A map from vertex id to vertex attribute.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	VertexPartition.VertexPartitionOpsConstructor$ Implicit evidence that VertexPartition is a member of the VertexPartitionBaseOpsConstructor typeclass.

Constructor Summary

Constructors

Constructor and Description
VertexPartition(org.apache.spark.util.collection.OpenHashSet<Object> index, Object values, org.apache.spark.util.collection.BitSet mask, scala.reflect.ClassTag<VD> evidence$4)

Method Summary

Methods

Modifier and Type	Method and Description
static <VD> VertexPartition<VD>	apply(scala.collection.Iterator<scala.Tuple2<Object,VD>> iter, scala.reflect.ClassTag<VD> evidence$1) Construct a `VertexPartition` from the given vertices.
org.apache.spark.util.collection.OpenHashSet<Object>	index()
org.apache.spark.util.collection.BitSet	mask()
static <VD> VertexPartitionOps<VD>	partitionToOps(VertexPartition<VD> partition, scala.reflect.ClassTag<VD> evidence$2) Implicit conversion to allow invoking VertexPartitionBase operations directly on a VertexPartition.
Object	values()

Methods inherited from class org.apache.spark.graphx.impl.VertexPartitionBase

apply, capacity, initFrom, initFrom, isDefined, iterator, size

Methods inherited from class Object

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

Constructor Detail

VertexPartition

public VertexPartition(org.apache.spark.util.collection.OpenHashSet<Object> index,
               Object values,
               org.apache.spark.util.collection.BitSet mask,
               scala.reflect.ClassTag<VD> evidence$4)

Method Detail

apply

public static <VD> VertexPartition<VD> apply(scala.collection.Iterator<scala.Tuple2<Object,VD>> iter,
                             scala.reflect.ClassTag<VD> evidence$1)

Construct a `VertexPartition` from the given vertices.

partitionToOps

public static <VD> VertexPartitionOps<VD> partitionToOps(VertexPartition<VD> partition,
                                         scala.reflect.ClassTag<VD> evidence$2)

Implicit conversion to allow invoking VertexPartitionBase operations directly on a VertexPartition.

index

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

Specified by:

index in class VertexPartitionBase<VD>

values

public Object values()

Specified by:

values in class VertexPartitionBase<VD>

mask

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

Specified by:

mask in class VertexPartitionBase<VD>