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 35cb327 [FLINK-17977][core] Silence type extractor warnings for
built-in Row
add b592dd2 [FLINK-12855] Add WindowStagger to
TumblingProcessingTimeWindows
No new revisions were added by this update.
Summary of changes:
.../assigners/TumblingProcessingTimeWindows.java | 37 +++++++++--
.../api/windowing/assigners/WindowStagger.java | 75 ++++++++++++++++++++++
.../TumblingProcessingTimeWindowsTest.java | 22 ++++++-
.../operators/windowing/WindowStaggerTest.java | 33 +++++-----
4 files changed, 141 insertions(+), 26 deletions(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/WindowStagger.java
copy
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/SequenceFileWriterTest.java
=>
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowStaggerTest.java
(55%)
