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

Class AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule

java.lang.Object

<any>

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

Enclosing class:

AsyncCalcSplitRule

public static class AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule
extends <any>

Splits async calls if there are multiple across projections, so that there's one per calc. This assumes that the nested rule has been run first, so there is just one per projection.

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

becomes

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State State object used to keep track of whether a match has been found yet.

Constructor Summary

Constructors

Constructor and Description
AsyncCalcSplitOnePerCalcRule(RemoteCalcCallFinder callFinder)

Method Summary

Modifier and Type	Method and Description
scala.Option<AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State>	getMatchState()
boolean	matches(org.apache.calcite.plan.RelOptRuleCall call)
boolean	needConvert(org.apache.calcite.rex.RexProgram program, org.apache.calcite.rex.RexNode node, scala.Option<AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State> matchState)

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncCalcSplitOnePerCalcRule

public AsyncCalcSplitOnePerCalcRule(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<AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State> matchState)

getMatchState

public scala.Option<AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State> getMatchState()