Module datarush.library
Package com.pervasive.datarush.ports.record

Class UnspecifiedPartialDistribution

java.lang.Object
com.pervasive.datarush.ports.record.DataDistribution
com.pervasive.datarush.ports.record.PartialDataDistribution
com.pervasive.datarush.ports.record.PartialStaticDataDistribution
com.pervasive.datarush.ports.record.UnspecifiedPartialDistribution
public final class UnspecifiedPartialDistribution extends PartialStaticDataDistribution
The default data distribution; if unspecified an operator will receive data in the same distribution as the upstream operator.

  • Field Details

  • Method Details

    • toString

      public String toString()
      Specified by:
      toString in class DataDistribution

    • remap

      public UnspecifiedPartialDistribution remap(FieldRemapping mapping)
      Because UnspecifiedPartialDistribution does not reference any key names, it is not sensitive to transformations to the record namespace and thus this method just returns a reference to this, unmodified.
      Specified by:
      remap in class DataDistribution
      Parameters:
      mapping - the field remapping.
      Returns:
      this distribution, unmodified

    • requiresRepartitionFrom

      protected boolean requiresRepartitionFrom(PartialDataDistribution source)
      Description copied from class: PartialStaticDataDistribution
      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.
      Specified by:
      requiresRepartitionFrom in class PartialStaticDataDistribution
      Parameters:
      source - the source distribution
      Returns:
      true if a repartition is required, false if this data distribution matches what was specified.

    • getAliases

      public AliasSet[] getAliases()
      Description copied from class: DataDistribution
      Returns the fields that are referenced by this distribution. Note that it is valid for a distribution to reference no fields, in which case it should return an empty array. This method is used by the framework to validate the distribution is consistent with the type of the record.
      Specified by:
      getAliases in class DataDistribution
      Returns:
      the fields that are referenced by this distribution

    • getPartitionOperator

      protected com.pervasive.datarush.operators.partition.internal.PartitionOperator getPartitionOperator(int partitionCount)

    • getPartitioningFunction

      protected PartitioningFunction getPartitioningFunction()
      Description copied from class: PartialStaticDataDistribution
      Subclasses must override this method to provide the partitioning function to be used
      Specified by:
      getPartitioningFunction in class PartialStaticDataDistribution
      Returns:
      a partition function

    • supportsLocalRepartition

      protected boolean supportsLocalRepartition()
      Description copied from class: PartialStaticDataDistribution
      Subclasses may override to indicate that they support a local repartition
      Overrides:
      supportsLocalRepartition in class PartialStaticDataDistribution
      Returns: