[
https://issues.apache.org/jira/browse/FLINK-25387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25387:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Labels: pull-request-available
>
> 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)
