[FLINK-19282] Support watermark push down with WatermarkStrategy

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.12.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Shengkai Fang
• Reporter: Shengkai Fang
• Created: 17/Sep/20 13:37
• Updated: 07/Nov/20 03:02
• Resolved: 07/Nov/20 03:01

Description

Push the WatermarkStrategy into TableSourceScan in the interface SupportsWatermarkPushDown. Sometimes users define watermark on computed column. Therefore, we will push the computed column of rowtime into WatermarkStrategy first. For more info, please take a look at discussion.

Issue Links

• links to: GitHub Pull Request #13449