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, reindexequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitinitializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarningpublic 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>