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

Class AsyncCalcSplitRule.AsyncCalcSplitNestedRule

java.lang.Object

org.apache.calcite.plan.RelOptRule

org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase<Void>

org.apache.flink.table.planner.plan.rules.logical.AsyncCalcSplitRule.AsyncCalcSplitNestedRule

Enclosing class:

AsyncCalcSplitRule

public static class AsyncCalcSplitRule.AsyncCalcSplitNestedRule
extends org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase<Void>

Splits nested call <- asyncCall chains so that nothing is immediately waiting on an async call in a single calc.

For Example: Calc(select=[syncCall(asyncCall()]) -> Source

becomes

Calc(select=[syncCall(f0)]) -> AsyncCalc(select=[asyncCall() as f0]) -> Source

Nested Class Summary

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

org.apache.calcite.plan.RelOptRule.ConverterRelOptRuleOperand

Field Summary

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

description, operands, relBuilderFactory

Constructor Summary

Constructors

Constructor and Description
AsyncCalcSplitNestedRule(RemoteCalcCallFinder callFinder)

Method Summary

Modifier and Type	Method and Description
boolean	matches(org.apache.calcite.plan.RelOptRuleCall call)
boolean	needConvert(org.apache.calcite.rex.RexProgram program, org.apache.calcite.rex.RexNode node, scala.Option<Void> matchState)
org.apache.flink.table.planner.plan.rules.logical.SplitComponents	split(org.apache.calcite.rex.RexProgram program, org.apache.flink.table.planner.plan.rules.logical.ScalarFunctionSplitter splitter)

Methods inherited from class org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase

callFinder, equals, getMatchState, onMatch

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

any, convert, convert, convertList, convertOperand, convertOperand, 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

Constructor Detail

AsyncCalcSplitNestedRule

public AsyncCalcSplitNestedRule(RemoteCalcCallFinder callFinder)

Method Detail

matches

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

Overrides:

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

needConvert

public boolean needConvert(org.apache.calcite.rex.RexProgram program,
                           org.apache.calcite.rex.RexNode node,
                           scala.Option<Void> matchState)

Specified by:

needConvert in class org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase<Void>

split

public org.apache.flink.table.planner.plan.rules.logical.SplitComponents split(org.apache.calcite.rex.RexProgram program,
                                                                               org.apache.flink.table.planner.plan.rules.logical.ScalarFunctionSplitter splitter)

Specified by:

split in class org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase<Void>