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 4541707 [FLINK-20737][table-planner-blink] Introduce
StreamPhysicalPythonGroupTableAggregate, and make
StreamExecPythonGroupTableAggregate only extended from ExecNode
add facd51f [FLINK-20854][table-runtime-blink] Introduce BytesMultiMap to
support buffering records
No new revisions were added by this update.
Summary of changes:
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 34 +-
.../codegen/agg/batch/HashAggCodeGenerator.scala | 16 +-
.../agg/batch/HashWindowCodeGenerator.scala | 35 +-
.../batch/BatchExecHashWindowAggregateBase.scala | 6 +-
.../runtime/operators/aggregate/BytesHashMap.java | 453 +++++---------------
.../runtime/operators/aggregate/BytesMap.java | 391 +++++++++++++++++
.../runtime/operators/aggregate/BytesMultiMap.java | 466 +++++++++++++++++++++
.../{RowIterator.java => KeyValueIterator.java} | 34 +-
.../table/runtime/util/LazyMemorySegmentPool.java | 45 +-
.../operators/aggregate/BytesHashMapTest.java | 144 +------
.../operators/aggregate/BytesMapTestBase.java | 112 +++++
.../operators/aggregate/BytesMultiMapTest.java | 123 ++++++
.../aggregate/SumHashAggTestOperator.java | 16 +-
13 files changed, 1313 insertions(+), 562 deletions(-)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/BytesMap.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/BytesMultiMap.java
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/{RowIterator.java
=> KeyValueIterator.java} (54%)
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/aggregate/BytesMapTestBase.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/aggregate/BytesMultiMapTest.java
