This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 977404e5409 [fix](compile) Enable compile checking for function_json
(#42329)
add 152cc2c3cb9 [Feature](hash-table) unify initialization of
HashTableVariants and support set for distinct agg (#42046)
No new revisions were added by this update.
Summary of changes:
be/src/olap/rowset/segment_v2/column_reader.h | 3 +-
be/src/pipeline/common/agg_utils.h | 183 ++++++++------------
be/src/pipeline/common/distinct_agg_utils.h | 155 +++++++++++++++++
be/src/pipeline/common/join_utils.h | 109 ++++++++++--
be/src/pipeline/common/partition_sort_utils.cpp | 95 ++++++++++
.../partition_sort_utils.h} | 192 ++++++++-------------
be/src/pipeline/common/runtime_filter_consumer.h | 2 +-
be/src/pipeline/common/set_utils.h | 112 ++++++++++++
be/src/pipeline/dependency.cpp | 13 ++
be/src/pipeline/dependency.h | 82 +--------
be/src/pipeline/exec/aggregation_sink_operator.cpp | 14 +-
.../pipeline/exec/aggregation_source_operator.cpp | 4 +-
.../distinct_streaming_aggregation_operator.cpp | 22 +--
.../exec/distinct_streaming_aggregation_operator.h | 4 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 182 ++++++-------------
be/src/pipeline/exec/hashjoin_build_sink.h | 2 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 4 +-
.../exec/join/process_hash_table_probe_impl.h | 36 ++--
.../pipeline/exec/memory_scratch_sink_operator.h | 4 +-
.../pipeline/exec/partition_sort_sink_operator.cpp | 84 +--------
.../pipeline/exec/partition_sort_sink_operator.h | 190 +-------------------
be/src/pipeline/exec/set_probe_sink_operator.cpp | 6 +-
be/src/pipeline/exec/set_sink_operator.cpp | 8 +-
be/src/pipeline/exec/set_source_operator.cpp | 2 +-
.../exec/streaming_aggregation_operator.cpp | 8 +-
be/src/vec/common/columns_hashing.h | 37 +++-
be/src/vec/common/columns_hashing_impl.h | 10 +-
be/src/vec/common/hash_table/hash_key_type.h | 128 ++++++++++++++
be/src/vec/common/hash_table/hash_map_context.h | 18 +-
.../common/hash_table/hash_map_context_creator.h | 183 --------------------
be/src/vec/common/hash_table/hash_map_util.h | 63 +++----
be/src/vec/common/hash_table/ph_hash_map.h | 1 -
be/src/vec/common/hash_table/ph_hash_set.h | 111 ++++++++++++
be/src/vec/data_types/data_type.cpp | 2 +-
be/src/vec/data_types/data_type_bitmap.h | 1 -
be/src/vec/data_types/data_type_hll.h | 1 -
be/src/vec/data_types/data_type_nullable.cpp | 6 -
be/src/vec/data_types/data_type_nullable.h | 1 -
be/src/vec/data_types/data_type_quantilestate.h | 1 -
.../array/function_array_enumerate_uniq.cpp | 2 +-
40 files changed, 1049 insertions(+), 1032 deletions(-)
create mode 100644 be/src/pipeline/common/distinct_agg_utils.h
create mode 100644 be/src/pipeline/common/partition_sort_utils.cpp
copy be/src/pipeline/{exec/partition_sort_sink_operator.h =>
common/partition_sort_utils.h} (57%)
create mode 100644 be/src/pipeline/common/set_utils.h
create mode 100644 be/src/vec/common/hash_table/hash_key_type.h
delete mode 100644 be/src/vec/common/hash_table/hash_map_context_creator.h
create mode 100644 be/src/vec/common/hash_table/ph_hash_set.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
