This is an automated email from the ASF dual-hosted git repository.
Mryange pushed a change to branch groupjoin
in repository https://gitbox.apache.org/repos/asf/doris.git
from 5826a0b4674 [improvement](fe) Skip Group Join without aggregate
functions
add 301bbe303a7 [refactor](be) Implement GroupJoin with the join hash table
No new revisions were added by this update.
Summary of changes:
be/src/exec/common/groupjoin_utils.h | 135 +----
be/src/exec/common/hash_table/join_hash_table.h | 4 +-
.../exec/common/hash_table/join_hash_table_utils.h | 53 ++
be/src/exec/common/join_utils.h | 26 +
be/src/exec/operator/groupjoin_build_sink.cpp | 368 ++++++-------
be/src/exec/operator/groupjoin_build_sink.h | 70 +--
be/src/exec/operator/groupjoin_operator_utils.cpp | 490 ++---------------
be/src/exec/operator/groupjoin_operator_utils.h | 90 ++--
be/src/exec/operator/groupjoin_probe_operator.cpp | 593 +++++++++++++++------
be/src/exec/operator/groupjoin_probe_operator.h | 119 +++--
be/src/exec/operator/groupjoin_shared_state.h | 42 +-
be/src/exec/operator/hashjoin_build_sink.h | 19 +-
.../operator/join/process_hash_table_probe_impl.h | 14 +-
be/src/exec/operator/operator.cpp | 2 +-
be/src/exprs/aggregate/aggregate_function.h | 60 +--
be/src/exprs/aggregate/aggregate_function_count.h | 51 --
.../exprs/aggregate/aggregate_function_min_max.h | 13 -
.../exprs/aggregate/aggregate_function_null_v2.h | 95 ++--
be/src/exprs/aggregate/aggregate_function_sum.h | 82 +--
be/src/exprs/vectorized_agg_fn.cpp | 9 -
be/src/exprs/vectorized_agg_fn.h | 10 +-
be/test/exec/operator/groupjoin_match_test.cpp | 173 ++++++
.../operator/groupjoin_operator_utils_test.cpp | 220 +-------
.../aggregate/aggregate_function_indexed_test.cpp | 195 +++++++
.../aggregate/aggregate_function_repeat_test.cpp | 438 ---------------
.../glue/translator/PhysicalPlanTranslator.java | 19 +-
.../doris/nereids/util/GroupJoinFusionUtils.java | 158 ++----
.../org/apache/doris/planner/GroupJoinNode.java | 2 +
.../nereids/util/GroupJoinFusionUtilsTest.java | 142 ++++-
gensrc/thrift/PlanNodes.thrift | 17 +-
.../test_join_based_group_join_poc.out | 201 +++++++
.../test_join_based_group_join_state_pages.out | 11 +
.../test_group_join_float_special.groovy | 8 +-
.../test_group_join_fusion_binary_agg.groovy | 18 +-
...t_group_join_fusion_intermediate_project.groovy | 26 +-
.../test_join_based_group_join_poc.groovy | 300 +++++++++++
.../test_join_based_group_join_state_pages.groovy | 67 +++
37 files changed, 2180 insertions(+), 2160 deletions(-)
create mode 100644 be/src/exec/common/hash_table/join_hash_table_utils.h
create mode 100644 be/test/exec/operator/groupjoin_match_test.cpp
create mode 100644 be/test/exprs/aggregate/aggregate_function_indexed_test.cpp
delete mode 100644 be/test/exprs/aggregate/aggregate_function_repeat_test.cpp
create mode 100644
regression-test/data/group_join_fusion_p0/test_join_based_group_join_poc.out
create mode 100644
regression-test/data/group_join_fusion_p0/test_join_based_group_join_state_pages.out
create mode 100644
regression-test/suites/group_join_fusion_p0/test_join_based_group_join_poc.groovy
create mode 100644
regression-test/suites/group_join_fusion_p0/test_join_based_group_join_state_pages.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
