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 59850a91f96 [FLINK-32491][table-runtime] Introduce
RuntimeFilterCodeGenerator
add f500b593911 [FLINK-32280][table-runtime] HashAgg support operator
fusion codegen
add 53649ef98ef [FLINK-32280][table-runtime] Extend MultipleInput
algorithm to support one-input node as root node if operator fusion codegen
enabled
add b74bf010c48 [FLINK-32280][table-runtime] Add ITCase for HashAgg
operator fusion codegen
add 6fd47ec7cbf [FLINK-32280][table-runtime] Fix the failed batch agg
tests due to doens't mock the filterArgs
No new revisions were added by this update.
Summary of changes:
.../nodes/exec/batch/BatchExecHashAggregate.java | 57 ++
.../MultipleInputNodeCreationProcessor.java | 58 +-
.../flink/table/planner/codegen/CodeGenUtils.scala | 28 +
.../planner/codegen/ProjectionCodeGenerator.scala | 74 ++-
.../codegen/agg/batch/AggCodeGenHelper.scala | 45 +-
.../agg/batch/AggWithoutKeysCodeGenerator.scala | 4 +-
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 75 ++-
.../codegen/agg/batch/HashAggCodeGenerator.scala | 4 +-
.../codegen/agg/batch/SortAggCodeGenerator.scala | 7 +-
.../codegen/agg/batch/WindowCodeGenerator.scala | 14 +-
.../planner/plan/fusion/FusionCodegenUtil.scala | 51 +-
.../fusion/spec/HashAggFusionCodegenSpec.scala | 681 +++++++++++++++++++++
.../fusion/spec/HashJoinFusionCodegenSpec.scala | 2 +-
.../table/planner/codegen/agg/AggTestBase.scala | 3 +
.../agg/batch/HashAggCodeGeneratorTest.scala | 1 +
.../batch/sql/OperatorFusionCodegenITCase.scala | 142 ++++-
16 files changed, 1180 insertions(+), 66 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/fusion/spec/HashAggFusionCodegenSpec.scala
