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 c6786ab [FLINK-20654][checkpointing] Decline checkpoints until input
channels are recovered
add 14b4dc8 [FLINK-20877][table-runtime-blink] Move BytesMap classes to
util package
add e79dd4e [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and
BytesMultiMap to support window key
No new revisions were added by this update.
Summary of changes:
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 6 +-
.../codegen/agg/batch/HashAggCodeGenerator.scala | 10 +-
.../agg/batch/HashWindowCodeGenerator.scala | 15 +-
.../batch/BatchExecHashWindowAggregateBase.scala | 3 +-
.../BytesHashMapSpillMemorySegmentPool.java | 1 +
.../typeutils/AbstractRowDataSerializer.java | 57 +----
.../runtime/typeutils/BinaryRowDataSerializer.java | 12 +-
...ataSerializer.java => PagedTypeSerializer.java} | 28 +--
.../table/runtime/typeutils/RowDataSerializer.java | 11 +-
.../runtime/typeutils/WindowKeySerializer.java | 228 +++++++++++++++++
.../apache/flink/table/runtime/util/WindowKey.java | 71 ++++++
.../collections/binary/AbstractBytesHashMap.java} | 177 +++++---------
.../collections/binary/AbstractBytesMultiMap.java} | 81 +++---
.../util/collections/binary/BytesHashMap.java | 51 ++++
.../collections/binary}/BytesMap.java | 65 ++---
.../util/collections/binary/BytesMultiMap.java | 49 ++++
.../collections/binary/WindowBytesHashMap.java | 49 ++++
.../collections/binary/WindowBytesMultiMap.java | 49 ++++
.../apache/flink/table/data/BinaryRowDataTest.java | 19 +-
.../aggregate/SumHashAggTestOperator.java | 7 +-
.../runtime/typeutils/WindowKeySerializerTest.java | 64 +++++
.../util/collections/binary/BytesHashMapTest.java | 46 ++++
.../collections/binary/BytesHashMapTestBase.java} | 271 ++++++++++-----------
.../collections/binary}/BytesMapTestBase.java | 9 +-
.../util/collections/binary/BytesMultiMapTest.java | 46 ++++
.../collections/binary/BytesMultiMapTestBase.java} | 88 ++++---
.../collections/binary/WindowBytesHashMapTest.java | 55 +++++
.../binary/WindowBytesMultiMapTest.java | 55 +++++
28 files changed, 1152 insertions(+), 471 deletions(-)
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{AbstractRowDataSerializer.java
=> PagedTypeSerializer.java} (78%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/WindowKeySerializer.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/WindowKey.java
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/{operators/aggregate/BytesHashMap.java
=> util/collections/binary/AbstractBytesHashMap.java} (72%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/{operators/aggregate/BytesMultiMap.java
=> util/collections/binary/AbstractBytesMultiMap.java} (89%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/collections/binary/BytesHashMap.java
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/{operators/aggregate
=> util/collections/binary}/BytesMap.java (88%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/collections/binary/BytesMultiMap.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/collections/binary/WindowBytesHashMap.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/collections/binary/WindowBytesMultiMap.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/WindowKeySerializerTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/collections/binary/BytesHashMapTest.java
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/{operators/aggregate/BytesHashMapTest.java
=> util/collections/binary/BytesHashMapTestBase.java} (56%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/{operators/aggregate
=> util/collections/binary}/BytesMapTestBase.java (92%)
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/collections/binary/BytesMultiMapTest.java
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/{operators/aggregate/BytesMultiMapTest.java
=> util/collections/binary/BytesMultiMapTestBase.java} (58%)
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/collections/binary/WindowBytesHashMapTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/collections/binary/WindowBytesMultiMapTest.java
