This is an automated email from the ASF dual-hosted git repository.
tangyun pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e8b118598c6 [FLINK-32569][table] Fix the incomplete serialization of
ResolvedCatalogTable caused by the newly introduced time travel interface
(#22977)
add a3471eab759 [FLINK-31536][flink-table] support to set watermark emit
strategy with table options and 'OPTIONS' hint
add 8f64775e577 [FLINK-31539][flink-table-planner] supported watermark
alignment in sql layer.
add 2aa9af15b41 [FLINK-31540][flink-table-planner] support to set
idle-timeout options with table options and 'OPTIONS' hint
add 5cacd1216b0 [FLINK-31819][doc] Added documentations for advanced
watermark features in sql
No new revisions were added by this update.
Summary of changes:
.../docs/dev/table/concepts/time_attributes.md | 95 ++++++++++
.../docs/dev/table/concepts/time_attributes.md | 99 +++++++++++
.../apache/flink/table/factories/FactoryUtil.java | 102 +++++++++++
.../table/watermark/WatermarkEmitStrategy.java | 42 +++--
.../flink/table/watermark/WatermarkParams.java | 196 +++++++++++++++++++++
.../flink/table/factories/FactoryUtilTest.java | 45 +++++
.../table/planner/hint/FlinkHintStrategies.java | 23 ++-
.../abilities/source/WatermarkPushDownSpec.java | 77 ++++++--
.../PushWatermarkIntoTableSourceScanRuleBase.java | 77 +++++++-
.../serde/DynamicTableSourceSpecSerdeTest.java | 13 +-
.../PushWatermarkIntoTableSourceScanRuleTest.java | 120 +++++++++++++
.../testWatermarkPushDown.out | 11 +-
.../PushWatermarkIntoTableSourceScanRuleTest.xml | 126 ++++++++++++-
.../plan/stream/sql/FilterableSourceTest.xml | 10 +-
.../plan/stream/sql/SourceWatermarkTest.xml | 18 +-
.../planner/plan/stream/sql/TableScanTest.xml | 2 +-
.../GeneratedWatermarkGeneratorSupplier.java | 29 ++-
17 files changed, 1012 insertions(+), 73 deletions(-)
copy
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/splitreader/SplitsAddition.java
=>
flink-table/flink-table-common/src/main/java/org/apache/flink/table/watermark/WatermarkEmitStrategy.java
(55%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/watermark/WatermarkParams.java
