Uses of Class
org.apache.calcite.rel.core.CorrelationId
-
Packages that use CorrelationId Package Description org.apache.calcite.adapter.enumerable Query optimizer rules for Java calling convention.org.apache.calcite.adapter.jdbc Query provider based on a JDBC data source.org.apache.calcite.adapter.pig Pig query provider.org.apache.calcite.interpreter Provides an implementation of relational expressions using an interpreter.org.apache.calcite.plan Defines interfaces for constructing rule-based optimizers of relational expressions.org.apache.calcite.plan.volcano Optimizes relational expressions.org.apache.calcite.rel Defines relational expressions.org.apache.calcite.rel.core Defines core relational expressions.org.apache.calcite.rel.externalize Facilities to externalizeRelNode
s to and from XML and JSON format.org.apache.calcite.rel.logical Defines logical relational expressions.org.apache.calcite.rel.mutable Defines mutable relational expressions.org.apache.calcite.rel.rel2sql Translates a relational expression to SQL parse tree.org.apache.calcite.rel.rules Provides a core set of planner rules.org.apache.calcite.rex Provides a language for representing row-expressions.org.apache.calcite.sql2rel Translates a SQL parse tree to relational expression.org.apache.calcite.tools Provides utility classes. -
-
Uses of CorrelationId in org.apache.calcite.adapter.enumerable
Methods in org.apache.calcite.adapter.enumerable with parameters of type CorrelationId Modifier and Type Method Description EnumerableCorrelate
EnumerableCorrelate. copy(RelTraitSet traitSet, RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Method parameters in org.apache.calcite.adapter.enumerable with type arguments of type CorrelationId Modifier and Type Method Description static EnumerableJoin
EnumerableJoin. create(RelNode left, RelNode right, RexNode condition, ImmutableIntList leftKeys, ImmutableIntList rightKeys, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType)
Creates an EnumerableJoin.Constructors in org.apache.calcite.adapter.enumerable with parameters of type CorrelationId Constructor Description EnumerableCorrelate(RelOptCluster cluster, RelTraitSet traits, RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Constructor parameters in org.apache.calcite.adapter.enumerable with type arguments of type CorrelationId Constructor Description EnumerableJoin(RelOptCluster cluster, RelTraitSet traits, RelNode left, RelNode right, RexNode condition, ImmutableIntList leftKeys, ImmutableIntList rightKeys, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType)
Creates an EnumerableJoin.EnumerableMergeJoin(RelOptCluster cluster, RelTraitSet traits, RelNode left, RelNode right, RexNode condition, ImmutableIntList leftKeys, ImmutableIntList rightKeys, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType)
EnumerableThetaJoin(RelOptCluster cluster, RelTraitSet traits, RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType)
Creates an EnumerableThetaJoin. -
Uses of CorrelationId in org.apache.calcite.adapter.jdbc
Constructor parameters in org.apache.calcite.adapter.jdbc with type arguments of type CorrelationId Constructor Description JdbcJoin(RelOptCluster cluster, RelTraitSet traitSet, RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType)
Creates a JdbcJoin. -
Uses of CorrelationId in org.apache.calcite.adapter.pig
Method parameters in org.apache.calcite.adapter.pig with type arguments of type CorrelationId Modifier and Type Method Description RelNode
PigRelFactories.PigJoinFactory. createJoin(RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType, boolean semiJoinDone)
-
Uses of CorrelationId in org.apache.calcite.interpreter
Constructor parameters in org.apache.calcite.interpreter with type arguments of type CorrelationId Constructor Description BindableJoin(RelOptCluster cluster, RelTraitSet traitSet, RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType)
Creates a BindableJoin. -
Uses of CorrelationId in org.apache.calcite.plan
Fields in org.apache.calcite.plan with type parameters of type CorrelationId Modifier and Type Field Description com.google.common.collect.Multimap<CorrelationId,java.lang.Integer>
RelOptUtil.VariableUsedVisitor. variableFields
(package private) java.util.Set<CorrelationId>
RelOptUtil.VariableSetVisitor. variables
java.util.Set<CorrelationId>
RelOptUtil.VariableUsedVisitor. variables
Methods in org.apache.calcite.plan that return CorrelationId Modifier and Type Method Description CorrelationId
RelOptCluster. createCorrel()
Constructs a new id for a correlating variable.Methods in org.apache.calcite.plan that return types with arguments of type CorrelationId Modifier and Type Method Description static java.util.Set<CorrelationId>
RelOptUtil. getVariablesSet(RelNode rel)
Returns a list of variables set by a relational expression or its descendants.static java.util.List<CorrelationId>
RelOptUtil. getVariablesSetAndUsed(RelNode rel0, RelNode rel1)
Deprecated.static java.util.Set<CorrelationId>
RelOptUtil. getVariablesUsed(RelNode rel)
Returns a set of variables used by a relational expression or its descendants.Methods in org.apache.calcite.plan with parameters of type CorrelationId Modifier and Type Method Description static ImmutableBitSet
RelOptUtil. correlationColumns(CorrelationId id, RelNode rel)
Finds which columns of a correlation variable are used within a relational expression.static boolean
RelOptUtil. notContainsCorrelation(RelNode r, CorrelationId correlationId, Litmus litmus)
Returns true, and callsLitmus.succeed()
if a given relational expression does not contain a given correlation. -
Uses of CorrelationId in org.apache.calcite.plan.volcano
Fields in org.apache.calcite.plan.volcano with type parameters of type CorrelationId Modifier and Type Field Description (package private) java.util.Set<CorrelationId>
RelSet. variablesPropagated
Variables that are set by relational expressions in this set and available for use by parent and child expressions.(package private) java.util.Set<CorrelationId>
RelSet. variablesUsed
Variables that are used by relational expressions in this set.Method parameters in org.apache.calcite.plan.volcano with type arguments of type CorrelationId Modifier and Type Method Description void
RelSubset. collectVariablesSet(java.util.Set<CorrelationId> variableSet)
void
RelSubset. collectVariablesUsed(java.util.Set<CorrelationId> variableSet)
Constructor parameters in org.apache.calcite.plan.volcano with type arguments of type CorrelationId Constructor Description RelSet(int id, java.util.Set<CorrelationId> variablesPropagated, java.util.Set<CorrelationId> variablesUsed)
-
Uses of CorrelationId in org.apache.calcite.rel
Methods in org.apache.calcite.rel that return types with arguments of type CorrelationId Modifier and Type Method Description java.util.Set<CorrelationId>
RelNode.Context. correlationIds()
java.util.Set<CorrelationId>
AbstractRelNode. getVariablesSet()
java.util.Set<CorrelationId>
RelNode. getVariablesSet()
Returns the variables that are set in this relational expression but also used and therefore not available to parents of this relational expression.Method parameters in org.apache.calcite.rel with type arguments of type CorrelationId Modifier and Type Method Description void
AbstractRelNode. collectVariablesSet(java.util.Set<CorrelationId> variableSet)
void
RelNode. collectVariablesSet(java.util.Set<CorrelationId> variableSet)
Collects variables set by this expression.void
AbstractRelNode. collectVariablesUsed(java.util.Set<CorrelationId> variableSet)
void
RelNode. collectVariablesUsed(java.util.Set<CorrelationId> variableSet)
Collects variables known to be used by this expression or its descendants. -
Uses of CorrelationId in org.apache.calcite.rel.core
Fields in org.apache.calcite.rel.core declared as CorrelationId Modifier and Type Field Description protected CorrelationId
Correlate. correlationId
Fields in org.apache.calcite.rel.core with type parameters of type CorrelationId Modifier and Type Field Description protected com.google.common.collect.ImmutableSet<CorrelationId>
Join. variablesSet
Methods in org.apache.calcite.rel.core that return CorrelationId Modifier and Type Method Description CorrelationId
Correlate. getCorrelationId()
Returns the correlating expressions.Methods in org.apache.calcite.rel.core that return types with arguments of type CorrelationId Modifier and Type Method Description java.util.Set<CorrelationId>
Correlate. getVariablesSet()
java.util.Set<CorrelationId>
Join. getVariablesSet()
static com.google.common.collect.ImmutableSet<CorrelationId>
CorrelationId. setOf(java.util.Set<java.lang.String> set)
Converts a set of correlation ids to a set of names.Methods in org.apache.calcite.rel.core with parameters of type CorrelationId Modifier and Type Method Description int
CorrelationId. compareTo(CorrelationId other)
abstract Correlate
Correlate. copy(RelTraitSet traitSet, RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
RelNode
RelFactories.CorrelateFactory. createCorrelate(RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Creates a correlate.RelNode
RelFactories.CorrelateFactoryImpl. createCorrelate(RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Method parameters in org.apache.calcite.rel.core with type arguments of type CorrelationId Modifier and Type Method Description RelNode
RelFactories.JoinFactory. createJoin(RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType, boolean semiJoinDone)
Creates a join.RelNode
RelFactories.JoinFactoryImpl. createJoin(RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType, boolean semiJoinDone)
static java.util.Set<java.lang.String>
CorrelationId. names(java.util.Set<CorrelationId> set)
Converts a set of names to a set of correlation ids.Constructors in org.apache.calcite.rel.core with parameters of type CorrelationId Constructor Description Correlate(RelOptCluster cluster, RelTraitSet traits, RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Creates a Correlate.Constructor parameters in org.apache.calcite.rel.core with type arguments of type CorrelationId Constructor Description EquiJoin(RelOptCluster cluster, RelTraitSet traits, RelNode left, RelNode right, RexNode condition, ImmutableIntList leftKeys, ImmutableIntList rightKeys, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType)
Creates an EquiJoin.Join(RelOptCluster cluster, RelTraitSet traitSet, RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType)
Creates a Join. -
Uses of CorrelationId in org.apache.calcite.rel.externalize
Methods in org.apache.calcite.rel.externalize with parameters of type CorrelationId Modifier and Type Method Description private java.lang.Object
RelJson. toJson(CorrelationId node)
-
Uses of CorrelationId in org.apache.calcite.rel.logical
Fields in org.apache.calcite.rel.logical with type parameters of type CorrelationId Modifier and Type Field Description private com.google.common.collect.ImmutableSet<CorrelationId>
LogicalFilter. variablesSet
Methods in org.apache.calcite.rel.logical that return types with arguments of type CorrelationId Modifier and Type Method Description java.util.Set<CorrelationId>
LogicalFilter. getVariablesSet()
Methods in org.apache.calcite.rel.logical with parameters of type CorrelationId Modifier and Type Method Description LogicalCorrelate
LogicalCorrelate. copy(RelTraitSet traitSet, RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
static LogicalCorrelate
LogicalCorrelate. create(RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Creates a LogicalCorrelate.Method parameters in org.apache.calcite.rel.logical with type arguments of type CorrelationId Modifier and Type Method Description void
LogicalCalc. collectVariablesUsed(java.util.Set<CorrelationId> variableSet)
static LogicalFilter
LogicalFilter. create(RelNode input, RexNode condition, com.google.common.collect.ImmutableSet<CorrelationId> variablesSet)
Creates a LogicalFilter.static LogicalJoin
LogicalJoin. create(RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType)
Creates a LogicalJoin.static LogicalJoin
LogicalJoin. create(RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType, boolean semiJoinDone, com.google.common.collect.ImmutableList<RelDataTypeField> systemFieldList)
Creates a LogicalJoin, flagged with whether it has been translated to a semi-join.Constructors in org.apache.calcite.rel.logical with parameters of type CorrelationId Constructor Description LogicalCorrelate(RelOptCluster cluster, RelTraitSet traitSet, RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Creates a LogicalCorrelate.LogicalCorrelate(RelOptCluster cluster, RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Deprecated.Constructor parameters in org.apache.calcite.rel.logical with type arguments of type CorrelationId Constructor Description LogicalFilter(RelOptCluster cluster, RelTraitSet traitSet, RelNode child, RexNode condition, com.google.common.collect.ImmutableSet<CorrelationId> variablesSet)
Creates a LogicalFilter.LogicalJoin(RelOptCluster cluster, RelTraitSet traitSet, RelNode left, RelNode right, RexNode condition, java.util.Set<CorrelationId> variablesSet, JoinRelType joinType, boolean semiJoinDone, com.google.common.collect.ImmutableList<RelDataTypeField> systemFieldList)
Creates a LogicalJoin. -
Uses of CorrelationId in org.apache.calcite.rel.mutable
Fields in org.apache.calcite.rel.mutable declared as CorrelationId Modifier and Type Field Description CorrelationId
MutableCorrelate. correlationId
Fields in org.apache.calcite.rel.mutable with type parameters of type CorrelationId Modifier and Type Field Description java.util.Set<CorrelationId>
MutableJoin. variablesSet
Methods in org.apache.calcite.rel.mutable with parameters of type CorrelationId Modifier and Type Method Description static MutableCorrelate
MutableCorrelate. of(RelDataType rowType, MutableRel left, MutableRel right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Creates a MutableCorrelate.Method parameters in org.apache.calcite.rel.mutable with type arguments of type CorrelationId Modifier and Type Method Description static MutableJoin
MutableJoin. of(RelDataType rowType, MutableRel left, MutableRel right, RexNode condition, JoinRelType joinType, java.util.Set<CorrelationId> variablesStopped)
Creates a MutableJoin.Constructors in org.apache.calcite.rel.mutable with parameters of type CorrelationId Constructor Description MutableCorrelate(RelDataType rowType, MutableRel left, MutableRel right, CorrelationId correlationId, ImmutableBitSet requiredColumns, SemiJoinType joinType)
Constructor parameters in org.apache.calcite.rel.mutable with type arguments of type CorrelationId Constructor Description MutableJoin(RelDataType rowType, MutableRel left, MutableRel right, RexNode condition, JoinRelType joinType, java.util.Set<CorrelationId> variablesSet)
-
Uses of CorrelationId in org.apache.calcite.rel.rel2sql
Fields in org.apache.calcite.rel.rel2sql with type parameters of type CorrelationId Modifier and Type Field Description protected java.util.Map<CorrelationId,SqlImplementor.Context>
SqlImplementor. correlTableMap
-
Uses of CorrelationId in org.apache.calcite.rel.rules
Fields in org.apache.calcite.rel.rules declared as CorrelationId Modifier and Type Field Description private CorrelationId
ProjectCorrelateTransposeRule.RexFieldAccessReplacer. rexCorrelVariableToReplace
Method parameters in org.apache.calcite.rel.rules with type arguments of type CorrelationId Modifier and Type Method Description protected RexNode
SubQueryRemoveRule. apply(RexSubQuery e, java.util.Set<CorrelationId> variablesSet, RelOptUtil.Logic logic, RelBuilder builder, int inputCount, int offset)
private RexNode
SubQueryRemoveRule. rewriteExists(RexSubQuery e, java.util.Set<CorrelationId> variablesSet, RelOptUtil.Logic logic, RelBuilder builder)
Rewrites an EXISTS RexSubQuery into aJoin
.private RexNode
SubQueryRemoveRule. rewriteIn(RexSubQuery e, java.util.Set<CorrelationId> variablesSet, RelOptUtil.Logic logic, RelBuilder builder, int offset)
Rewrites an IN RexSubQuery into aJoin
.private RexNode
SubQueryRemoveRule. rewriteScalarQuery(RexSubQuery e, java.util.Set<CorrelationId> variablesSet, RelBuilder builder, int inputCount, int offset)
Rewrites a scalar sub-query into anAggregate
.Constructors in org.apache.calcite.rel.rules with parameters of type CorrelationId Constructor Description RexFieldAccessReplacer(CorrelationId rexCorrelVariableToReplace, RexCorrelVariable rexCorrelVariable, RexBuilder builder, java.util.Map<java.lang.Integer,java.lang.Integer> requiredColsMap)
-
Uses of CorrelationId in org.apache.calcite.rex
Fields in org.apache.calcite.rex declared as CorrelationId Modifier and Type Field Description CorrelationId
RexCorrelVariable. id
Methods in org.apache.calcite.rex with parameters of type CorrelationId Modifier and Type Method Description RexNode
RexBuilder. makeCorrel(RelDataType type, CorrelationId id)
Creates an expression referencing a correlation variable.Constructors in org.apache.calcite.rex with parameters of type CorrelationId Constructor Description RexCorrelVariable(CorrelationId id, RelDataType type)
-
Uses of CorrelationId in org.apache.calcite.sql2rel
Fields in org.apache.calcite.sql2rel declared as CorrelationId Modifier and Type Field Description private CorrelationId
DeduplicateCorrelateVariables.DeduplicateCorrelateVariablesShuttle. canonicalId
CorrelationId
RelDecorrelator.CorDef. corr
CorrelationId
RelDecorrelator.CorRef. corr
private CorrelationId
SqlToRelConverter.CorrelationUse. id
Fields in org.apache.calcite.sql2rel with type parameters of type CorrelationId Modifier and Type Field Description private com.google.common.collect.ImmutableSet<CorrelationId>
DeduplicateCorrelateVariables.DeduplicateCorrelateVariablesShuttle. alternateIds
private java.util.Map<CorrelationId,RexFieldAccess>
SqlToRelConverter.Blackboard. mapCorrelateToRex
private java.util.Map<CorrelationId,SqlToRelConverter.DeferredLookup>
SqlToRelConverter. mapCorrelToDeferred
Fields used in name resolution for correlated sub-queries.private java.util.SortedMap<CorrelationId,RelNode>
RelDecorrelator.CorelMap. mapCorToCorRel
(package private) java.util.SortedMap<CorrelationId,RelNode>
RelDecorrelator.CorelMapBuilder. mapCorToCorRel
Methods in org.apache.calcite.sql2rel with parameters of type CorrelationId Modifier and Type Method Description RexFieldAccess
SqlToRelConverter.DeferredLookup. getFieldAccess(CorrelationId name)
static RelNode
DeduplicateCorrelateVariables. go(RexBuilder builder, CorrelationId canonicalId, java.lang.Iterable<? extends CorrelationId> alternateIds, RelNode r)
Rewrites a relational expression, replacing alternate correlation variables with a canonical correlation variable.Method parameters in org.apache.calcite.sql2rel with type arguments of type CorrelationId Modifier and Type Method Description static RelNode
DeduplicateCorrelateVariables. go(RexBuilder builder, CorrelationId canonicalId, java.lang.Iterable<? extends CorrelationId> alternateIds, RelNode r)
Rewrites a relational expression, replacing alternate correlation variables with a canonical correlation variable.static RelDecorrelator.CorelMap
RelDecorrelator.CorelMap. of(com.google.common.collect.SortedSetMultimap<RelNode,RelDecorrelator.CorRef> mapRefRelToCorVar, java.util.SortedMap<CorrelationId,RelNode> mapCorToCorRel, java.util.Map<RexFieldAccess,RelDecorrelator.CorRef> mapFieldAccessToCorVar)
Creates a CorelMap with given contents.void
RelStructuredTypeFlattener. updateRelInMap(com.google.common.collect.SortedSetMultimap<RelNode,CorrelationId> mapRefRelToCorVar)
void
RelStructuredTypeFlattener. updateRelInMap(java.util.SortedMap<CorrelationId,LogicalCorrelate> mapCorVarToCorRel)
Constructors in org.apache.calcite.sql2rel with parameters of type CorrelationId Constructor Description CorDef(CorrelationId corr, int field)
CorRef(CorrelationId corr, int field, int uniqueKey)
CorrelationUse(CorrelationId id, ImmutableBitSet requiredColumns, RelNode r)
DeduplicateCorrelateVariables(RexBuilder builder, CorrelationId canonicalId, com.google.common.collect.ImmutableSet<CorrelationId> alternateIds)
Creates a DeduplicateCorrelateVariables.DeduplicateCorrelateVariablesShuttle(RexBuilder builder, CorrelationId canonicalId, com.google.common.collect.ImmutableSet<CorrelationId> alternateIds, DeduplicateCorrelateVariables shuttle)
Constructor parameters in org.apache.calcite.sql2rel with type arguments of type CorrelationId Constructor Description CorelMap(com.google.common.collect.Multimap<RelNode,RelDecorrelator.CorRef> mapRefRelToCorRef, java.util.SortedMap<CorrelationId,RelNode> mapCorToCorRel, java.util.Map<RexFieldAccess,RelDecorrelator.CorRef> mapFieldAccessToCorRef)
DeduplicateCorrelateVariables(RexBuilder builder, CorrelationId canonicalId, com.google.common.collect.ImmutableSet<CorrelationId> alternateIds)
Creates a DeduplicateCorrelateVariables.DeduplicateCorrelateVariablesShuttle(RexBuilder builder, CorrelationId canonicalId, com.google.common.collect.ImmutableSet<CorrelationId> alternateIds, DeduplicateCorrelateVariables shuttle)
-
Uses of CorrelationId in org.apache.calcite.tools
Fields in org.apache.calcite.tools declared as CorrelationId Modifier and Type Field Description private CorrelationId
RelBuilder.Shifter. id
Method parameters in org.apache.calcite.tools with type arguments of type CorrelationId Modifier and Type Method Description RelBuilder
RelBuilder. join(JoinRelType joinType, RexNode condition, java.util.Set<CorrelationId> variablesSet)
Creates aJoin
with correlating variables.Constructors in org.apache.calcite.tools with parameters of type CorrelationId Constructor Description Shifter(RelNode left, CorrelationId id, RelNode right)
-