public static class AsyncCalcSplitRule.AsyncRemoteCalcCallFinder extends Object implements org.apache.flink.table.planner.plan.rules.logical.RemoteCalcCallFinder
RemoteCalcCallFinder
which finds uses of AsyncScalarFunction
.Constructor and Description |
---|
AsyncRemoteCalcCallFinder() |
Modifier and Type | Method and 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) |
public boolean containsRemoteCall(org.apache.calcite.rex.RexNode node)
containsRemoteCall
in interface org.apache.flink.table.planner.plan.rules.logical.RemoteCalcCallFinder
public boolean containsNonRemoteCall(org.apache.calcite.rex.RexNode node)
containsNonRemoteCall
in interface org.apache.flink.table.planner.plan.rules.logical.RemoteCalcCallFinder
public boolean isRemoteCall(org.apache.calcite.rex.RexNode node)
isRemoteCall
in interface org.apache.flink.table.planner.plan.rules.logical.RemoteCalcCallFinder
public boolean isNonRemoteCall(org.apache.calcite.rex.RexNode node)
isNonRemoteCall
in interface org.apache.flink.table.planner.plan.rules.logical.RemoteCalcCallFinder
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.