org.apache.flink.table.planner.plan.rules.logical

类 FlinkAggregateExpandDistinctAggregatesRule

java.lang.Object

org.apache.calcite.plan.RelOptRule

org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateExpandDistinctAggregatesRule

public final class FlinkAggregateExpandDistinctAggregatesRule
extends org.apache.calcite.plan.RelOptRule

Planner rule that expands distinct aggregates (such as COUNT(DISTINCT x)) from a Aggregate.

How this is done depends upon the arguments to the function. If all functions have the same argument (e.g. COUNT(DISTINCT x), SUM(DISTINCT x) both have the argument x) then one extra Aggregate is sufficient.

If there are multiple arguments (e.g. COUNT(DISTINCT x), COUNT(DISTINCT y)) the rule creates separate Aggregates and combines using a Join.

嵌套类概要

从类继承的嵌套类/接口 org.apache.calcite.plan.RelOptRule

org.apache.calcite.plan.RelOptRule.ConverterRelOptRuleOperand

字段概要

字段

限定符和类型	字段和说明
static FlinkAggregateExpandDistinctAggregatesRule	INSTANCE The default instance of the rule; operates only on logical expressions.
static FlinkAggregateExpandDistinctAggregatesRule	JOIN Instance of the rule that operates only on logical expressions and generates a join.
boolean	useGroupingSets

从类继承的字段 org.apache.calcite.plan.RelOptRule

description, operands, relBuilderFactory

构造器概要

构造器

构造器和说明
FlinkAggregateExpandDistinctAggregatesRule(Class<? extends org.apache.calcite.rel.core.Aggregate> clazz, boolean useGroupingSets, org.apache.calcite.tools.RelBuilderFactory relBuilderFactory)
FlinkAggregateExpandDistinctAggregatesRule(Class<? extends org.apache.calcite.rel.logical.LogicalAggregate> clazz, boolean useGroupingSets, org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory) 已过时。
FlinkAggregateExpandDistinctAggregatesRule(Class<? extends org.apache.calcite.rel.logical.LogicalAggregate> clazz, org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory) 已过时。

方法概要

限定符和类型	方法和说明
void	onMatch(org.apache.calcite.plan.RelOptRuleCall call)

从类继承的方法 org.apache.calcite.plan.RelOptRule

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

从类继承的方法 java.lang.Object

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

字段详细资料

INSTANCE

public static final FlinkAggregateExpandDistinctAggregatesRule INSTANCE

The default instance of the rule; operates only on logical expressions.

JOIN

public static final FlinkAggregateExpandDistinctAggregatesRule JOIN

Instance of the rule that operates only on logical expressions and generates a join.

useGroupingSets

public final boolean useGroupingSets

构造器详细资料

FlinkAggregateExpandDistinctAggregatesRule

public FlinkAggregateExpandDistinctAggregatesRule(Class<? extends org.apache.calcite.rel.core.Aggregate> clazz,
                                                  boolean useGroupingSets,
                                                  org.apache.calcite.tools.RelBuilderFactory relBuilderFactory)

FlinkAggregateExpandDistinctAggregatesRule

@Deprecated
public FlinkAggregateExpandDistinctAggregatesRule(Class<? extends org.apache.calcite.rel.logical.LogicalAggregate> clazz,
                                                              boolean useGroupingSets,
                                                              org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory)

已过时。

FlinkAggregateExpandDistinctAggregatesRule

@Deprecated
public FlinkAggregateExpandDistinctAggregatesRule(Class<? extends org.apache.calcite.rel.logical.LogicalAggregate> clazz,
                                                              org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory)

已过时。

方法详细资料

onMatch

public void onMatch(org.apache.calcite.plan.RelOptRuleCall call)

指定者:

onMatch 在类中 org.apache.calcite.plan.RelOptRule