Class PartitionStrategy.EdgePartition1D$

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

public static class PartitionStrategy.EdgePartition1D$ extends Object implements PartitionStrategy, scala.Product, Serializable
Assigns edges to partitions using only the source vertex ID, colocating edges with the same source.
See Also:
  • Field Details

  • Constructor Details

    • EdgePartition1D$

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