@Internal public final class ExecNodeMetadataUtil extends Object
ExecNodeMetadata
related functionality.Modifier and Type | Class and Description |
---|---|
static class |
ExecNodeMetadataUtil.ExecNodeNameVersion
Helper Pojo used as a tuple for the
LOOKUP_MAP . |
Modifier and Type | Field and Description |
---|---|
static Set<ConfigOption<?>> |
EXECUTION_CONFIG_OPTIONS |
static Set<ConfigOption<?>> |
TABLE_CONFIG_OPTIONS |
Modifier and Type | Method and Description |
---|---|
static void |
addTestNode(Class<? extends ExecNode<?>> execNodeClass) |
static <T extends ExecNode<?>> |
consumedOptions(Class<T> execNodeClass) |
static Set<Class<? extends ExecNode<?>>> |
execNodes() |
static <T extends ExecNode<?>> |
extractMetadataFromAnnotation(Class<T> execNodeClass) |
static Map<ExecNodeMetadataUtil.ExecNodeNameVersion,Class<? extends ExecNode<?>>> |
getVersionedExecNodes() |
static <T extends ExecNode<?>> |
isUnsupported(Class<T> execNode) |
static <T extends ExecNode<?>> |
latestAnnotation(Class<T> execNodeClass)
Returns the
ExecNodeMetadata annotation of the class with the highest (most recent)
ExecNodeMetadata.version() . |
static <T extends ExecNode<?>> |
newPersistedConfig(Class<T> execNodeClass,
ReadableConfig tableConfig,
java.util.stream.Stream<ConfigOption<?>> configOptions) |
static Class<? extends ExecNode<?>> |
retrieveExecNode(String name,
int version) |
public static final Set<ConfigOption<?>> TABLE_CONFIG_OPTIONS
public static final Set<ConfigOption<?>> EXECUTION_CONFIG_OPTIONS
public static Map<ExecNodeMetadataUtil.ExecNodeNameVersion,Class<? extends ExecNode<?>>> getVersionedExecNodes()
public static Class<? extends ExecNode<?>> retrieveExecNode(String name, int version)
public static <T extends ExecNode<?>> List<ExecNodeMetadata> extractMetadataFromAnnotation(Class<T> execNodeClass)
public static <T extends ExecNode<?>> ExecNodeMetadata latestAnnotation(Class<T> execNodeClass)
ExecNodeMetadata
annotation of the class with the highest (most recent)
ExecNodeMetadata.version()
.@Nullable public static <T extends ExecNode<?>> String[] consumedOptions(Class<T> execNodeClass)
public static <T extends ExecNode<?>> ReadableConfig newPersistedConfig(Class<T> execNodeClass, ReadableConfig tableConfig, java.util.stream.Stream<ConfigOption<?>> configOptions)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.