You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by al...@apache.org on 2020/06/12 13:25:49 UTC

[flink] branch master updated (35cb327 -> b592dd2)

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