[FLINK-9852] Expose descriptor-based sink creation and introduce update mode

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.6.0
• Fix Version/s: 1.6.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 15/Jul/18 10:32
• Updated: 20/Jul/18 07:45
• Resolved: 20/Jul/18 07:45

Description

Currently, only a table source can be created using the unified table descriptors with tableEnv.from(...). A similar approach should be supported for defining sinks or even both types at the same time.

I suggest the following syntax:

tableEnv.connect(Kafka(...)).registerSource("name")
tableEnv.connect(Kafka(...)).registerSink("name")
tableEnv.connect(Kafka(...)).registerSourceAndSink("name")

A table could then access the registered source/sink.

We need to introduce a new update-mode property in order to distinguish between append, retract, and upsert table sources and sinks.

Issue Links

• links to: GitHub Pull Request #6343