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 d20867a [FLINK-21070][table-runtime-blink] Fix invalid reuse of
generated code
new 33c14a1 [hotfix][runtime] Fix the missing arguments in error message
in MemoryManager and FsCheckpointStorageAccess
new 88dc2fc [hotfix][streaming][test] Allow
AbstractStreamOperatorTestHarness to use managed memory for operator use case
new d16393f [hotfix][table-runtime-blink] Make MemoryManager not null in
LazyMemorySegmentPool
new f3db422 [hotfix][table-runtime-blink] Rename StateTtlConfigUtil to
StateConfigUtil
new c4bfa9f [FLINK-21054][table-runtime-blink] Implement mini-batch
optimized slicing window aggregate operator
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/flink/runtime/memory/MemoryManager.java | 2 +-
.../filesystem/FsCheckpointStorageAccess.java | 2 +-
.../util/AbstractStreamOperatorTestHarness.java | 1 +
.../table/planner/utils/StateConfigUtilTest.java | 124 ++++
.../operators/aggregate/GroupAggFunction.java | 2 +-
.../operators/aggregate/GroupTableAggFunction.java | 2 +-
.../aggregate/MiniBatchGlobalGroupAggFunction.java | 2 +-
.../aggregate/MiniBatchGroupAggFunction.java | 2 +-
.../MiniBatchIncrementalGroupAggFunction.java | 2 +-
.../window/SlicingWindowAggOperatorBuilder.java | 137 ++++
.../window/buffers/RecordsWindowBuffer.java | 142 ++++
.../aggregate/window/buffers/WindowBuffer.java | 96 +++
.../window/combines/CombineRecordsFunction.java | 165 +++++
.../window/combines/WindowCombineFunction.java | 72 ++
.../processors/AbstractWindowAggProcessor.java | 179 +++++
.../processors/SliceSharedWindowAggProcessor.java | 152 ++++
.../SliceUnsharedWindowAggProcessor.java | 54 ++
.../deduplicate/DeduplicateFunctionBase.java | 2 +-
.../MiniBatchDeduplicateFunctionBase.java | 2 +-
.../join/stream/state/JoinRecordStateViews.java | 2 +-
.../stream/state/OuterJoinRecordStateViews.java | 2 +-
.../operators/window/slicing/ClockService.java | 38 +
.../operators/window/slicing/SliceAssigner.java | 62 ++
.../operators/window/slicing/SliceAssigners.java | 473 +++++++++++++
.../window/slicing/SliceSharedAssigner.java | 81 +++
.../window/slicing/SliceUnsharedAssigner.java | 30 +
.../window/slicing/SlicingWindowOperator.java | 324 +++++++++
.../window/slicing/SlicingWindowProcessor.java | 119 ++++
.../operators/window/state/StateKeyContext.java | 28 +
.../operators/window/state/WindowState.java | 26 +
.../operators/window/state/WindowValueState.java | 57 ++
.../table/runtime/util/LazyMemorySegmentPool.java | 45 +-
...tateTtlConfigUtil.java => StateConfigUtil.java} | 23 +-
.../runtime/util/collections/binary/BytesMap.java | 5 +-
.../window/SlicingWindowAggOperatorTest.java | 783 +++++++++++++++++++++
.../slicing/CumulativeSliceAssignerTest.java | 175 +++++
.../window/slicing/HoppingSliceAssignerTest.java | 148 ++++
.../window/slicing/SliceAssignerTestBase.java | 89 +++
.../window/slicing/TumblingSliceAssignerTest.java | 95 +++
.../window/slicing/WindowedSliceAssignerTest.java | 84 +++
40 files changed, 3779 insertions(+), 50 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/utils/StateConfigUtilTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/SlicingWindowAggOperatorBuilder.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/buffers/RecordsWindowBuffer.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/buffers/WindowBuffer.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/combines/CombineRecordsFunction.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/combines/WindowCombineFunction.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/processors/AbstractWindowAggProcessor.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/processors/SliceSharedWindowAggProcessor.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/processors/SliceUnsharedWindowAggProcessor.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/ClockService.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceAssigner.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceAssigners.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceSharedAssigner.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceUnsharedAssigner.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SlicingWindowOperator.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SlicingWindowProcessor.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/state/StateKeyContext.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/state/WindowState.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/state/WindowValueState.java
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/{StateTtlConfigUtil.java
=> StateConfigUtil.java} (58%)
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/aggregate/window/SlicingWindowAggOperatorTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/window/slicing/CumulativeSliceAssignerTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/window/slicing/HoppingSliceAssignerTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/window/slicing/SliceAssignerTestBase.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/window/slicing/TumblingSliceAssignerTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/window/slicing/WindowedSliceAssignerTest.java
