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

Class FlinkAggregateJoinTransposeRule

java.lang.Object

org.apache.calcite.plan.RelOptRule

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

public class FlinkAggregateJoinTransposeRule
extends org.apache.calcite.plan.RelOptRule

Planner rule that pushes an Aggregate past a Join.

Nested Class Summary

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

org.apache.calcite.plan.RelOptRule.ConverterRelOptRuleOperand

Field Summary

Fields

Modifier and Type	Field	Description
static FlinkAggregateJoinTransposeRule	EXTENDED	Extended instance of the rule that can push down aggregate functions.
static FlinkAggregateJoinTransposeRule	INSTANCE

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

description, operands, relBuilderFactory

Constructor Summary

Constructors

Constructor	Description
FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass, Class<? extends org.apache.calcite.rel.core.Join> joinClass, org.apache.calcite.tools.RelBuilderFactory relBuilderFactory, boolean allowFunctions)	Creates an FlinkAggregateJoinTransposeRule.
FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass, org.apache.calcite.rel.core.RelFactories.AggregateFactory aggregateFactory, Class<? extends org.apache.calcite.rel.core.Join> joinClass, org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory)	Deprecated.
FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass, org.apache.calcite.rel.core.RelFactories.AggregateFactory aggregateFactory, Class<? extends org.apache.calcite.rel.core.Join> joinClass, org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory, boolean allowFunctions)	Deprecated.
FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass, org.apache.calcite.rel.core.RelFactories.AggregateFactory aggregateFactory, Class<? extends org.apache.calcite.rel.core.Join> joinClass, org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory, org.apache.calcite.rel.core.RelFactories.ProjectFactory projectFactory)	Deprecated.
FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass, org.apache.calcite.rel.core.RelFactories.AggregateFactory aggregateFactory, Class<? extends org.apache.calcite.rel.core.Join> joinClass, org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory, org.apache.calcite.rel.core.RelFactories.ProjectFactory projectFactory, boolean allowFunctions)	Deprecated.

Method Summary

Modifier and Type	Method	Description
boolean	matches(org.apache.calcite.plan.RelOptRuleCall call)
void	onMatch(org.apache.calcite.plan.RelOptRuleCall call)

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

any, convert, convert, convertList, convertOperand, convertOperand, equals, equals, getOperand, getOperands, getOutConvention, getOutTrait, hashCode, none, 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

Field Detail

INSTANCE

public static final FlinkAggregateJoinTransposeRule INSTANCE

EXTENDED

public static final FlinkAggregateJoinTransposeRule EXTENDED

Extended instance of the rule that can push down aggregate functions.

Constructor Detail

FlinkAggregateJoinTransposeRule

public FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass,
                                       Class<? extends org.apache.calcite.rel.core.Join> joinClass,
                                       org.apache.calcite.tools.RelBuilderFactory relBuilderFactory,
                                       boolean allowFunctions)

Creates an FlinkAggregateJoinTransposeRule.

FlinkAggregateJoinTransposeRule

@Deprecated
public FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass,
                                       org.apache.calcite.rel.core.RelFactories.AggregateFactory aggregateFactory,
                                       Class<? extends org.apache.calcite.rel.core.Join> joinClass,
                                       org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory)

Deprecated.

FlinkAggregateJoinTransposeRule

@Deprecated
public FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass,
                                       org.apache.calcite.rel.core.RelFactories.AggregateFactory aggregateFactory,
                                       Class<? extends org.apache.calcite.rel.core.Join> joinClass,
                                       org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory,
                                       boolean allowFunctions)

Deprecated.

FlinkAggregateJoinTransposeRule

@Deprecated
public FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass,
                                       org.apache.calcite.rel.core.RelFactories.AggregateFactory aggregateFactory,
                                       Class<? extends org.apache.calcite.rel.core.Join> joinClass,
                                       org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory,
                                       org.apache.calcite.rel.core.RelFactories.ProjectFactory projectFactory)

Deprecated.

FlinkAggregateJoinTransposeRule

@Deprecated
public FlinkAggregateJoinTransposeRule(Class<? extends org.apache.calcite.rel.core.Aggregate> aggregateClass,
                                       org.apache.calcite.rel.core.RelFactories.AggregateFactory aggregateFactory,
                                       Class<? extends org.apache.calcite.rel.core.Join> joinClass,
                                       org.apache.calcite.rel.core.RelFactories.JoinFactory joinFactory,
                                       org.apache.calcite.rel.core.RelFactories.ProjectFactory projectFactory,
                                       boolean allowFunctions)

Deprecated.

Method Detail

matches

public boolean matches(org.apache.calcite.plan.RelOptRuleCall call)

Overrides:

matches in class org.apache.calcite.plan.RelOptRule

onMatch

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

Specified by:

onMatch in class org.apache.calcite.plan.RelOptRule