From 2cb3dd034f2a1484cf075d1d4fdbe6d1f3b1dd83 Mon Sep 17 00:00:00 2001
From: discord9 <discord9@163.com>
Date: Wed, 18 Dec 2024 19:42:36 +0800
Subject: [PATCH] chore: rename

---
 src/flow/src/adapter/flownode_impl.rs | 4 ++--
 src/flow/src/adapter/util.rs          | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/flow/src/adapter/flownode_impl.rs b/src/flow/src/adapter/flownode_impl.rs
index ce72d7a35af3..1fa11b4d83a2 100644
--- a/src/flow/src/adapter/flownode_impl.rs
+++ b/src/flow/src/adapter/flownode_impl.rs
@@ -28,7 +28,7 @@ use itertools::Itertools;
 use snafu::{OptionExt, ResultExt};
 use store_api::storage::RegionId;
 
-use super::util::from_proto_to_column_schema;
+use super::util::from_proto_to_data_type;
 use crate::adapter::{CreateFlowArgs, FlowWorkerManager};
 use crate::error::InternalSnafu;
 use crate::metrics::METRIC_FLOW_TASK_COUNT;
@@ -209,7 +209,7 @@ impl Flownode for FlowWorkerManager {
                 .collect_vec();
             let batch_datatypes = insert_schema
                 .iter()
-                .map(from_proto_to_column_schema)
+                .map(from_proto_to_data_type)
                 .collect::<std::result::Result<Vec<_>, _>>()
                 .map_err(to_meta_err)?;
             self.handle_write_request(region_id.into(), rows, &batch_datatypes)
diff --git a/src/flow/src/adapter/util.rs b/src/flow/src/adapter/util.rs
index a9da8ef2c35a..f2a29bec8e9e 100644
--- a/src/flow/src/adapter/util.rs
+++ b/src/flow/src/adapter/util.rs
@@ -23,7 +23,7 @@ use snafu::ResultExt;
 
 use crate::error::{Error, ExternalSnafu};
 
-pub fn from_proto_to_column_schema(
+pub fn from_proto_to_data_type(
     column_schema: &api::v1::ColumnSchema,
 ) -> Result<ConcreteDataType, Error> {
     let wrapper = ColumnDataTypeWrapper::try_new(