Package org.apache.druid.query.operator

Class GlueingPartitioningOperatorFactory

java.lang.Object
org.apache.druid.query.operator.AbstractPartitioningOperatorFactory
org.apache.druid.query.operator.GlueingPartitioningOperatorFactory
All Implemented Interfaces:
OperatorFactory
public class GlueingPartitioningOperatorFactory extends AbstractPartitioningOperatorFactory

  • Constructor Details

    • GlueingPartitioningOperatorFactory

      public GlueingPartitioningOperatorFactory(List<String> partitionColumns, Integer maxRowsMaterialized)

  • Method Details

    • getMaxRowsMaterialized

      public Integer getMaxRowsMaterialized()

    • wrap

      public Operator wrap(Operator op)
      Description copied from interface: OperatorFactory
      Builds an operator according to the definition of the OperatorFactory and wraps it around the operator passed in to this function.
      Specified by:
      wrap in interface OperatorFactory
      Specified by:
      wrap in class AbstractPartitioningOperatorFactory
      Parameters:
      op - the Operator to wrap
      Returns:
      the wrapped Operator

    • validateEquivalent

      public boolean validateEquivalent(OperatorFactory other)
      Description copied from interface: OperatorFactory
      Validates the equivalence of Operators. This is similar to @{code .equals} but is its own method so that it can ignore certain fields that would be important for a true equality check. Namely, two Operators defined the same way but with different output names can be considered equivalent even though they are not equal.

      This primarily exists to simplify tests, where this equivalence can be used to validate that the Operators created by the SQL planner are actually equivalent to what we expect without needing to be overly dependent on how the planner names output columns

      Specified by:
      validateEquivalent in interface OperatorFactory
      Overrides:
      validateEquivalent in class AbstractPartitioningOperatorFactory
      Parameters:
      other - the processor to test equivalence of
      Returns:
      boolean identifying if these processors should be considered equivalent to each other.

    • toString

      public String toString()
      Overrides:
      toString in class AbstractPartitioningOperatorFactory

    • hashCode

      public final int hashCode()
      Overrides:
      hashCode in class AbstractPartitioningOperatorFactory

    • equals

      public final boolean equals(Object obj)
      Overrides:
      equals in class AbstractPartitioningOperatorFactory