public class ShippableVertexPartitionOps<VD> extends VertexPartitionBaseOps<VD,ShippableVertexPartition>
| Constructor and Description |
|---|
ShippableVertexPartitionOps(ShippableVertexPartition<VD> self,
scala.reflect.ClassTag<VD> evidence$8) |
| Modifier and Type | Method and Description |
|---|---|
ShippableVertexPartition<VD> |
withIndex(org.apache.spark.util.collection.OpenHashSet<Object> index) |
ShippableVertexPartition<VD> |
withMask(org.apache.spark.util.collection.BitSet mask) |
<VD2> ShippableVertexPartition<VD2> |
withValues(Object values,
scala.reflect.ClassTag<VD2> evidence$9) |
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 ShippableVertexPartitionOps(ShippableVertexPartition<VD> self, scala.reflect.ClassTag<VD> evidence$8)
public ShippableVertexPartition<VD> withIndex(org.apache.spark.util.collection.OpenHashSet<Object> index)
withIndex in class VertexPartitionBaseOps<VD,ShippableVertexPartition>public <VD2> ShippableVertexPartition<VD2> withValues(Object values, scala.reflect.ClassTag<VD2> evidence$9)
withValues in class VertexPartitionBaseOps<VD,ShippableVertexPartition>public ShippableVertexPartition<VD> withMask(org.apache.spark.util.collection.BitSet mask)
withMask in class VertexPartitionBaseOps<VD,ShippableVertexPartition>