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.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.
|
Modifier and Type | Method and Description |
---|---|
EnumerableCorrelate |
EnumerableCorrelate.copy(RelTraitSet traitSet,
RelNode left,
RelNode right,
CorrelationId correlationId,
ImmutableBitSet requiredColumns,
SemiJoinType joinType) |
Modifier and Type | Method and Description |
---|---|
static EnumerableJoin |
EnumerableJoin.create(RelNode left,
RelNode right,
RexNode condition,
ImmutableIntList leftKeys,
ImmutableIntList rightKeys,
Set<CorrelationId> variablesSet,
JoinRelType joinType)
Creates an EnumerableJoin.
|
Constructor and Description |
---|
EnumerableCorrelate(RelOptCluster cluster,
RelTraitSet traits,
RelNode left,
RelNode right,
CorrelationId correlationId,
ImmutableBitSet requiredColumns,
SemiJoinType joinType) |
Constructor and Description |
---|
EnumerableJoin(RelOptCluster cluster,
RelTraitSet traits,
RelNode left,
RelNode right,
RexNode condition,
ImmutableIntList leftKeys,
ImmutableIntList rightKeys,
Set<CorrelationId> variablesSet,
JoinRelType joinType)
Creates an EnumerableJoin.
|
EnumerableThetaJoin(RelOptCluster cluster,
RelTraitSet traits,
RelNode left,
RelNode right,
RexNode condition,
Set<CorrelationId> variablesSet,
JoinRelType joinType)
Creates an EnumerableThetaJoin.
|
Constructor and Description |
---|
JdbcJoin(RelOptCluster cluster,
RelTraitSet traitSet,
RelNode left,
RelNode right,
RexNode condition,
Set<CorrelationId> variablesSet,
JoinRelType joinType)
Creates a JdbcJoin.
|
Modifier and Type | Method and Description |
---|---|
RelNode |
PigRelFactories.PigJoinFactory.createJoin(RelNode left,
RelNode right,
RexNode condition,
Set<CorrelationId> variablesSet,
JoinRelType joinType,
boolean semiJoinDone) |
Constructor and Description |
---|
BindableJoin(RelOptCluster cluster,
RelTraitSet traitSet,
RelNode left,
RelNode right,
RexNode condition,
Set<CorrelationId> variablesSet,
JoinRelType joinType)
Creates a BindableJoin.
|
Modifier and Type | Field and Description |
---|---|
com.google.common.collect.Multimap<CorrelationId,Integer> |
RelOptUtil.VariableUsedVisitor.variableFields |
Set<CorrelationId> |
RelOptUtil.VariableUsedVisitor.variables |
Modifier and Type | Method and Description |
---|---|
CorrelationId |
RelOptCluster.createCorrel()
Constructs a new id for a correlating variable.
|
Modifier and Type | Method and Description |
---|---|
static Set<CorrelationId> |
RelOptUtil.getVariablesSet(RelNode rel)
Returns a list of variables set by a relational expression or its
descendants.
|
static List<CorrelationId> |
RelOptUtil.getVariablesSetAndUsed(RelNode rel0,
RelNode rel1)
Deprecated.
|
static Set<CorrelationId> |
RelOptUtil.getVariablesUsed(RelNode rel)
Returns a set of variables used by a relational expression or its
descendants.
|
Modifier and Type | Method and 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 calls
Litmus.succeed() if a given relational
expression does not contain a given correlation. |
Modifier and Type | Method and Description |
---|---|
void |
RelSubset.collectVariablesSet(Set<CorrelationId> variableSet) |
void |
RelSubset.collectVariablesUsed(Set<CorrelationId> variableSet) |
Modifier and Type | Method and Description |
---|---|
Set<CorrelationId> |
RelNode.Context.correlationIds() |
Set<CorrelationId> |
AbstractRelNode.getVariablesSet() |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractRelNode.collectVariablesSet(Set<CorrelationId> variableSet) |
void |
RelNode.collectVariablesSet(Set<CorrelationId> variableSet)
Collects variables set by this expression.
|
void |
AbstractRelNode.collectVariablesUsed(Set<CorrelationId> variableSet) |
void |
RelNode.collectVariablesUsed(Set<CorrelationId> variableSet)
Collects variables known to be used by this expression or its
descendants.
|
Modifier and Type | Field and Description |
---|---|
protected CorrelationId |
Correlate.correlationId |
Modifier and Type | Field and Description |
---|---|
protected com.google.common.collect.ImmutableSet<CorrelationId> |
Join.variablesSet |
Modifier and Type | Method and Description |
---|---|
CorrelationId |
Correlate.getCorrelationId()
Returns the correlating expressions.
|
Modifier and Type | Method and Description |
---|---|
Set<CorrelationId> |
Join.getVariablesSet() |
Set<CorrelationId> |
Correlate.getVariablesSet() |
static com.google.common.collect.ImmutableSet<CorrelationId> |
CorrelationId.setOf(Set<String> set)
Converts a set of correlation ids to a set of names.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
RelNode |
RelFactories.JoinFactory.createJoin(RelNode left,
RelNode right,
RexNode condition,
Set<CorrelationId> variablesSet,
JoinRelType joinType,
boolean semiJoinDone)
Creates a join.
|
static Set<String> |
CorrelationId.names(Set<CorrelationId> set)
Converts a set of names to a set of correlation ids.
|
Constructor and Description |
---|
Correlate(RelOptCluster cluster,
RelTraitSet traits,
RelNode left,
RelNode right,
CorrelationId correlationId,
ImmutableBitSet requiredColumns,
SemiJoinType joinType)
Creates a Correlate.
|
Constructor and Description |
---|
EquiJoin(RelOptCluster cluster,
RelTraitSet traits,
RelNode left,
RelNode right,
RexNode condition,
ImmutableIntList leftKeys,
ImmutableIntList rightKeys,
Set<CorrelationId> variablesSet,
JoinRelType joinType)
Creates an EquiJoin.
|
Join(RelOptCluster cluster,
RelTraitSet traitSet,
RelNode left,
RelNode right,
RexNode condition,
Set<CorrelationId> variablesSet,
JoinRelType joinType)
Creates a Join.
|
Modifier and Type | Method and Description |
---|---|
Set<CorrelationId> |
LogicalFilter.getVariablesSet() |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
void |
LogicalCalc.collectVariablesUsed(Set<CorrelationId> variableSet) |
static LogicalJoin |
LogicalJoin.create(RelNode left,
RelNode right,
RexNode condition,
Set<CorrelationId> variablesSet,
JoinRelType joinType)
Creates a LogicalJoin.
|
static LogicalJoin |
LogicalJoin.create(RelNode left,
RelNode right,
RexNode condition,
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.
|
static LogicalFilter |
LogicalFilter.create(RelNode input,
RexNode condition,
com.google.common.collect.ImmutableSet<CorrelationId> variablesSet)
Creates a LogicalFilter.
|
Constructor and Description |
---|
LogicalCorrelate(RelOptCluster cluster,
RelNode left,
RelNode right,
CorrelationId correlationId,
ImmutableBitSet requiredColumns,
SemiJoinType joinType)
Deprecated.
|
LogicalCorrelate(RelOptCluster cluster,
RelTraitSet traitSet,
RelNode left,
RelNode right,
CorrelationId correlationId,
ImmutableBitSet requiredColumns,
SemiJoinType joinType)
Creates a LogicalCorrelate.
|
Constructor and 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,
Set<CorrelationId> variablesSet,
JoinRelType joinType,
boolean semiJoinDone,
com.google.common.collect.ImmutableList<RelDataTypeField> systemFieldList)
Creates a LogicalJoin.
|
Modifier and Type | Field and Description |
---|---|
CorrelationId |
MutableCorrelate.correlationId |
Modifier and Type | Field and Description |
---|---|
Set<CorrelationId> |
MutableJoin.variablesSet |
Modifier and Type | Method and Description |
---|---|
static MutableCorrelate |
MutableCorrelate.of(RelDataType rowType,
MutableRel left,
MutableRel right,
CorrelationId correlationId,
ImmutableBitSet requiredColumns,
SemiJoinType joinType)
Creates a MutableCorrelate.
|
Modifier and Type | Method and Description |
---|---|
static MutableJoin |
MutableJoin.of(RelDataType rowType,
MutableRel left,
MutableRel right,
RexNode condition,
JoinRelType joinType,
Set<CorrelationId> variablesStopped)
Creates a MutableJoin.
|
Modifier and Type | Field and Description |
---|---|
protected Map<CorrelationId,SqlImplementor.Context> |
SqlImplementor.correlTableMap |
Modifier and Type | Method and Description |
---|---|
protected RexNode |
SubQueryRemoveRule.apply(RexSubQuery e,
Set<CorrelationId> variablesSet,
RelOptUtil.Logic logic,
RelBuilder builder,
int inputCount,
int offset) |
Modifier and Type | Field and Description |
---|---|
CorrelationId |
RexCorrelVariable.id |
Modifier and Type | Method and Description |
---|---|
RexNode |
RexBuilder.makeCorrel(RelDataType type,
CorrelationId id)
Creates an expression referencing a correlation variable.
|
Modifier and Type | Method and Description |
---|---|
static RelNode |
DeduplicateCorrelateVariables.go(RexBuilder builder,
CorrelationId canonicalId,
Iterable<? extends CorrelationId> alternateIds,
RelNode r)
Rewrites a relational expression, replacing alternate correlation variables
with a canonical correlation variable.
|
Modifier and Type | Method and Description |
---|---|
static RelNode |
DeduplicateCorrelateVariables.go(RexBuilder builder,
CorrelationId canonicalId,
Iterable<? extends CorrelationId> alternateIds,
RelNode r)
Rewrites a relational expression, replacing alternate correlation variables
with a canonical correlation variable.
|
void |
RelStructuredTypeFlattener.updateRelInMap(SortedMap<CorrelationId,LogicalCorrelate> mapCorVarToCorRel) |
void |
RelStructuredTypeFlattener.updateRelInMap(com.google.common.collect.SortedSetMultimap<RelNode,CorrelationId> mapRefRelToCorVar) |
Modifier and Type | Method and Description |
---|---|
RelBuilder |
RelBuilder.join(JoinRelType joinType,
RexNode condition,
Set<CorrelationId> variablesSet)
Creates a
Join with correlating
variables. |
Copyright © 2012–2018 The Apache Software Foundation. All rights reserved.