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

Posted to commits@flink.apache.org by lz...@apache.org on 2021/03/19 09:07:41 UTC

[flink] branch master updated (23a164f -> 5bea459)

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 23a164f  [FLINK-21837][table-planner-blink] Support StreamExecIntervalJoin json serialization/deserialization
     add 5bea459  [FLINK-21818][table] Refactor SlicingWindowAggOperatorBuilder to accept serializer instead of LogicalType

No new revisions were added by this update.

Summary of changes:
 .../exec/stream/StreamExecWindowAggregate.java     | 18 ++---
 .../window/SlicingWindowAggOperatorBuilder.java    | 40 +++++++-----
 .../window/buffers/RecordsWindowBuffer.java        | 37 +++++------
 .../aggregate/window/buffers/WindowBuffer.java     |  3 +-
 .../window/combines/CombineRecordsFunction.java    | 32 +++++----
 .../processors/AbstractWindowAggProcessor.java     | 14 ++--
 .../processors/SliceSharedWindowAggProcessor.java  |  6 +-
 .../SliceUnsharedWindowAggProcessor.java           |  6 +-
 .../window/slicing/SlicingWindowOperator.java      |  3 +-
 .../window/slicing/SlicingWindowProcessor.java     |  3 +-
 .../runtime/typeutils/WindowKeySerializer.java     | 76 ++++++++--------------
 .../apache/flink/table/runtime/util/WindowKey.java | 13 ++--
 .../collections/binary/AbstractBytesHashMap.java   | 13 +++-
 .../collections/binary/AbstractBytesMultiMap.java  | 13 +++-
 .../collections/binary/WindowBytesHashMap.java     | 14 ++--
 .../collections/binary/WindowBytesMultiMap.java    | 14 ++--
 .../window/SlicingWindowAggOperatorTest.java       | 53 ++++++++-------
 .../runtime/typeutils/WindowKeySerializerTest.java |  2 +-
 .../collections/binary/WindowBytesHashMapTest.java | 13 +++-
 .../binary/WindowBytesMultiMapTest.java            | 13 +++-
 20 files changed, 196 insertions(+), 190 deletions(-)