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

Class AsyncCalcSplitRule.AsyncCalcSplitNestedRule

java.lang.Object

<any>

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

Enclosing class:

AsyncCalcSplitRule

public static class AsyncCalcSplitRule.AsyncCalcSplitNestedRule
extends <any>

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

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)
SplitComponents	split(org.apache.calcite.rex.RexProgram program, ScalarFunctionSplitter splitter)

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncCalcSplitNestedRule

public AsyncCalcSplitNestedRule(RemoteCalcCallFinder callFinder)

Method Detail

matches

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

needConvert

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

split

public SplitComponents split(org.apache.calcite.rex.RexProgram program,
                             ScalarFunctionSplitter splitter)