Package org.apache.flink.table.planner.plan.utils

Class AsyncUtil

java.lang.Object

org.apache.flink.table.planner.plan.utils.AsyncUtil

public class AsyncUtil
extends Object

Contains utilities for AsyncScalarFunction.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncUtil.Options	Options for configuring async behavior.

Constructor Summary

Constructors

Constructor	Description
AsyncUtil()

Method Summary

Modifier and Type	Method	Description
static boolean	containsAsyncCall(org.apache.calcite.rex.RexNode node)	Checks whether it contains the specified kind of async function call in the specified node.
static boolean	containsNonAsyncCall(org.apache.calcite.rex.RexNode node)	Checks whether it contains non-async function call in the specified node.
static AsyncUtil.Options	getAsyncOptions(ExecNodeConfig config)	Gets the options required to run the operator.
static boolean	isAsyncCall(org.apache.calcite.rex.RexNode node)	Checks whether the specified node is the specified kind of async function call.
static boolean	isNonAsyncCall(org.apache.calcite.rex.RexNode node)	Checks whether the specified node is a non-async function call.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncUtil

public AsyncUtil()

Method Detail

containsAsyncCall

public static boolean containsAsyncCall(org.apache.calcite.rex.RexNode node)

Checks whether it contains the specified kind of async function call in the specified node.

Parameters:

node - the RexNode to check

Returns:

true if it contains an async function call in the specified node.

containsNonAsyncCall

public static boolean containsNonAsyncCall(org.apache.calcite.rex.RexNode node)

Checks whether it contains non-async function call in the specified node.

Parameters:

node - the RexNode to check

Returns:

true if it contains a non-async function call in the specified node.

isAsyncCall

public static boolean isAsyncCall(org.apache.calcite.rex.RexNode node)

Checks whether the specified node is the specified kind of async function call.

Parameters:

node - the RexNode to check

Returns:

true if the specified node is an async function call.

isNonAsyncCall

public static boolean isNonAsyncCall(org.apache.calcite.rex.RexNode node)

Checks whether the specified node is a non-async function call.

Parameters:

node - the RexNode to check

Returns:

true if the specified node is a non-async function call.

getAsyncOptions

public static AsyncUtil.Options getAsyncOptions(ExecNodeConfig config)

Gets the options required to run the operator.

Parameters:

config - The config from which to fetch the options

Returns:

Extracted options