This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1d4bd2b [FLINK-18005][table] Implement type inference for CAST add 12a895a [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic No new revisions were added by this update. Summary of changes: docs/dev/connectors/kafka.md | 10 +- docs/dev/event_timestamp_extractors.md | 17 +- docs/dev/event_timestamps_watermarks.md | 43 ++-- .../source/reader/CoordinatedSourceITCase.java | 8 +- .../connectors/kafka/FlinkKafkaConsumerBase.java | 4 +- .../internals/AbstractFetcherWatermarksTest.java | 4 +- .../api/common/eventtime/WatermarkStrategies.java | 250 --------------------- .../api/common/eventtime/WatermarkStrategy.java | 141 +++++++++++- .../eventtime/WatermarkStrategyWithIdleness.java | 27 ++- .../WatermarkStrategyWithTimestampAssigner.java | 38 ++-- ...ategiesTest.java => WatermarkStrategyTest.java} | 91 +++++--- .../flink/streaming/api/datastream/DataStream.java | 4 +- .../apache/flink/streaming/api/DataStreamTest.java | 23 ++ .../api/graph/StreamingJobGraphGeneratorTest.java | 6 +- .../source/SourceOperatorEventTimeTest.java | 25 +-- .../operators/source/TestingSourceOperator.java | 3 +- .../TimestampsAndWatermarksOperatorTest.java | 22 +- .../tasks/SourceOperatorStreamTaskTest.java | 4 +- .../flink/streaming/api/scala/DataStream.scala | 4 +- .../api/scala/StreamExecutionEnvironmentTest.scala | 5 +- 20 files changed, 328 insertions(+), 401 deletions(-) delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategies.java copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DayTimeIntervalDurationConverter.java => flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategyWithIdleness.java (52%) copy flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorBase.java => flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategyWithTimestampAssigner.java (50%) rename flink-core/src/test/java/org/apache/flink/api/common/eventtime/{WatermarkStrategiesTest.java => WatermarkStrategyTest.java} (72%)