org.apache.flink.table.planner.codegen

Class AsyncCodeGenerator

java.lang.Object

org.apache.flink.table.planner.codegen.AsyncCodeGenerator

public class AsyncCodeGenerator
extends Object

Generates an AsyncFunction which can be used to evaluate calc projections from an async scalar function.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_DELEGATING_FUTURE_TERM
static String	DEFAULT_EXCEPTION_TERM

Constructor Summary

Constructors

Constructor and Description
AsyncCodeGenerator()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.table.runtime.generated.GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>>	generateFunction(String name, org.apache.flink.table.types.logical.RowType inputType, org.apache.flink.table.types.logical.RowType returnType, List<org.apache.calcite.rex.RexNode> calcProjection, boolean retainHeader, org.apache.flink.configuration.ReadableConfig tableConfig, ClassLoader classLoader) Creates a generated function which produces an AsyncFunction which executes the calc projections.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_EXCEPTION_TERM

public static final String DEFAULT_EXCEPTION_TERM

See Also:

Constant Field Values

DEFAULT_DELEGATING_FUTURE_TERM

public static final String DEFAULT_DELEGATING_FUTURE_TERM

See Also:

Constant Field Values

Constructor Detail

AsyncCodeGenerator

public AsyncCodeGenerator()

Method Detail

generateFunction

public static org.apache.flink.table.runtime.generated.GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>> generateFunction(String name,
                                                                                                                                                                                                                                 org.apache.flink.table.types.logical.RowType inputType,
                                                                                                                                                                                                                                 org.apache.flink.table.types.logical.RowType returnType,
                                                                                                                                                                                                                                 List<org.apache.calcite.rex.RexNode> calcProjection,
                                                                                                                                                                                                                                 boolean retainHeader,
                                                                                                                                                                                                                                 org.apache.flink.configuration.ReadableConfig tableConfig,
                                                                                                                                                                                                                                 ClassLoader classLoader)

Creates a generated function which produces an AsyncFunction which executes the calc projections.

Parameters:

name - The name used to generate the underlying function name

inputType - The RowType of the input RowData

returnType - The RowType of the resulting RowData

retainHeader - If the header of the row should be retained

calcProjection - The list of projections to be executed by this function

tableConfig - The table configuration

classLoader - The classloader to use while resolving classes

Returns:

A GeneratedFunction returning an AsyncFunction executing the given list of projections