Class PartitionStrategy.CanonicalRandomVertexCut$

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

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

  • Constructor Details

    • CanonicalRandomVertexCut$

      public CanonicalRandomVertexCut$()
  • 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