Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
As discussed in mailing list [1], the existing SupportsComputedColumnPushDown and SupportsWatermarkPushDown are confusing and hard to implement for connectors. The
SupportsComputedColumnPushDown only used for watermark push down. Therefore,
combining them into a single interface SupportsWatermarkPushDown would be better and also work. The proposed interface looks like this:
public interface SupportsWatermarkPushDown { void applyWatermark(org.apache.flink.table.sources.wmstrategies.WatermarkStrategy<RowData> watermarkStrategy); }
Attachments
Issue Links
- links to