swapna267 opened a new pull request, #12191:
URL: https://github.com/apache/iceberg/pull/12191
Iceberg Source to support Source Watermark, so it can be used in Flink
WINDOW functions.
https://github.com/apache/flink/blob/release-1.18/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsSourceWatermark.java
enables Flink to rely on the watermark strategy provided by the
ScanTableSource itself.
```
CREATE TABLE table_wm (
eventTS AS CAST(t1 AS TIMESTAMP(3)),
WATERMARK FOR eventTS AS SOURCE_WATERMARK()
) WITH (
'watermark-column'='t1'
) LIKE iceberg_catalog.db.table;
```
**Reference:**
https://github.com/apache/iceberg/issues/10219
https://github.com/apache/iceberg/pull/9346
Previous discussion in PR, https://github.com/apache/iceberg/pull/12116 .
Split into separate PR for easy review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
