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%)
