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

Class ExecNodeMetadataUtil

java.lang.Object

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

@Internal
public final class ExecNodeMetadataUtil
extends Object

Utility class for ExecNodeMetadata related functionality.

Field Summary

Fields

Modifier and Type	Field and Description
static Set<org.apache.flink.configuration.ConfigOption<?>>	EXECUTION_CONFIG_OPTIONS
static Set<org.apache.flink.configuration.ConfigOption<?>>	TABLE_CONFIG_OPTIONS

Method Summary

Modifier and Type	Method and Description
static void	addTestNode(Class<? extends ExecNode<?>> execNodeClass)
static <T extends ExecNode<?>> String[]	consumedOptions(Class<T> execNodeClass)
static Set<Class<? extends ExecNode<?>>>	execNodes()
static <T extends ExecNode<?>> List<ExecNodeMetadata>	extractMetadataFromAnnotation(Class<T> execNodeClass)
static <T extends ExecNode<?>> boolean	isUnsupported(Class<T> execNode)
static <T extends ExecNode<?>> ExecNodeMetadata	latestAnnotation(Class<T> execNodeClass) Returns the ExecNodeMetadata annotation of the class with the highest (most recent) ExecNodeMetadata.version().
static <T extends ExecNode<?>> org.apache.flink.configuration.ReadableConfig	newPersistedConfig(Class<T> execNodeClass, org.apache.flink.configuration.ReadableConfig tableConfig, Stream<org.apache.flink.configuration.ConfigOption<?>> configOptions)
static Class<? extends ExecNode<?>>	retrieveExecNode(String name, int version)

Methods inherited from class java.lang.Object

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

Field Detail

TABLE_CONFIG_OPTIONS

public static final Set<org.apache.flink.configuration.ConfigOption<?>> TABLE_CONFIG_OPTIONS

EXECUTION_CONFIG_OPTIONS

public static final Set<org.apache.flink.configuration.ConfigOption<?>> EXECUTION_CONFIG_OPTIONS

Method Detail

execNodes

public static Set<Class<? extends ExecNode<?>>> execNodes()

retrieveExecNode

public static Class<? extends ExecNode<?>> retrieveExecNode(String name,
                                                            int version)

isUnsupported

public static <T extends ExecNode<?>> boolean isUnsupported(Class<T> execNode)

addTestNode

public static void addTestNode(Class<? extends ExecNode<?>> execNodeClass)

extractMetadataFromAnnotation

public static <T extends ExecNode<?>> List<ExecNodeMetadata> extractMetadataFromAnnotation(Class<T> execNodeClass)

latestAnnotation

public static <T extends ExecNode<?>> ExecNodeMetadata latestAnnotation(Class<T> execNodeClass)

Returns the ExecNodeMetadata annotation of the class with the highest (most recent) ExecNodeMetadata.version().

consumedOptions

@Nullable
public static <T extends ExecNode<?>> String[] consumedOptions(Class<T> execNodeClass)

newPersistedConfig

public static <T extends ExecNode<?>> org.apache.flink.configuration.ReadableConfig newPersistedConfig(Class<T> execNodeClass,
                                                                                                       org.apache.flink.configuration.ReadableConfig tableConfig,
                                                                                                       Stream<org.apache.flink.configuration.ConfigOption<?>> configOptions)