Class AsyncCalcSplitRule.AsyncRemoteCalcCallFinder
- java.lang.Object
-
- org.apache.flink.table.planner.plan.rules.logical.AsyncCalcSplitRule.AsyncRemoteCalcCallFinder
-
- All Implemented Interfaces:
RemoteCalcCallFinder
- Enclosing class:
- AsyncCalcSplitRule
public static class AsyncCalcSplitRule.AsyncRemoteCalcCallFinder extends Object implements RemoteCalcCallFinder
An Async implementation ofRemoteCalcCallFinder
which finds uses ofAsyncScalarFunction
.
-
-
Constructor Summary
Constructors Constructor Description AsyncRemoteCalcCallFinder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
containsNonRemoteCall(org.apache.calcite.rex.RexNode node)
boolean
containsRemoteCall(org.apache.calcite.rex.RexNode node)
boolean
isNonRemoteCall(org.apache.calcite.rex.RexNode node)
boolean
isRemoteCall(org.apache.calcite.rex.RexNode node)
-
-
-
Method Detail
-
containsRemoteCall
public boolean containsRemoteCall(org.apache.calcite.rex.RexNode node)
- Specified by:
containsRemoteCall
in interfaceRemoteCalcCallFinder
-
containsNonRemoteCall
public boolean containsNonRemoteCall(org.apache.calcite.rex.RexNode node)
- Specified by:
containsNonRemoteCall
in interfaceRemoteCalcCallFinder
-
isRemoteCall
public boolean isRemoteCall(org.apache.calcite.rex.RexNode node)
- Specified by:
isRemoteCall
in interfaceRemoteCalcCallFinder
-
isNonRemoteCall
public boolean isNonRemoteCall(org.apache.calcite.rex.RexNode node)
- Specified by:
isNonRemoteCall
in interfaceRemoteCalcCallFinder
-
-