[FLINK-25387] Introduce ExecNodeMetadata annotation and tooling

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.15.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Marios Trivyzas
• Reporter: Timo Walther
• Created: 20/Dec/21 12:44
• Updated: 02/Feb/22 17:01
• Resolved: 02/Feb/22 17:01

Description

Introduce annotation:

@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)

 

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

Issue Links

• links to: GitHub Pull Request #18479