Package org.apache.drill.exec.planner.physical

Class AggPruleBase

java.lang.Object
org.apache.calcite.plan.RelOptRule
org.apache.drill.exec.planner.physical.Prule
org.apache.drill.exec.planner.physical.AggPruleBase
Direct Known Subclasses:
HashAggPrule, StreamAggPrule
public abstract class AggPruleBase extends Prule

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.calcite.plan.RelOptRule

    org.apache.calcite.plan.RelOptRule.ConverterRelOptRuleOperand

  • Field Summary

    Fields inherited from class org.apache.calcite.plan.RelOptRule

    description, operands, relBuilderFactory

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    AggPruleBase(org.apache.calcite.plan.RelOptRuleOperand operand, String description)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected boolean
    create2PhasePlan(org.apache.calcite.plan.RelOptRuleCall call, DrillAggregateRel aggregate)
     
    protected List<DrillDistributionTrait.DistributionField>
    getDistributionField(DrillAggregateRel rel, boolean allFields)
     
    static org.apache.calcite.util.ImmutableBitSet
    remapGroupSet(org.apache.calcite.util.ImmutableBitSet groupSet)
    Returns group-by keys with the remapped arguments for specified aggregate.

    Methods inherited from class org.apache.drill.exec.planner.physical.Prule

    convert, isSingleMode

    Methods inherited from class org.apache.calcite.plan.RelOptRule

    any, convert, convertList, convertOperand, convertOperand, equals, equals, getOperand, getOperands, getOutConvention, getOutTrait, hashCode, matches, none, onMatch, operand, operand, operand, operand, operand, operandJ, operandJ, some, toString, unordered

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • AggPruleBase

      protected AggPruleBase(org.apache.calcite.plan.RelOptRuleOperand operand, String description)

  • Method Details

    • getDistributionField

      protected List<DrillDistributionTrait.DistributionField> getDistributionField(DrillAggregateRel rel, boolean allFields)

    • create2PhasePlan

      protected boolean create2PhasePlan(org.apache.calcite.plan.RelOptRuleCall call, DrillAggregateRel aggregate)

    • remapGroupSet

      public static org.apache.calcite.util.ImmutableBitSet remapGroupSet(org.apache.calcite.util.ImmutableBitSet groupSet)
      Returns group-by keys with the remapped arguments for specified aggregate.
      Parameters:
      groupSet - ImmutableBitSet of aggregate rel node, whose group-by keys should be remapped.
      Returns:
      ImmutableBitSet instance with remapped keys.