org.apache.hadoop.hive.ql.optimizer.calcite.rules

Class HiveSubQueryRemoveRule

java.lang.Object

org.apache.calcite.plan.RelOptRule

org.apache.hadoop.hive.ql.optimizer.calcite.rules.HiveSubQueryRemoveRule

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

NOTE: this rule is replicated from Calcite's SubqueryRemoveRule Transform that converts IN, EXISTS and scalar sub-queries into joins. TODO: Reason this is replicated instead of using Calcite's is Calcite creates null literal with null type but hive needs it to be properly typed

Sub-queries are represented by RexSubQuery expressions.

A sub-query may or may not be correlated. If a sub-query is correlated, the wrapped RelNode will contain a RexCorrelVariable before the rewrite, and the product of the rewrite will be a Correlate. The Correlate can be removed using RelDecorrelator.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveSubQueryRemoveRule.HiveSubQueryFinder Visitor that throws Util.FoundOne if applied to an expression that contains a RexSubQuery.

Field Summary

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

description, operands, relBuilderFactory

Constructor Summary

Constructors

Constructor and Description
HiveSubQueryRemoveRule(HiveConf conf)

Method Summary

Modifier and Type	Method and Description
protected org.apache.calcite.rex.RexNode	apply(org.apache.calcite.rex.RexSubQuery e, Set<org.apache.calcite.rel.core.CorrelationId> variablesSet, org.apache.calcite.plan.RelOptUtil.Logic logic, HiveSubQRemoveRelBuilder builder, int inputCount, int offset, boolean isCorrScalarAgg, boolean hasNoWindowingAndNoGby)
void	onMatch(org.apache.calcite.plan.RelOptRuleCall call)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveSubQueryRemoveRule

public HiveSubQueryRemoveRule(HiveConf conf)

Method Detail

onMatch

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

Specified by:

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

apply

protected org.apache.calcite.rex.RexNode apply(org.apache.calcite.rex.RexSubQuery e,
                                               Set<org.apache.calcite.rel.core.CorrelationId> variablesSet,
                                               org.apache.calcite.plan.RelOptUtil.Logic logic,
                                               HiveSubQRemoveRelBuilder builder,
                                               int inputCount,
                                               int offset,
                                               boolean isCorrScalarAgg,
                                               boolean hasNoWindowingAndNoGby)