Class PartitionStrategy.RandomVertexCut$

Object
org.apache.spark.graphx.PartitionStrategy.RandomVertexCut$
All Implemented Interfaces:
Serializable, PartitionStrategy, scala.Equals, scala.Product, scala.Serializable
Enclosing interface:
PartitionStrategy

public static class PartitionStrategy.RandomVertexCut$ extends Object implements PartitionStrategy, scala.Product, scala.Serializable
Assigns edges to partitions by hashing the source and destination vertex IDs, resulting in a random vertex cut that colocates all same-direction edges between two vertices.
See Also:
  • Field Details

  • Constructor Details

    • RandomVertexCut$

      public RandomVertexCut$()
  • Method Details

    • getPartition

      public int getPartition(long src, long dst, int numParts)
      Description copied from interface: PartitionStrategy
      Returns the partition number for a given edge.
      Specified by:
      getPartition in interface PartitionStrategy