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, 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 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>