This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 11f5abc [FLINK-22479[Kinesis][Consumer] Potential lock-up under error
condition
add 538d1d9 [FLINK-22304][table] Refactor some interfaces for TVF based
window to improve the extendability
No new revisions were added by this update.
Summary of changes:
.../stream/StreamExecLocalWindowAggregate.java | 20 ++++--
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 2 +-
.../agg/batch/HashWindowCodeGenerator.scala | 2 +-
.../window/LocalSlicingWindowAggOperator.java | 33 ++-------
.../window/SlicingWindowAggOperatorBuilder.java | 37 +++++-----
.../window/buffers/RecordsWindowBuffer.java | 84 +++++++++++++++++++---
.../aggregate/window/buffers/WindowBuffer.java | 46 ++++++++++--
.../{AggRecordsCombiner.java => AggCombiner.java} | 60 +++-------------
...lAggAccCombiner.java => GlobalAggCombiner.java} | 63 ++++++----------
...gRecordsCombiner.java => LocalAggCombiner.java} | 35 ++++-----
.../processors/AbstractWindowAggProcessor.java | 17 ++---
.../processors/SliceSharedWindowAggProcessor.java | 10 +--
.../SliceUnsharedWindowAggProcessor.java | 10 +--
.../rank/window/WindowRankOperatorBuilder.java | 15 ++--
.../rank/window/combines/TopNRecordsCombiner.java | 38 ++--------
.../window/processors/WindowRankProcessor.java | 17 ++---
...owCombineFunction.java => RecordsCombiner.java} | 25 +++----
.../collections/binary/AbstractBytesHashMap.java | 16 +++--
.../collections/binary/AbstractBytesMultiMap.java | 25 ++++---
.../aggregate/SumHashAggTestOperator.java | 3 +-
.../collections/binary/BytesHashMapTestBase.java | 2 +-
.../collections/binary/BytesMultiMapTestBase.java | 2 +-
22 files changed, 260 insertions(+), 302 deletions(-)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/combines/{AggRecordsCombiner.java
=> AggCombiner.java} (71%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/combines/{GlobalAggAccCombiner.java
=> GlobalAggCombiner.java} (75%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/combines/{LocalAggRecordsCombiner.java
=> LocalAggCombiner.java} (77%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/combines/{WindowCombineFunction.java
=> RecordsCombiner.java} (76%)
