public class HiveAggregate extends org.apache.calcite.rel.core.Aggregate implements HiveRelNode
org.apache.calcite.rel.core.Aggregate.AggCallBinding, org.apache.calcite.rel.core.Aggregate.Group
HiveRelNode.Implementor
aggCalls, groupSet, groupSets, indicator, IS_NOT_GRAND_TOTAL, IS_SIMPLE
CONVENTION
Constructor and Description |
---|
HiveAggregate(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode child,
boolean indicator,
org.apache.calcite.util.ImmutableBitSet groupSet,
List<org.apache.calcite.util.ImmutableBitSet> groupSets,
List<org.apache.calcite.rel.core.AggregateCall> aggCalls) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.core.Aggregate |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode input,
boolean indicator,
org.apache.calcite.util.ImmutableBitSet groupSet,
List<org.apache.calcite.util.ImmutableBitSet> groupSets,
List<org.apache.calcite.rel.core.AggregateCall> aggCalls) |
protected org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
static org.apache.calcite.rel.type.RelDataType |
deriveRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory,
org.apache.calcite.rel.type.RelDataType inputRowType,
boolean indicator,
org.apache.calcite.util.ImmutableBitSet groupSet,
List<org.apache.calcite.util.ImmutableBitSet> groupSets,
List<org.apache.calcite.rel.core.AggregateCall> aggCalls) |
double |
estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery mq) |
LinkedHashSet<Integer> |
getAggregateColumnsOrder() |
void |
implement(HiveRelNode.Implementor implementor) |
boolean |
isBucketedInput() |
void |
setAggregateColumnsOrder(LinkedHashSet<Integer> aggregateColumnsOrder) |
computeSelfCost, containsDistinctCall, copy, explainTerms, getAggCallList, getGroupCount, getGroupSet, getGroupSets, getGroupType, getIndicatorCount, getNamedAggCalls, isValid
childrenAccept, getInput, getInputs, replaceInput
accept, accept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, explain, getChildExps, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, metadata, onRegister, recomputeDigest, register, sole, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, copy, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
public HiveAggregate(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode child, boolean indicator, org.apache.calcite.util.ImmutableBitSet groupSet, List<org.apache.calcite.util.ImmutableBitSet> groupSets, List<org.apache.calcite.rel.core.AggregateCall> aggCalls)
public org.apache.calcite.rel.core.Aggregate copy(org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode input, boolean indicator, org.apache.calcite.util.ImmutableBitSet groupSet, List<org.apache.calcite.util.ImmutableBitSet> groupSets, List<org.apache.calcite.rel.core.AggregateCall> aggCalls)
copy
in class org.apache.calcite.rel.core.Aggregate
public void implement(HiveRelNode.Implementor implementor)
implement
in interface HiveRelNode
public double estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery mq)
estimateRowCount
in interface org.apache.calcite.rel.RelNode
estimateRowCount
in class org.apache.calcite.rel.core.Aggregate
public boolean isBucketedInput()
protected org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class org.apache.calcite.rel.core.Aggregate
public static org.apache.calcite.rel.type.RelDataType deriveRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, org.apache.calcite.rel.type.RelDataType inputRowType, boolean indicator, org.apache.calcite.util.ImmutableBitSet groupSet, List<org.apache.calcite.util.ImmutableBitSet> groupSets, List<org.apache.calcite.rel.core.AggregateCall> aggCalls)
public void setAggregateColumnsOrder(LinkedHashSet<Integer> aggregateColumnsOrder)
public LinkedHashSet<Integer> getAggregateColumnsOrder()
Copyright © 2021 The Apache Software Foundation. All rights reserved.