public static class AsyncCalcSplitRule.AsyncCalcSplitNestedRule extends org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase<Void>
For Example: Calc(select=[syncCall(asyncCall()]) -> Source
becomes
Calc(select=[syncCall(f0)]) -> AsyncCalc(select=[asyncCall() as f0]) -> Source
Constructor and Description |
---|
AsyncCalcSplitNestedRule(org.apache.flink.table.planner.plan.rules.logical.RemoteCalcCallFinder callFinder) |
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) |
callFinder, equals, getMatchState, 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 AsyncCalcSplitNestedRule(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<Void> matchState)
needConvert
in class org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase<Void>
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)
split
in class org.apache.flink.table.planner.plan.rules.logical.RemoteCalcSplitRuleBase<Void>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.