public static class AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule extends org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitProjectionRuleBase<AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State>
For Example: Calc(select=[asyncCall(), asyncCall()]) -> Source
becomes
AsyncCalc(select=[asyncCall(), f0]) -> AsyncCalc(select=[asyncCall() as f0]) -> Source
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 and Description |
---|
AsyncCalcSplitOnePerCalcRule(org.apache.flink.table.planner.plan.rules.logical.RemoteCalcCallFinder callFinder) |
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) |
split
callFinder, equals, onMatch
any, convert, convert, convertList, convertOperand, convertOperand, equals, getOperand, getOperands, getOutConvention, getOutTrait, hashCode, none, operand, operand, operand, operand, operand, operandJ, operandJ, some, toString, unordered
public AsyncCalcSplitOnePerCalcRule(org.apache.flink.table.planner.plan.rules.logical.RemoteCalcCallFinder callFinder)
public boolean matches(org.apache.calcite.plan.RelOptRuleCall call)
matches
in class org.apache.calcite.plan.RelOptRule
public boolean needConvert(org.apache.calcite.rex.RexProgram program, org.apache.calcite.rex.RexNode node, scala.Option<AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State> matchState)
needConvert
in class org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase<AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State>
public scala.Option<AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State> getMatchState()
getMatchState
in class org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase<AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.