[
https://issues.apache.org/jira/browse/FLINK-25387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-25387:
---------------------------------
Description:
Introduce annotation:
{code}
@ExecNodeMetadata(
// main information
name = "stream-exec-sink",
version = 1,
// maintenance information for us/the community and our tests
consumedOptions = {"table.exec.sink.not-null-enforcer",
"table.exec.sink.upsert-materialize"}
producedOperators = {"not-null-enforcer", "upsert-materializer"}
minPlanVersion = FlinkVersion.1_15,
minStateVersion = FlinkVersion.1_15)
{code}
* Introduce a util to map from name and version to concrete ExecNode class.
This util is required to switch the JSON plan from `ReflectionUtil` class-based
approach to annotation-based approach.
was:
Introduce annotation:
{code}
@ExecNodeMetadata(
// main information
name = "stream-exec-sink",
version = 1,
// maintenance information for us/the community and our tests
consumedOptions = {"table.exec.sink.not-null-enforcer",
"table.exec.sink.upsert-materialize"}
producedOperators = {"not-null-enforcer", "upsert-materializer"}
minPlanVersion = FlinkVersion.1_15,
minStateVersion = FlinkVersion.1_15)
{code}
* Introduce a util to map from name and version to concrete ExecNode class.
This util is required to switch the JSON plan from `ReflectionUtil` class-based
approach to annotation-based approach.
* Introduce a
> Introduce ExecNodeMetadata annotation and tooling
> -------------------------------------------------
>
> Key: FLINK-25387
> URL: https://issues.apache.org/jira/browse/FLINK-25387
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: Timo Walther
> Assignee: Marios Trivyzas
> Priority: Major
>
> Introduce annotation:
> {code}
> @ExecNodeMetadata(
> // main information
> name = "stream-exec-sink",
> version = 1,
> // maintenance information for us/the community and our tests
> consumedOptions = {"table.exec.sink.not-null-enforcer",
> "table.exec.sink.upsert-materialize"}
> producedOperators = {"not-null-enforcer", "upsert-materializer"}
> minPlanVersion = FlinkVersion.1_15,
> minStateVersion = FlinkVersion.1_15)
> {code}
>
> * Introduce a util to map from name and version to concrete ExecNode class.
> This util is required to switch the JSON plan from `ReflectionUtil`
> class-based approach to annotation-based approach.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
