update

Author: Gabriel39

be/src/exec/schema_scanner.cpp

@@ -54,6 +54,7 @@
 #include "pipeline/dependency.h"
 #include "runtime/define_primitive_type.h"
 #include "runtime/fragment_mgr.h"
+#include "runtime/types.h"
 #include "util/string_util.h"
 #include "util/types.h"
 #include "vec/columns/column.h"
@@ -67,6 +68,7 @@
 #include "vec/core/column_with_type_and_name.h"
 #include "vec/core/types.h"
 #include "vec/data_types/data_type.h"
+#include "vec/data_types/data_type_factory.hpp"
 
 namespace doris {
 class ObjectPool;
@@ -191,6 +193,16 @@ std::unique_ptr<SchemaScanner> SchemaScanner::create(TSchemaTableType::type type
     }
 }
 
+void SchemaScanner::init_block(vectorized::Block* src_block) {
+    const std::vector<SchemaScanner::ColumnDesc>& columns_desc(get_column_desc());
+    for (int i = 0; i < columns_desc.size(); ++i) {
+        TypeDescriptor descriptor(columns_desc[i].type);
+        auto data_type = vectorized::DataTypeFactory::instance().create_data_type(descriptor, true);
+        src_block->insert(vectorized::ColumnWithTypeAndName(data_type->create_column(), data_type,
+                                                            columns_desc[i].name));
+    }
+}
+
 Status SchemaScanner::fill_dest_column_for_range(vectorized::Block* block, size_t pos,
                                                  const std::vector<void*>& datas) {
     const ColumnDesc& col_desc = _columns[pos];

be/src/exec/schema_scanner.h

@@ -112,16 +112,7 @@ class SchemaScanner {
         _finish_dependency = fin_dep;
     }
 
-    void init_block(vectorized::Block* src_block) {
-        const std::vector<SchemaScanner::ColumnDesc>& columns_desc(get_column_desc());
-        for (int i = 0; i < columns_desc.size(); ++i) {
-            TypeDescriptor descriptor(columns_desc[i].type);
-            auto data_type =
-                    vectorized::DataTypeFactory::instance().create_data_type(descriptor, true);
-            src_block->insert(vectorized::ColumnWithTypeAndName(data_type->create_column(),
-                                                                data_type, columns_desc[i].name));
-        }
-    }
+    void init_block(vectorized::Block* src_block);
 
 protected:
     // For async scanner (which has blocking operation (e.g. RPC), this function should return true