This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 448f5f7c5b17cad38aef0877a760fad995004f79 Author: Jerry Hu <[email protected]> AuthorDate: Thu Sep 14 09:19:02 2023 +0800 [fix](agg) Add the unimplemented functions in 'AggregateFunctionCountNotNullUnaryOld' (#24310) Similar to #24211 --- .../aggregate_functions/aggregate_function_count_old.h | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/be/src/vec/aggregate_functions/aggregate_function_count_old.h b/be/src/vec/aggregate_functions/aggregate_function_count_old.h index e42299fdc6..9a191bfd64 100644 --- a/be/src/vec/aggregate_functions/aggregate_function_count_old.h +++ b/be/src/vec/aggregate_functions/aggregate_function_count_old.h @@ -237,6 +237,22 @@ public: } } + void deserialize_and_merge_vec(const AggregateDataPtr* places, size_t offset, + AggregateDataPtr rhs, const ColumnString* column, Arena* arena, + const size_t num_rows) const override { + this->deserialize_from_column(rhs, *column, arena, num_rows); + DEFER({ this->destroy_vec(rhs, num_rows); }); + this->merge_vec(places, offset, rhs, arena, num_rows); + } + + void deserialize_and_merge_vec_selected(const AggregateDataPtr* places, size_t offset, + AggregateDataPtr rhs, const ColumnString* column, + Arena* arena, const size_t num_rows) const override { + this->deserialize_from_column(rhs, *column, arena, num_rows); + DEFER({ this->destroy_vec(rhs, num_rows); }); + this->merge_vec_selected(places, offset, rhs, arena, num_rows); + } + void deserialize_and_merge_from_column(AggregateDataPtr __restrict place, const IColumn& column, Arena* arena) const override { auto data = assert_cast<const ColumnUInt64&>(column).get_data().data(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
