[fix](agg) Add the unimplemented functions in 'AggregateFunctionCount…

…NotNullUnaryOld' (apache#24310) Similar to apache#24211
w41ter · Sep 14, 2023 · 539a7c2 · 539a7c2
1 parent 93a9f10
commit 539a7c2
Showing 1 changed file with 16 additions and 0 deletions.
diff --git 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 @@ class AggregateFunctionCountNotNullUnaryOld final
         }
     }
 
+    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();