Package 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ExecNodeMetadataUtil.ExecNodeNameVersion	Helper Pojo used as a tuple for the LOOKUP_MAP.

Field Summary

Fields

Modifier and Type	Field	Description
static Set<ConfigOption<?>>	EXECUTION_CONFIG_OPTIONS
static Set<ConfigOption<?>>	TABLE_CONFIG_OPTIONS

Method Summary

Modifier and Type	Method	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 Map<ExecNodeMetadataUtil.ExecNodeNameVersion,Class<? extends ExecNode<?>>>	getVersionedExecNodes()
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<?>> ReadableConfig	newPersistedConfig(Class<T> execNodeClass, ReadableConfig tableConfig, Stream<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<ConfigOption<?>> TABLE_CONFIG_OPTIONS

EXECUTION_CONFIG_OPTIONS

public static final Set<ConfigOption<?>> EXECUTION_CONFIG_OPTIONS

Method Detail

execNodes

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

getVersionedExecNodes

public static Map<ExecNodeMetadataUtil.ExecNodeNameVersion,Class<? extends ExecNode<?>>> getVersionedExecNodes()

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<?>> ReadableConfig newPersistedConfig(Class<T> execNodeClass,
                                                                        ReadableConfig tableConfig,
                                                                        Stream<ConfigOption<?>> configOptions)