[FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: API / Core, API / DataStream
• Labels: pull-request-available
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 13/May/20 08:36
• Updated: 16/Oct/20 10:36
• Resolved: 09/Jun/20 10:44

Description

https://cwiki.apache.org/confluence/display/FLINK/FLIP-126%3A+Unify+%28and+separate%29+Watermark+Assigners

Issue Links

• links to: GitHub Pull Request #12147
• mentioned in: Page Loading...

Sub-Tasks

• Move Clock classes to flink-core to make them usable outside runtime: Closed
• Remove old and long deprecated TimestampExtractor: Closed
• Add new TimestampAssigner and WatermarkGenerator interfaces: Closed
• Add common watermark strategies and WatermarkStrategies helper: Closed
• Add APIs for using new WatermarkStrategy/WatermarkGenerator: Closed
• Use new WatermarkStrategy/WatermarkGenerator in Kafka connector: Closed
• Use checkpoint lock instead of fine-grained locking in Kafka AbstractFetcher: Closed
• Update documentation for new WatermarkGenerator/WatermarkStrategies: Closed
• Change KafkaConnector to give per-partition metric group to WatermarkGenerator: Closed
• Make WatermarkStrategy/WatermarkStrategies more ergonomic: Closed