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

Field Summary

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

description, operands, relBuilderFactory

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

AggPruleBase

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

Method Detail

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.