Class BlockPartitioner

  • All Implemented Interfaces:
    Serializable, scala.Serializable

    public class BlockPartitioner
    extends org.apache.spark.Partitioner
    Default partitioner used for all binary block rdd operations in order to enable sufficient local aggregation independent of the aggregation direction (row/col-wise). Especially, on large squared matrices (as common for factorization or graph algorithms), this is crucial for performance.
    See Also:
    Serialized Form
    • Constructor Detail

    • Method Detail

      • getPartition

        public int getPartition​(Object arg0)
        Specified by:
        getPartition in class org.apache.spark.Partitioner
      • numPartitions

        public int numPartitions()
        Specified by:
        numPartitions in class org.apache.spark.Partitioner
      • hashCode

        public int hashCode()
        hashCode in class Object