org.apache.calcite.sql2rel

Class RelDecorrelator

java.lang.Object

org.apache.calcite.sql2rel.RelDecorrelator

All Implemented Interfaces:

org.apache.calcite.util.ReflectiveVisitor

public class RelDecorrelator
extends Object
implements org.apache.calcite.util.ReflectiveVisitor

Copied to fix CALCITE-4333, should be removed for the next Calcite upgrade.

Changes: Line 671 ~ Line 681, Line 430 ~ Line 441.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RelDecorrelator.AdjustProjectForCountAggregateRule Planner rule that adjusts projects when counts are added.
static interface	RelDecorrelator.Config Base configuration for rules that are non-static in a RelDecorrelator.
protected static class	RelDecorrelator.CorelMap A map of the locations of Correlate in a tree of RelNodes.
static class	RelDecorrelator.CorelMapBuilder Builds a RelDecorrelator.CorelMap.
static class	RelDecorrelator.RemoveCorrelationForScalarAggregateRule Planner rule that removes correlations for scalar aggregates.
static class	RelDecorrelator.RemoveCorrelationForScalarProjectRule Planner rule that removes correlations for scalar projects.
static class	RelDecorrelator.RemoveSingleAggregateRule Rule to remove single_value rel.

Field Summary

Fields

Modifier and Type	Field and Description
protected RelDecorrelator.CorelMap	cm

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RelDecorrelator(RelDecorrelator.CorelMap cm, org.apache.calcite.plan.Context context, org.apache.calcite.tools.RelBuilder relBuilder)

Method Summary

Modifier and Type	Method and Description
protected org.apache.calcite.rel.RelNode	decorrelate(org.apache.calcite.rel.RelNode root)
protected org.apache.calcite.rex.RexNode	decorrelateExpr(org.apache.calcite.rel.RelNode currentRel, Map<org.apache.calcite.rel.RelNode,org.apache.calcite.sql2rel.RelDecorrelator.Frame> map, RelDecorrelator.CorelMap cm, org.apache.calcite.rex.RexNode exp)
static org.apache.calcite.rel.RelNode	decorrelateQuery(org.apache.calcite.rel.RelNode rootRel) Deprecated.
static org.apache.calcite.rel.RelNode	decorrelateQuery(org.apache.calcite.rel.RelNode rootRel, org.apache.calcite.tools.RelBuilder relBuilder) Decorrelates a query.
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.core.Aggregate rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.core.Correlate rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.core.Filter rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.core.Join rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.logical.LogicalAggregate rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.logical.LogicalCorrelate rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.logical.LogicalFilter rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.logical.LogicalJoin rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.logical.LogicalProject rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.logical.LogicalSnapshot rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.logical.LogicalTableFunctionScan rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.core.Project rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.RelNode rel) Fallback if none of the other decorrelateRel methods match.
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.core.Sort rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	decorrelateRel(org.apache.calcite.rel.core.Values rel)
org.apache.calcite.sql2rel.RelDecorrelator.Frame	getInvoke(org.apache.calcite.rel.RelNode r, org.apache.calcite.rel.RelNode parent)
protected org.apache.calcite.tools.RelBuilderFactory	relBuilderFactory()
protected org.apache.calcite.rex.RexNode	removeCorrelationExpr(org.apache.calcite.rex.RexNode exp, boolean projectPulledAboveLeftCorrelator)
protected org.apache.calcite.rex.RexNode	removeCorrelationExpr(org.apache.calcite.rex.RexNode exp, boolean projectPulledAboveLeftCorrelator, org.apache.calcite.rex.RexInputRef nullIndicator)
protected org.apache.calcite.rex.RexNode	removeCorrelationExpr(org.apache.calcite.rex.RexNode exp, boolean projectPulledAboveLeftCorrelator, Set<Integer> isCount)
org.apache.calcite.rel.RelNode	removeCorrelationViaRule(org.apache.calcite.rel.RelNode root)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

cm

protected RelDecorrelator.CorelMap cm

Constructor Detail

RelDecorrelator

protected RelDecorrelator(RelDecorrelator.CorelMap cm,
                          org.apache.calcite.plan.Context context,
                          org.apache.calcite.tools.RelBuilder relBuilder)

Method Detail

decorrelateQuery

@Deprecated
public static org.apache.calcite.rel.RelNode decorrelateQuery(org.apache.calcite.rel.RelNode rootRel)

Deprecated.

decorrelateQuery

public static org.apache.calcite.rel.RelNode decorrelateQuery(org.apache.calcite.rel.RelNode rootRel,
                                                              org.apache.calcite.tools.RelBuilder relBuilder)

Decorrelates a query.

This is the main entry point to RelDecorrelator.

Parameters:

rootRel - Root node of the query

relBuilder - Builder for relational expressions

Returns:

Equivalent query with all Correlate instances removed

relBuilderFactory

protected org.apache.calcite.tools.RelBuilderFactory relBuilderFactory()

decorrelate

protected org.apache.calcite.rel.RelNode decorrelate(org.apache.calcite.rel.RelNode root)

removeCorrelationViaRule

public org.apache.calcite.rel.RelNode removeCorrelationViaRule(org.apache.calcite.rel.RelNode root)

decorrelateExpr

protected org.apache.calcite.rex.RexNode decorrelateExpr(org.apache.calcite.rel.RelNode currentRel,
                                                         Map<org.apache.calcite.rel.RelNode,org.apache.calcite.sql2rel.RelDecorrelator.Frame> map,
                                                         RelDecorrelator.CorelMap cm,
                                                         org.apache.calcite.rex.RexNode exp)

removeCorrelationExpr

protected org.apache.calcite.rex.RexNode removeCorrelationExpr(org.apache.calcite.rex.RexNode exp,
                                                               boolean projectPulledAboveLeftCorrelator)

removeCorrelationExpr

protected org.apache.calcite.rex.RexNode removeCorrelationExpr(org.apache.calcite.rex.RexNode exp,
                                                               boolean projectPulledAboveLeftCorrelator,
                                                               org.apache.calcite.rex.RexInputRef nullIndicator)

removeCorrelationExpr

protected org.apache.calcite.rex.RexNode removeCorrelationExpr(org.apache.calcite.rex.RexNode exp,
                                                               boolean projectPulledAboveLeftCorrelator,
                                                               Set<Integer> isCount)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.RelNode rel)

Fallback if none of the other decorrelateRel methods match.

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.core.Sort rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.core.Values rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.logical.LogicalAggregate rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.core.Aggregate rel)

getInvoke

public org.apache.calcite.sql2rel.RelDecorrelator.Frame getInvoke(org.apache.calcite.rel.RelNode r,
                                                                  org.apache.calcite.rel.RelNode parent)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.logical.LogicalProject rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.core.Project rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.logical.LogicalSnapshot rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.logical.LogicalTableFunctionScan rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.logical.LogicalFilter rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.core.Filter rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.logical.LogicalCorrelate rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.core.Correlate rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.logical.LogicalJoin rel)

decorrelateRel

public org.apache.calcite.sql2rel.RelDecorrelator.Frame decorrelateRel(org.apache.calcite.rel.core.Join rel)