Class PartialStaticDataDistribution

    • Constructor Detail

      • PartialStaticDataDistribution

        protected PartialStaticDataDistribution()
        Default constructor.
    • Method Detail

      • supportsLocalRepartition

        protected boolean supportsLocalRepartition()
        Subclasses may override to indicate that they support a local repartition
        Returns:
      • getPartitioningFunction

        protected abstract PartitioningFunction getPartitioningFunction()
        Subclasses must override this method to provide the partitioning function to be used
        Returns:
        a partition function
      • requiresRepartitionFrom

        protected abstract boolean requiresRepartitionFrom​(PartialDataDistribution source)
        Subclasses must override this method to declare whether a repartition is required given the source distribution. Implementations may err on the side of caution by always returning true but this may have an impact on performance.
        Parameters:
        source - the source distribution
        Returns:
        true if a repartition is required, false if this data distribution matches what was specified.