public class VertexPartitionOps<VD> extends VertexPartitionBaseOps<VD,VertexPartition>
Constructor and Description |
---|
VertexPartitionOps(VertexPartition<VD> self,
scala.reflect.ClassTag<VD> evidence$5) |
Modifier and Type | Method and Description |
---|---|
VertexPartition<VD> |
withIndex(org.apache.spark.util.collection.OpenHashSet<Object> index) |
VertexPartition<VD> |
withMask(org.apache.spark.util.collection.BitSet mask) |
<VD2> VertexPartition<VD2> |
withValues(Object values,
scala.reflect.ClassTag<VD2> evidence$6) |
aggregateUsingIndex, createUsingIndex, diff, filter, innerJoin, innerJoin, innerJoinKeepLeft, leftJoin, leftJoin, map, reindex
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public VertexPartitionOps(VertexPartition<VD> self, scala.reflect.ClassTag<VD> evidence$5)
public VertexPartition<VD> withIndex(org.apache.spark.util.collection.OpenHashSet<Object> index)
withIndex
in class VertexPartitionBaseOps<VD,VertexPartition>
public <VD2> VertexPartition<VD2> withValues(Object values, scala.reflect.ClassTag<VD2> evidence$6)
withValues
in class VertexPartitionBaseOps<VD,VertexPartition>
public VertexPartition<VD> withMask(org.apache.spark.util.collection.BitSet mask)
withMask
in class VertexPartitionBaseOps<VD,VertexPartition>